]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd: Use crimson::net::make_message() in Watch
authorAmnon Hanuhov <ahanukov@redhat.com>
Tue, 13 Apr 2021 12:27:15 +0000 (15:27 +0300)
committerAmnon Hanuhov <ahanukov@redhat.com>
Thu, 6 May 2021 17:22:06 +0000 (20:22 +0300)
Signed-off-by: Amnon Hanuhov <ahanukov@redhat.com>
src/crimson/osd/watch.cc

index 856eafd9c3c8218aa79d82472d0178332030a101..5639eca0609334bef219a1f5c5cba823dcbbeb57 100644 (file)
@@ -36,7 +36,7 @@ seastar::future<> Watch::connect(crimson::net::ConnectionRef conn, bool)
 seastar::future<> Watch::send_notify_msg(NotifyRef notify)
 {
   logger().info("{} for notify(id={})", __func__, notify->ninfo.notify_id);
-  return conn->send(make_message<MWatchNotify>(
+  return conn->send(crimson::net::make_message<MWatchNotify>(
     winfo.cookie,
     notify->user_version,
     notify->ninfo.notify_id,
@@ -75,7 +75,7 @@ seastar::future<> Watch::send_disconnect_msg()
     return seastar::now();
   }
   ceph::bufferlist empty;
-  return conn->send(make_message<MWatchNotify>(
+  return conn->send(crimson::net::make_message<MWatchNotify>(
     winfo.cookie,
     0,
     0,
@@ -183,7 +183,7 @@ seastar::future<> Notify::send_completion(
   logger().debug("{} sending notify replies: {}", __func__, notify_replies);
 
   ceph::bufferlist empty;
-  auto reply = make_message<MWatchNotify>(
+  auto reply = crimson::net::make_message<MWatchNotify>(
     ninfo.cookie,
     user_version,
     ninfo.notify_id,