cluster/tier: make attach/detach work with new rebalance logic

The new rebalance performance improvements added new
datastructures which were not initialized in the
tier case. Function dht_find_local_subvol_cbk() needs
to accept a list built by lower level DHT translators
in order to build the local subvolumes list.

Change-Id: Iab03fc8e7fadc22debc08cd5bc781b9e3e270497
BUG: 1222088
Signed-off-by: Dan Lambright <dlambrig@redhat.com>
Reviewed-on: http://review.gluster.org/10795
Tested-by: NetBSD Build System <jenkins@build.gluster.org>
Reviewed-by: Shyamsundar Ranganathan <srangana@redhat.com>

2 files changed, 28 insertions, 23 deletions

diff --git a/xlators/cluster/dht/src/dht-common.c b/xlators/cluster/dht/src/dht-common.c
index 545c4796673..d7b41a8f28a 100644
--- a/xlators/cluster/dht/src/dht-common.c
+++ b/xlators/cluster/dht/src/dht-common.c
@@ -2622,6 +2622,9 @@ dht_find_local_subvol_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
         int           this_call_cnt = 0;
         int           ret           = 0;
         char         *uuid_str      = NULL;
+        char         *uuid_list     = NULL;
+        char         *next_uuid_str = NULL;
+        char         *saveptr       = NULL;
         uuid_t        node_uuid     = {0,};
 
 
@@ -2644,7 +2647,7 @@ dht_find_local_subvol_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
                         goto unlock;
                 }
 
-                ret = dict_get_str (xattr, local->xsel, &uuid_str);
+                ret = dict_get_str (xattr, local->xsel, &uuid_list);
 
                 if (ret < 0) {
                         gf_log (this->name, GF_LOG_ERROR, "Failed to "
@@ -2654,22 +2657,29 @@ dht_find_local_subvol_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
                         goto unlock;
                 }
 
-                if (gf_uuid_parse (uuid_str, node_uuid)) {
-                        gf_log (this->name, GF_LOG_ERROR, "Failed to parse uuid"
-                                " failed for %s", prev->this->name);
-                        local->op_ret = -1;
-                        local->op_errno = EINVAL;
-                        goto unlock;
-                }
+                for (uuid_str = strtok_r (uuid_list, " ", &saveptr);
+                     uuid_str;
+                     uuid_str = next_uuid_str) {
 
-                if (gf_uuid_compare (node_uuid, conf->defrag->node_uuid)) {
-                        gf_log (this->name, GF_LOG_DEBUG, "subvol %s does not"
-                                "belong to this node", prev->this->name);
-                } else {
-                        conf->local_subvols[(conf->local_subvols_cnt)++]
-                                                           = prev->this;
-                        gf_log (this->name, GF_LOG_DEBUG, "subvol %s belongs to"
-                                " this node", prev->this->name);
+                        next_uuid_str = strtok_r (NULL, " ", &saveptr);
+                        if (gf_uuid_parse (uuid_str, node_uuid)) {
+                                gf_log (this->name, GF_LOG_ERROR, "Failed to parse uuid"
+                                        " failed for %s", prev->this->name);
+                                local->op_ret = -1;
+                                local->op_errno = EINVAL;
+                                goto unlock;
+                        }
+
+                        if (gf_uuid_compare (node_uuid, conf->defrag->node_uuid)) {
+                                gf_log (this->name, GF_LOG_DEBUG, "subvol %s does not"
+                                        "belong to this node", prev->this->name);
+                        } else {
+                                conf->local_subvols[(conf->local_subvols_cnt)++]
+                                        = prev->this;
+                                gf_log (this->name, GF_LOG_DEBUG, "subvol %s belongs to"
+                                        " this node", prev->this->name);
+                                break;
+                        }
                 }
         }
 
diff --git a/xlators/cluster/dht/src/dht-rebalance.c b/xlators/cluster/dht/src/dht-rebalance.c
index 49e0f879381..b93d0859b50 100644
--- a/xlators/cluster/dht/src/dht-rebalance.c
+++ b/xlators/cluster/dht/src/dht-rebalance.c
@@ -2686,8 +2686,7 @@ gf_defrag_start_crawl (void *data)
                 goto out;
         }
 
-        if ((defrag->cmd != GF_DEFRAG_CMD_START_TIER) &&
-            (defrag->cmd != GF_DEFRAG_CMD_START_LAYOUT_FIX)) {
+        if (defrag->cmd != GF_DEFRAG_CMD_START_LAYOUT_FIX) {
                 migrate_data = dict_new ();
                 if (!migrate_data) {
                         defrag->total_failures++;
@@ -2784,11 +2783,7 @@ gf_defrag_start_crawl (void *data)
                 }
                 methods->migration_other(this, defrag);
                 if (defrag->cmd == GF_DEFRAG_CMD_START_DETACH_TIER) {
-                        migrate_data = dict_new ();
-                        if (!migrate_data) {
-                                ret = -1;
-                                goto out;
-                        }
+
                         ret = dict_set_str (migrate_data,
                                             GF_XATTR_FILE_MIGRATE_KEY,
                                             "force");