gsyncd: distribute the crawling load

* also consume changelog for change detection.
* Status fixes
* Use new libgfchangelog done API
* process (and sync) one changelog at a time

Change-Id: I24891615bb762e0741b1819ddfdef8802326cb16
BUG: 847839
Original Author: Csaba Henk <csaba@redhat.com>
Original Author: Aravinda VK <avishwan@redhat.com>
Original Author: Venky Shankar <vshankar@redhat.com>
Original Author: Amar Tumballi <amarts@redhat.com>
Original Author: Avra Sengupta <asengupt@redhat.com>
Signed-off-by: Avra Sengupta <asengupt@redhat.com>
Reviewed-on: http://review.gluster.org/5131
Reviewed-by: Vijay Bellur <vbellur@redhat.com>
Tested-by: Vijay Bellur <vbellur@redhat.com>

1 files changed, 106 insertions, 0 deletions

diff --git a/extras/geo-rep/gsync-sync-gfid.c b/extras/geo-rep/gsync-sync-gfid.c
new file mode 100644
index 00000000000..601f4720e25
--- /dev/null
+++ b/extras/geo-rep/gsync-sync-gfid.c
@@ -0,0 +1,106 @@
+
+#include <stdio.h>
+#include <errno.h>
+#include <string.h>
+#include <limits.h>
+#include <sys/types.h>
+#include <attr/xattr.h>
+#include <libgen.h>
+#include <ctype.h>
+#include <stdlib.h>
+
+#ifndef UUID_CANONICAL_FORM_LEN
+#define UUID_CANONICAL_FORM_LEN 36
+#endif
+
+#ifndef GF_FUSE_AUX_GFID_HEAL
+#define GF_FUSE_AUX_GFID_HEAL    "glusterfs.gfid.heal"
+#endif
+
+#define GLFS_LINE_MAX           (PATH_MAX + (2 * UUID_CANONICAL_FORM_LEN))
+
+int
+main (int argc, char *argv[])
+{
+        char *file                = NULL;
+        char *tmp = NULL;
+        char *tmp1 = NULL;
+        char *parent_dir = NULL;
+        char *gfid                = NULL;
+        char *bname = NULL;
+        int   ret                 = -1;
+        int len = 0;
+        FILE *fp                  = NULL;
+        char  line[GLFS_LINE_MAX] = {0,};
+        char *path = NULL;
+        void  *blob               = NULL;
+        void  *tmp_blob               = NULL;
+
+        if (argc != 2) {
+                /* each line in the file has the following format
+                 * uuid-in-canonical-form path-relative-to-gluster-mount.
+                 * Both uuid and relative path are from master mount.
+                 */
+                fprintf (stderr, "usage: %s <file-of-paths-to-be-synced>\n",
+                         argv[0]);
+                goto out;
+        }
+
+        file = argv[1];
+
+        fp = fopen (file, "r");
+        if (fp == NULL) {
+                fprintf (stderr, "cannot open %s for reading (%s)\n",
+                         file, strerror (errno));
+                goto out;
+        }
+
+        while (fgets (line, GLFS_LINE_MAX, fp) != NULL) {
+                tmp = line;
+                path = gfid = line;
+
+                path += UUID_CANONICAL_FORM_LEN + 1;
+
+                while(isspace (*path))
+                        path++;
+
+                if ((strlen (line) < GLFS_LINE_MAX) &&
+                    (line[strlen (line) - 1] == '\n'))
+                        line[strlen (line) - 1] = '\0';
+
+                line[UUID_CANONICAL_FORM_LEN] = '\0';
+
+                tmp = strdup (path);
+                tmp1 = strdup (path);
+                parent_dir = dirname (tmp);
+                bname = basename (tmp1);
+
+                /* gfid + '\0' + bname + '\0' */
+                len = UUID_CANONICAL_FORM_LEN + 1 + strlen (bname) + 1;
+
+                blob = calloc (1, len);
+
+                memcpy (blob, gfid, UUID_CANONICAL_FORM_LEN);
+
+                tmp_blob = blob + UUID_CANONICAL_FORM_LEN + 1;
+
+                memcpy (tmp_blob, bname, strlen (bname));
+
+                ret = setxattr (parent_dir, GF_FUSE_AUX_GFID_HEAL, blob, len,
+                                0);
+                if (ret < 0) {
+                        fprintf (stderr, "setxattr on %s/%s failed (%s)\n",
+                                 parent_dir, bname, strerror (errno));
+                }
+                memset (line, 0, GLFS_LINE_MAX);
+
+                free (blob);
+                free (tmp); free (tmp1);
+                blob = NULL;
+        }
+
+        ret = 0;
+out:
+        return ret;
+}
+