update sources to v12.1.0

[ceph.git] / ceph / src / tools / rbd_mirror / PoolReplayer.h

diff --git a/ceph/src/tools/rbd_mirror/PoolReplayer.h b/ceph/src/tools/rbd_mirror/PoolReplayer.h
index 87a6589356eb116b45138ffc5b249c15f8626aef..09ad6835d9c5a85ad2b9f8db1e84ab29ca3866e5 100644 (file)
--- a/ceph/src/tools/rbd_mirror/PoolReplayer.h
+++ b/ceph/src/tools/rbd_mirror/PoolReplayer.h
@@ -40,7 +40,6 @@ class PoolReplayer {
 public:
   PoolReplayer(Threads<librbd::ImageCtx> *threads,
               std::shared_ptr<ImageDeleter> image_deleter,
-              ImageSyncThrottlerRef<> image_sync_throttler,
               int64_t local_pool_id, const peer_t &peer,
               const std::vector<const char*> &args);
   ~PoolReplayer();
@@ -100,9 +99,10 @@ private:
   void wait_for_update_ops(Context *on_finish);
   void handle_wait_for_update_ops(int r, Context *on_finish);
 
+  void handle_update_leader(const std::string &leader_instance_id);
+
   Threads<librbd::ImageCtx> *m_threads;
   std::shared_ptr<ImageDeleter> m_image_deleter;
-  ImageSyncThrottlerRef<> m_image_sync_throttler;
   mutable Mutex m_lock;
   Cond m_cond;
   std::atomic<bool> m_stopping = { false };
@@ -159,6 +159,11 @@ private:
       m_pool_replayer->handle_pre_release_leader(on_finish);
     }
 
+    void update_leader_handler(
+      const std::string &leader_instance_id) override {
+      m_pool_replayer->handle_update_leader(leader_instance_id);
+    }
+
   private:
     PoolReplayer *m_pool_replayer;
   } m_leader_listener;