librbd: pass notifier_id to Watcher handle_notify

Signed-off-by: Mykola Golub <mgolub@mirantis.com>

diff --git a/src/librbd/ImageWatcher.cc b/src/librbd/ImageWatcher.cc
index 55af5bbc55dbdaa3b36fe2481eb8d31e6a288b2f..27f76509519807516d54cf6cb5cf6bb87855f252 100644 (file)
--- a/src/librbd/ImageWatcher.cc
+++ b/src/librbd/ImageWatcher.cc
@@ -891,7 +891,7 @@ void ImageWatcher<I>::process_payload(uint64_t notify_id, uint64_t handle,
 
 template <typename I>
 void ImageWatcher<I>::handle_notify(uint64_t notify_id, uint64_t handle,
-                                   bufferlist &bl) {
+                                   uint64_t notifier_id, bufferlist &bl) {
   NotifyMessage notify_message;
   if (bl.length() == 0) {
     // legacy notification for header updates

diff --git a/src/librbd/ImageWatcher.h b/src/librbd/ImageWatcher.h
index 6ada79831e1d6aec786c6e7cd86c632635b780ef..42d85b32128bba4e03a43ca511d9bf40dce23d99 100644 (file)
--- a/src/librbd/ImageWatcher.h
+++ b/src/librbd/ImageWatcher.h
@@ -246,7 +246,7 @@ private:
                              const watch_notify::Payload &payload, int r);
 
   virtual void handle_notify(uint64_t notify_id, uint64_t handle,
-                             bufferlist &bl);
+                             uint64_t notifier_id, bufferlist &bl);
   virtual void handle_error(uint64_t cookie, int err);
   virtual void handle_rewatch_complete(int r);
 

diff --git a/src/librbd/MirroringWatcher.cc b/src/librbd/MirroringWatcher.cc
index d8b829947bda086f87c7cb3c08a262f7df60beaf..ef83c21c580c2057a8c3d3a51d10445a33cd7466 100644 (file)
--- a/src/librbd/MirroringWatcher.cc
+++ b/src/librbd/MirroringWatcher.cc
@@ -86,7 +86,7 @@ void MirroringWatcher<I>::notify_image_updated(
 
 template <typename I>
 void MirroringWatcher<I>::handle_notify(uint64_t notify_id, uint64_t handle,
-                                        bufferlist &bl) {
+                                        uint64_t notifier_id, bufferlist &bl) {
   CephContext *cct = this->m_cct;
   ldout(cct, 15) << ": notify_id=" << notify_id << ", "
                  << "handle=" << handle << dendl;

diff --git a/src/librbd/MirroringWatcher.h b/src/librbd/MirroringWatcher.h
index 1f385c5d10f7a0a5d080e23017b6879821a142a2..45925b4c7eef12349645eff22d80b094222d165e 100644 (file)
--- a/src/librbd/MirroringWatcher.h
+++ b/src/librbd/MirroringWatcher.h
@@ -59,7 +59,7 @@ private:
                       Context *on_notify_ack);
 
   virtual void handle_notify(uint64_t notify_id, uint64_t handle,
-                             bufferlist &bl);
+                             uint64_t notifier_id, bufferlist &bl);
 };
 
 } // namespace librbd

diff --git a/src/librbd/Watcher.cc b/src/librbd/Watcher.cc
index 528a7c22201ad164baf72a68a55c1dae017fd4d9..edf15d102d7c4fe43d6bdc19df7be64036cc9c77 100644 (file)
--- a/src/librbd/Watcher.cc
+++ b/src/librbd/Watcher.cc
@@ -217,7 +217,7 @@ void Watcher::WatchCtx::handle_notify(uint64_t notify_id,
                                                uint64_t handle,
                                                uint64_t notifier_id,
                                                bufferlist& bl) {
-  watcher.handle_notify(notify_id, handle, bl);
+  watcher.handle_notify(notify_id, handle, notifier_id, bl);
 }
 
 void Watcher::WatchCtx::handle_error(uint64_t handle, int err) {

diff --git a/src/librbd/Watcher.h b/src/librbd/Watcher.h
index 04806f2d91cddcee2ab7b40f74fc372c08470e7b..bf4b94080dbdf715cfcc37a3459c5a7568e2f3b8 100644 (file)
--- a/src/librbd/Watcher.h
+++ b/src/librbd/Watcher.h
@@ -61,7 +61,7 @@ protected:
                    Context *on_finish = nullptr);
 
   virtual void handle_notify(uint64_t notify_id, uint64_t handle,
-                             bufferlist &bl) = 0;
+                             uint64_t notifier_id, bufferlist &bl) = 0;
 
   virtual void handle_error(uint64_t cookie, int err);
 

diff --git a/src/tools/rbd_mirror/Replayer.cc b/src/tools/rbd_mirror/Replayer.cc
index 346a9c0e277c9a1a5239e65bad91df8a008c189e..5223aa2c29c65dff3c4911f3b104e6ca4c014fd5 100644 (file)
--- a/src/tools/rbd_mirror/Replayer.cc
+++ b/src/tools/rbd_mirror/Replayer.cc
@@ -220,7 +220,7 @@ private:
     }
 
     virtual void handle_notify(uint64_t notify_id, uint64_t handle,
-                               bufferlist &bl) {
+                               uint64_t notifier_id, bufferlist &bl) {
       bufferlist out;
       acknowledge_notify(notify_id, handle, out);
     }