From: Amnon Hanuhov Date: Tue, 13 Apr 2021 12:27:15 +0000 (+0300) Subject: crimson/osd: Use crimson::net::make_message() in Watch X-Git-Tag: v17.1.0~2024^2~5 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=31cab8821d2129128c6fc69b47ae13cb0846f905;p=ceph.git crimson/osd: Use crimson::net::make_message() in Watch Signed-off-by: Amnon Hanuhov --- diff --git a/src/crimson/osd/watch.cc b/src/crimson/osd/watch.cc index 856eafd9c3c..5639eca0609 100644 --- a/src/crimson/osd/watch.cc +++ b/src/crimson/osd/watch.cc @@ -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( + return conn->send(crimson::net::make_message( 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( + return conn->send(crimson::net::make_message( 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( + auto reply = crimson::net::make_message( ninfo.cookie, user_version, ninfo.notify_id,