X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=fd.c;h=1c67f22bb284ab11ffda80bb90c0693661b0328c;hp=8759d5099200c4f6c1b6c31e84b66da3372b5540;hb=b2e6a24448a9e49e0766ab4f32163580eeff469e;hpb=09b7971c7a862924d4ce669f8a33bda567ba570b

diff --git a/fd.c b/fd.c
index 8759d509..1c67f22b 100644
--- a/fd.c
+++ b/fd.c
@@ -14,7 +14,7 @@
 
 #include "para.h"
 #include "error.h"
-
+#include "string.h"
 /**
  * Write a buffer to a file descriptor, re-write on short writes.
  *
@@ -480,3 +480,65 @@ void valid_fd_012(void)
 		}
 	}
 }
+
+/**
+ * Traverse the given directory recursively.
+ *
+ * \param dirname The directory to traverse.
+ * \param func The function to call for each entry.
+ * \param private_data Pointer to an arbitrary data structure.
+ *
+ * For each regular file under \a dirname, the supplied function \a func is
+ * called.  The full path of the regular file and the \a private_data pointer
+ * are passed to \a func. Directories for which the calling process has no
+ * permissions to change to are silently ignored.
+ *
+ * \return Standard.
+ */
+int for_each_file_in_dir(const char *dirname,
+		int (*func)(const char *, void *), void *private_data)
+{
+	DIR *dir;
+	struct dirent *entry;
+	int cwd_fd, ret2, ret = para_opendir(dirname, &dir, &cwd_fd);
+
+	if (ret < 0)
+		return ret == -ERRNO_TO_PARA_ERROR(EACCES)? 1 : ret;
+	/* scan cwd recursively */
+	while ((entry = readdir(dir))) {
+		mode_t m;
+		char *tmp;
+		struct stat s;
+
+		if (!strcmp(entry->d_name, "."))
+			continue;
+		if (!strcmp(entry->d_name, ".."))
+			continue;
+		if (lstat(entry->d_name, &s) == -1)
+			continue;
+		m = s.st_mode;
+		if (!S_ISREG(m) && !S_ISDIR(m))
+			continue;
+		tmp = make_message("%s/%s", dirname, entry->d_name);
+		if (!S_ISDIR(m)) {
+			ret = func(tmp, private_data);
+			free(tmp);
+			if (ret < 0)
+				goto out;
+			continue;
+		}
+		/* directory */
+		ret = for_each_file_in_dir(tmp, func, private_data);
+		free(tmp);
+		if (ret < 0)
+			goto out;
+	}
+	ret = 1;
+out:
+	closedir(dir);
+	ret2 = para_fchdir(cwd_fd);
+	if (ret2 < 0 && ret >= 0)
+		ret = ret2;
+	close(cwd_fd);
+	return ret;
+}