update sources to v12.2.1

[ceph.git] / ceph / src / tools / rbd_mirror / ImageSyncThrottler.cc

diff --git a/ceph/src/tools/rbd_mirror/ImageSyncThrottler.cc b/ceph/src/tools/rbd_mirror/ImageSyncThrottler.cc
index e5d08cea5f48e8203e450878e2946a836ad44d49..dfa96ed4d3e463f3a21faca658958aa54398e99f 100644 (file)
--- a/ceph/src/tools/rbd_mirror/ImageSyncThrottler.cc
+++ b/ceph/src/tools/rbd_mirror/ImageSyncThrottler.cc
@@ -31,8 +31,8 @@ template <typename I>
 ImageSyncThrottler<I>::ImageSyncThrottler()
   : m_lock(librbd::util::unique_lock_name("rbd::mirror::ImageSyncThrottler",
                                           this)),
-    m_max_concurrent_syncs(
-      g_ceph_context->_conf->rbd_mirror_concurrent_image_syncs) {
+    m_max_concurrent_syncs(g_ceph_context->_conf->get_val<uint64_t>(
+      "rbd_mirror_concurrent_image_syncs")) {
   dout(20) << "max_concurrent_syncs=" << m_max_concurrent_syncs << dendl;
   g_ceph_context->_conf->add_observer(this);
 }
@@ -205,7 +205,7 @@ template <typename I>
 void ImageSyncThrottler<I>::handle_conf_change(const struct md_config_t *conf,
                                       const set<string> &changed) {
   if (changed.count("rbd_mirror_concurrent_image_syncs")) {
-    set_max_concurrent_syncs(conf->rbd_mirror_concurrent_image_syncs);
+    set_max_concurrent_syncs(conf->get_val<uint64_t>("rbd_mirror_concurrent_image_syncs"));
   }
 }