From: Amnon Hanuhov Date: Tue, 13 Apr 2021 11:05:23 +0000 (+0300) Subject: crimson/osd: Refactor heartbeat::connection::send() to take unique_ptr X-Git-Tag: v17.1.0~2024^2~13 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=c81e08ea58338ed174770ee5f63dfe2834c334be;p=ceph.git crimson/osd: Refactor heartbeat::connection::send() to take unique_ptr Signed-off-by: Amnon Hanuhov --- diff --git a/src/crimson/osd/heartbeat.cc b/src/crimson/osd/heartbeat.cc index 81ec06ecd5de..d6c4abfa21fe 100644 --- 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 4947e871ff5a..b4b295abc73b 100644 --- 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();