rgw: sync module instance specifies whether user writes supported

Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>

diff --git a/src/rgw/rgw_data_sync.cc b/src/rgw/rgw_data_sync.cc
index 8c36c1bb368c7e4f971993dbb27571f1e1547604..4e13091d3c606f3e52ddf44a675ee4504ce53ca2 100644 (file)
--- a/src/rgw/rgw_data_sync.cc
+++ b/src/rgw/rgw_data_sync.cc
@@ -1652,6 +1652,9 @@ public:
   RGWDataSyncModule *get_data_handler() override {
     return &data_handler;
   }
+  bool supports_user_writes() override {
+    return true;
+  }
 };
 
 int RGWDefaultSyncModule::create_instance(CephContext *cct, const JSONFormattable& config, RGWSyncModuleInstanceRef *instance)

diff --git a/src/rgw/rgw_sync_module.h b/src/rgw/rgw_sync_module.h
index 3540d2fb05cf2fc1d58e10617e3df32b2444b1ad..f626489ec5481c12c2baf33b21ad140e10daa411 100644 (file)
--- a/src/rgw/rgw_sync_module.h
+++ b/src/rgw/rgw_sync_module.h
@@ -42,6 +42,9 @@ public:
   virtual RGWRESTMgr *get_rest_filter(int dialect, RGWRESTMgr *orig) {
     return orig;
   }
+  virtual bool supports_user_writes() {
+    return false;
+  }
 };
 
 typedef std::shared_ptr<RGWSyncModuleInstance> RGWSyncModuleInstanceRef;

diff --git a/src/rgw/rgw_sync_module_es.h b/src/rgw/rgw_sync_module_es.h
index 7dcda39cbf72b3bbc12b9fcaa66988e1c7620604..f7c46b54c9f909463b8589d288b7043943141a7f 100644 (file)
--- a/src/rgw/rgw_sync_module_es.h
+++ b/src/rgw/rgw_sync_module_es.h
@@ -23,6 +23,9 @@ public:
   RGWRESTMgr *get_rest_filter(int dialect, RGWRESTMgr *orig) override;
   RGWRESTConn *get_rest_conn();
   std::string get_index_path();
+  bool supports_user_writes() override {
+    return true;
+  }
 };
 
 #endif

diff --git a/src/rgw/rgw_sync_module_pubsub.h b/src/rgw/rgw_sync_module_pubsub.h
index a7e91cfe28d8740652b3d67d91508bdf722cd8fe..b12bf904583801d45bcccf4dc93f2d15666b5fb0 100644 (file)
--- a/src/rgw/rgw_sync_module_pubsub.h
+++ b/src/rgw/rgw_sync_module_pubsub.h
@@ -21,6 +21,9 @@ public:
   RGWPSSyncModuleInstance(CephContext *cct, const JSONFormattable& config);
   RGWDataSyncModule *get_data_handler() override;
   RGWRESTMgr *get_rest_filter(int dialect, RGWRESTMgr *orig) override;
+  bool supports_user_writes() override {
+    return true;
+  }
 };
 
 #endif

diff --git a/src/rgw/services/svc_zone.cc b/src/rgw/services/svc_zone.cc
index 2e1e67706808ee62627c9ba93c36025b72d822d7..614f11d0b9ad54fe86b543a80bfdefcfdc79de87 100644 (file)
--- a/src/rgw/services/svc_zone.cc
+++ b/src/rgw/services/svc_zone.cc
@@ -151,6 +151,7 @@ int RGWSI_Zone::do_start()
 
   zone_short_id = current_period->get_map().get_zone_short_id(zone_params->get_id());
 
+#warning FIXME
   writeable_zone = (zone_public_config->tier_type.empty() || zone_public_config->tier_type == "rgw");
 
   /* first build all zones index */