From b82fefed59cd3964c4d667b1645e70825be8e984 Mon Sep 17 00:00:00 2001 From: Sakshi Bansal Date: Tue, 17 May 2016 13:23:28 +0530 Subject: dht: rename takes lock on parent directory if destination exists For directory rename if destination exists the source directory is created as a child of the given destination directory. Since the new child directory does not exist take lock on parent of the child directory. Backport of http://review.gluster.org/#/c/14371/ > Change-Id: I24a34605a2cd65984910643ff5462f35e8fc7e71 > BUG: 1336698 > Signed-off-by: Sakshi Bansal Change-Id: I24a34605a2cd65984910643ff5462f35e8fc7e71 BUG: 1337394 Signed-off-by: Sakshi Bansal Reviewed-on: http://review.gluster.org/14417 Smoke: Gluster Build System CentOS-regression: Gluster Build System NetBSD-regression: NetBSD Build System Reviewed-by: Raghavendra G --- xlators/cluster/dht/src/dht-rename.c | 39 +++++++++++++++++++++++++++++------- 1 file changed, 32 insertions(+), 7 deletions(-) (limited to 'xlators/cluster/dht') diff --git a/xlators/cluster/dht/src/dht-rename.c b/xlators/cluster/dht/src/dht-rename.c index 0f90f433180..f4f834c8342 100644 --- a/xlators/cluster/dht/src/dht-rename.c +++ b/xlators/cluster/dht/src/dht-rename.c @@ -321,6 +321,7 @@ dht_rename_dir (call_frame_t *frame, xlator_t *this) dht_lock_t **lk_array = NULL; dht_layout_t *dst_layout = NULL; xlator_t *first_subvol = NULL; + loc_t parent_loc = {0, }; int count = 1; int i = 0; int j = 0; @@ -339,6 +340,11 @@ dht_rename_dir (call_frame_t *frame, xlator_t *this) dst_layout = dht_layout_get (this, local->loc2.inode); if (dst_layout) ++count; + } else if (gf_uuid_compare (local->loc.parent->gfid, + local->loc2.parent->gfid)) { + dst_layout = dht_layout_get (this, local->loc2.parent); + if (dst_layout) + ++count; } for (i = 0; i < conf->subvolume_cnt; i++) { @@ -379,22 +385,39 @@ dht_rename_dir (call_frame_t *frame, xlator_t *this) * rename completes. To avoid a lookup selfheal to change dst layout * during this interval we take a lock on one subvol of dst. */ - if (dst_layout) { - for (j = 0; (j < dst_layout->cnt) && - (dst_layout->list[j].err == 0); j++) { + for (j = 0; dst_layout && (j < dst_layout->cnt) && + (dst_layout->list[j].err == 0); j++) { - first_subvol = dst_layout->list[j].xlator; + first_subvol = dst_layout->list[j].xlator; + if (local->loc2.inode) { lk_array[i] = dht_lock_new (frame->this, first_subvol, &local->loc2, F_WRLCK, DHT_LAYOUT_HEAL_DOMAIN); - if (lk_array[i] == NULL) { - op_errno = ENOMEM; + } else { + ret = dht_build_parent_loc (this, &parent_loc, + &local->loc2, &op_errno); + if (ret) { + gf_msg (this->name, GF_LOG_ERROR, ENOMEM, + DHT_MSG_NO_MEMORY, + "parent loc build failed"); goto err; } - break; + + lk_array[i] = dht_lock_new (frame->this, first_subvol, + &parent_loc, F_WRLCK, + DHT_LAYOUT_HEAL_DOMAIN); } + + if (lk_array[i] == NULL) { + op_errno = ENOMEM; + goto err; + } + break; } + if (!lk_array[i]) + --count; + local->lock.locks = lk_array; local->lock.lk_count = count; @@ -408,6 +431,7 @@ dht_rename_dir (call_frame_t *frame, xlator_t *this) goto err; } + loc_wipe (&parent_loc); return 0; err: @@ -416,6 +440,7 @@ err: GF_FREE (lk_array); } + loc_wipe (&parent_loc); op_errno = (op_errno == -1) ? errno : op_errno; DHT_STACK_UNWIND (rename, frame, -1, op_errno, NULL, NULL, NULL, NULL, NULL, NULL); -- cgit