diff options
| author | shishir gowda <shishirng@gluster.com> | 2011-03-22 04:43:56 +0000 |
|---|---|---|
| committer | Vijay Bellur <vijay@dev.gluster.com> | 2011-03-25 04:11:49 -0700 |
| commit | cd3d977b10e24c4b46e55f9831113aba3a241583 (patch) | |
| tree | 3b965765e7bcd25b603c71b0ce195b9bafdaa0c0 | |
| parent | 0ed446b7c8c8bcda74a5d64cdb8f0ac2d11b2389 (diff) | |
Process dir/link from other subvol if error in dht_readdir
Signed-off-by: shishir gowda <shishirng@gluster.com>
Signed-off-by: Vijay Bellur <vijay@dev.gluster.com>
BUG: 2137 (dhtafr - self heal after renaming directory)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=2137
| -rw-r--r-- | xlators/cluster/dht/src/dht-common.c | 21 |
1 files changed, 17 insertions, 4 deletions
diff --git a/xlators/cluster/dht/src/dht-common.c b/xlators/cluster/dht/src/dht-common.c index 5042ad06555..25aa3c444db 100644 --- a/xlators/cluster/dht/src/dht-common.c +++ b/xlators/cluster/dht/src/dht-common.c @@ -2898,13 +2898,20 @@ dht_readdirp_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int op_ret, int count = 0; dht_layout_t *layout = 0; dht_conf_t *conf = NULL; - xlator_t *subvol = 0; + xlator_t *subvol = NULL; + uint64_t value = 0; INIT_LIST_HEAD (&entries.list); prev = cookie; local = frame->local; conf = this->private; + if (!fd_ctx_get (local->fd, this, &value)) + subvol = (xlator_t *)(long)value; + + if (!subvol) + goto unwind; + if (op_ret < 0) goto done; @@ -2918,7 +2925,7 @@ dht_readdirp_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int op_ret, if (check_is_linkfile (NULL, (&orig_entry->d_stat), NULL) || (check_is_dir (NULL, (&orig_entry->d_stat), NULL) - && (prev->this != dht_first_up_subvol (this)))) { + && (prev->this != subvol))) { continue; } @@ -2977,6 +2984,9 @@ done: if (!next_subvol) { goto unwind; } + if ((op_ret < 0) && (prev->this == subvol)) + fd_ctx_set (local->fd, this, + (uint64_t)(long)next_subvol); STACK_WIND (frame, dht_readdirp_cbk, next_subvol, next_subvol->fops->readdirp, @@ -3128,10 +3138,13 @@ dht_do_readdir (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size, if (whichop == GF_FOP_READDIR) STACK_WIND (frame, dht_readdir_cbk, xvol, xvol->fops->readdir, fd, size, xoff); - else + else { + if (yoff == 0) + fd_ctx_set (fd, this, (uint64_t)(long)xvol); + STACK_WIND (frame, dht_readdirp_cbk, xvol, xvol->fops->readdirp, fd, size, xoff); - + } return 0; err: |