crimson/osd: Refactor heartbeat::connection::send() to take unique_ptr

Signed-off-by: Amnon Hanuhov <ahanukov@redhat.com>

diff --git a/src/crimson/osd/heartbeat.cc b/src/crimson/osd/heartbeat.cc
index 81ec06ecd5de5421d9237a78fd01657912650b17..d6c4abfa21fe3e69f13ead8eef4ea3d3de6332f1 100644 (file)
--- a/src/crimson/osd/heartbeat.cc
+++ b/src/crimson/osd/heartbeat.cc
@@ -421,10 +421,10 @@ void Heartbeat::Connection::reset()
   }
 }
 
-seastar::future<> Heartbeat::Connection::send(MessageRef msg)
+seastar::future<> Heartbeat::Connection::send(MessageURef msg)
 {
   assert(is_connected);
-  return conn->send(msg);
+  return conn->send(std::move(msg));
 }
 
 void Heartbeat::Connection::validate()

diff --git a/src/crimson/osd/heartbeat.h b/src/crimson/osd/heartbeat.h
index 4947e871ff5adbd582279250abb1cf7beb536500..b4b295abc73bb04b9e5512cc583ebdba64e589b6 100644 (file)
--- a/src/crimson/osd/heartbeat.h
+++ b/src/crimson/osd/heartbeat.h
@@ -189,7 +189,7 @@ class Heartbeat::Connection {
   void accepted(crimson::net::ConnectionRef);
   void replaced();
   void reset();
-  seastar::future<> send(MessageRef msg);
+  seastar::future<> send(MessageURef msg);
   void validate();
   // retry connection if still pending
   void retry();