rgw: add a separate configuration for data notifier interval

Signed-off-by: fang yuxiang <fang.yuxiang@eisoo.com>

diff --git a/src/common/options.cc b/src/common/options.cc
index 85b5a099e300c9a342bb6b81995f4cf1ed209fd1..9de60e8e61247e6ce79701c148f35cfe54328cc9 100644 (file)
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -4656,6 +4656,10 @@ std::vector<Option> get_rgw_options() {
     .set_default("")
     .set_description(""),
 
+    Option("rgw_data_notify_interval_msec", Option::TYPE_INT, Option::LEVEL_ADVANCED)
+    .set_default(200)
+    .set_description("data changes notification interval to followers"),
+
     Option("rgw_torrent_origin", Option::TYPE_STR, Option::LEVEL_ADVANCED)
     .set_default("")
     .set_description(""),

diff --git a/src/rgw/rgw_rados.cc b/src/rgw/rgw_rados.cc
index 4bebea03c0daa0c0fa5c7757883122ac7e71c90f..7a1fce857151b99077ef251e0afaa9ba02cfd1cd 100644 (file)
--- a/src/rgw/rgw_rados.cc
+++ b/src/rgw/rgw_rados.cc
@@ -3115,7 +3115,7 @@ class RGWDataNotifier : public RGWRadosThread {
   RGWDataNotifierManager notify_mgr;
 
   uint64_t interval_msec() override {
-    return cct->_conf->rgw_md_notify_interval_msec;
+    return cct->_conf->get_val<int64_t>("rgw_data_notify_interval_msec");
   }
 public:
   RGWDataNotifier(RGWRados *_store) : RGWRadosThread(_store, "data-notifier"), notify_mgr(_store) {}