]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
rgw: compilation fixes
authorYehuda Sadeh <yehuda@redhat.com>
Wed, 9 Oct 2019 21:17:40 +0000 (14:17 -0700)
committerYehuda Sadeh <yehuda@redhat.com>
Tue, 28 Jan 2020 18:20:36 +0000 (10:20 -0800)
Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>
src/rgw/rgw_bucket_sync.cc

index 92d70fff1cd6685f9a6bfd787b0839ac908d9c4b..f003fc3ba5c7664bde67f14021a5418393025ee4 100644 (file)
@@ -9,26 +9,10 @@
 
 #define dout_subsys ceph_subsys_rgw
 
-#if 0
-void RGWBucketSyncPolicyInfo::post_init()
-{
-  if (pipes) {
-    return;
-  }
-
-  for (auto& p : *pipes) {
-    auto& pipe = p.second;
-
-    source_zones.insert(pipe.source.zone_id());
-  }
-}
-#endif
-
-
 int RGWBucketSyncPolicyHandler::init()
 {
   const auto& zone_id = zone_svc->get_zone().id;
-  auto& zg = svc.zone->get_zonegroup();
+  auto& zg = zone_svc->get_zonegroup();
 
   if (!bucket_info.sync_policy) {
     return 0;
@@ -53,22 +37,24 @@ int RGWBucketSyncPolicyHandler::init()
         continue;
       }
 
-      /* populate trivial peers */
-      for (auto& rule : target.flow_rules) {
-        set<string> source_zones;
-        set<string> target_zones;
-        rule.get_zone_peers(zone_id, &source_zones, &target_zones);
+      if (target.flow_rules) {
+        /* populate trivial peers */
+        for (auto& rule : *target.flow_rules) {
+          set<string> source_zones;
+          set<string> target_zones;
+          rule.get_zone_peers(zone_id, &source_zones, &target_zones);
 
-        for (auto& sz : source_zones) {
-          peer_info sinfo;
-          sinfo.bucket = bucket_info.bucket;
-          sources[sz].insert(sinfo);
-        }
+          for (auto& sz : source_zones) {
+            peer_info sinfo;
+            sinfo.bucket = bucket_info.bucket;
+            sources[sz].insert(sinfo);
+          }
 
-        for (auto& tz : target_zones) {
-          peer_info tinfo;
-          tinfo.bucket = bucket_info.bucket;
-          targets[tz].insert(tinfo);
+          for (auto& tz : target_zones) {
+            peer_info tinfo;
+            tinfo.bucket = bucket_info.bucket;
+            targets[tz].insert(tinfo);
+          }
         }
       }