afr: Support readdirp fop

Signed-off-by: Anand V. Avati <avati@dev.gluster.com>

BUG: 292 (Separate readdirp functionality from readdir fop)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=292

1 files changed, 72 insertions, 10 deletions

diff --git a/xlators/cluster/afr/src/afr-dir-read.c b/xlators/cluster/afr/src/afr-dir-read.c
index f1638c740..e259f624b 100644
--- a/xlators/cluster/afr/src/afr-dir-read.c
+++ b/xlators/cluster/afr/src/afr-dir-read.c
@@ -180,8 +180,45 @@ afr_readdir_cbk (call_frame_t *frame, void *cookie,
 
 
 int32_t
-afr_readdir (call_frame_t *frame, xlator_t *this,
-	     fd_t *fd, size_t size, off_t offset)
+afr_readdirp_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
+                  int32_t op_ret, int32_t op_errno, gf_dirent_t *entries)
+{
+        afr_private_t * priv     = NULL;
+        afr_local_t *   local    = NULL;
+        xlator_t **     children = NULL;
+        ino_t           inum = 0;
+
+        gf_dirent_t * entry = NULL;
+
+        int child_index = -1;
+
+        priv     = this->private;
+        children = priv->children;
+
+        local = frame->local;
+
+        child_index = (long) cookie;
+
+        if (op_ret != -1) {
+                list_for_each_entry (entry, &entries->list, list) {
+                        inum = afr_itransform (entry->d_ino, priv->child_count,
+                                               child_index);
+                        entry->d_ino = inum;
+                        inum  = afr_itransform (entry->d_stat.st_ino,
+                                                priv->child_count, child_index);
+                        entry->d_stat.st_ino = inum;
+                }
+        }
+
+        AFR_STACK_UNWIND (frame, op_ret, op_errno, entries);
+
+        return 0;
+}
+
+
+int32_t
+afr_do_readdir (call_frame_t *frame, xlator_t *this,
+	        fd_t *fd, size_t size, off_t offset, int whichop)
 {
 	afr_private_t * priv       = NULL;
 	xlator_t **     children   = NULL;
@@ -217,14 +254,22 @@ afr_readdir (call_frame_t *frame, xlator_t *this,
 		goto out;
 	}
 
-	local->fd                  = fd_ref (fd);
-	local->cont.readdir.size   = size;
-	local->cont.readdir.offset = offset;
-
-	STACK_WIND_COOKIE (frame, afr_readdir_cbk, (void *) (long) call_child,
-                           children[call_child], 
-                           children[call_child]->fops->readdir,
-                           fd, size, offset);
+        local->fd                  = fd_ref (fd);
+        local->cont.readdir.size   = size;
+        local->cont.readdir.offset = offset;
+
+        if (whichop == GF_FOP_READDIR)
+                STACK_WIND_COOKIE (frame, afr_readdir_cbk,
+                                   (void *) (long) call_child,
+                                   children[call_child],
+                                   children[call_child]->fops->readdir, fd,
+                                   size, offset);
+        else
+                STACK_WIND_COOKIE (frame, afr_readdirp_cbk,
+                                   (void *) (long) call_child,
+                                   children[call_child],
+                                   children[call_child]->fops->readdirp, fd,
+                                   size, offset);
 
 	op_ret = 0;
 out:
@@ -236,6 +281,23 @@ out:
 
 
 int32_t
+afr_readdir (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
+             off_t offset)
+{
+        afr_do_readdir (frame, this, fd, size, offset, GF_FOP_READDIR);
+        return 0;
+}
+
+
+int32_t
+afr_readdirp (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
+              off_t offset)
+{
+        afr_do_readdir (frame, this, fd, size, offset, GF_FOP_READDIRP);
+        return 0;
+}
+
+int32_t
 afr_getdents_cbk (call_frame_t *frame, void *cookie,
 		  xlator_t *this, int32_t op_ret, int32_t op_errno,
 		  dir_entry_t *entry, int32_t count)