From 7892306e0f4d50d80107c9b57b3bbeb8a304ef55 Mon Sep 17 00:00:00 2001
From: Sakshi Bansal <sabansal@redhat.com>
Date: Tue, 17 May 2016 13:23:28 +0530
Subject: [PATCH 159/167] 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.

upstream patch : http://review.gluster.org/#/c/14371/
3.7 release : http://review.gluster.org/#/c/14407/

Change-Id: I24a34605a2cd65984910643ff5462f35e8fc7e71
BUG: 1118762
Signed-off-by: Sakshi Bansal <sabansal@redhat.com>
Reviewed-on: https://code.engineering.redhat.com/gerrit/74661
Reviewed-by: Raghavendra Gowdappa <rgowdapp@redhat.com>
Tested-by: Raghavendra Gowdappa <rgowdapp@redhat.com>
---
 xlators/cluster/dht/src/dht-rename.c |   39 +++++++++++++++++++++++++++------
 1 files changed, 32 insertions(+), 7 deletions(-)

diff --git a/xlators/cluster/dht/src/dht-rename.c b/xlators/cluster/dht/src/dht-rename.c
index c9a39b7..82a97bc 100644
--- a/xlators/cluster/dht/src/dht-rename.c
+++ b/xlators/cluster/dht/src/dht-rename.c
@@ -326,6 +326,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;
@@ -344,6 +345,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++) {
@@ -384,22 +390,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;
 
@@ -413,6 +436,7 @@ dht_rename_dir (call_frame_t *frame, xlator_t *this)
                 goto err;
         }
 
+        loc_wipe (&parent_loc);
         return 0;
 
 err:
@@ -421,6 +445,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);
-- 
1.7.1