rgw: RGWBucketPipeSyncStatusManager gets zone name on construction

So we can print it in the user friendly messages to come.

Signed-off-by: Adam C. Emerson <aemerson@redhat.com>

diff --git a/src/rgw/rgw_data_sync.cc b/src/rgw/rgw_data_sync.cc
index 2662a9ab0751fd3e9164784dc8bfbe59fb3bd745..fe420de82d57e4078f4666728d0484300bf8d9bf 100644 (file)
--- a/src/rgw/rgw_data_sync.cc
+++ b/src/rgw/rgw_data_sync.cc
@@ -5370,10 +5370,16 @@ int RGWBucketPipeSyncStatusManager::do_init(const DoutPrefixProvider *dpp)
       ldpp_dout(this, 0) << "connection object to zone " << szone << " does not exist" << dendl;
       return -EINVAL;
     }
+
+    RGWZone* z;
+    if (!(z = store->svc()->zone->find_zone(szone))) {
+      ldpp_dout(this, 0) << "zone " << szone << " does not exist" << dendl;
+      return -EINVAL;
+    }
     sources.emplace_back(&sync_env, szone, conn,
                         pipe.source.get_bucket_info(),
                         pipe.target.get_bucket(),
-                        pipe.handler);
+                        pipe.handler, z->name);
   }
 
   return 0;

diff --git a/src/rgw/rgw_data_sync.h b/src/rgw/rgw_data_sync.h
index 9fcebbbd17b8ee32a3f1fdc12e1416c5694f2794..dde6133770a3694c48672ad033c48f0885236f0c 100644 (file)
--- a/src/rgw/rgw_data_sync.h
+++ b/src/rgw/rgw_data_sync.h
@@ -703,11 +703,14 @@ class RGWBucketPipeSyncStatusManager : public DoutPrefixProvider {
     RGWBucketInfo info;
     rgw_bucket dest;
     RGWBucketSyncFlowManager::pipe_handler handler;
+    std::string zone_name;
 
     source(RGWDataSyncEnv* env, const rgw_zone_id& zone, RGWRESTConn* conn,
           const RGWBucketInfo& info, const rgw_bucket& dest,
-          const RGWBucketSyncFlowManager::pipe_handler& handler)
-      : sc(env, conn, zone), info(info), dest(dest), handler(handler) {}
+          const RGWBucketSyncFlowManager::pipe_handler& handler,
+          const std::string& zone_name)
+      : sc(env, conn, zone), info(info), dest(dest), handler(handler),
+       zone_name(zone_name) {}
   };
   std::vector<source> sources;