X-Git-Url: https://git.proxmox.com/?a=blobdiff_plain;f=ceph%2Fsrc%2Fcrimson%2Fnet%2FProtocol.h;h=0343f026025aa9a7fcb56180e651f1f8513abf59;hb=20effc670b57271cb089376d6d0800990e5218d5;hp=dc4e4f2af8f33c188740fd10b6bae8a267191f8d;hpb=a71831dadd1e1f3e0fa70405511f65cc33db0498;p=ceph.git

diff --git a/ceph/src/crimson/net/Protocol.h b/ceph/src/crimson/net/Protocol.h
index dc4e4f2af..0343f0260 100644
--- a/ceph/src/crimson/net/Protocol.h
+++ b/ceph/src/crimson/net/Protocol.h
@@ -56,7 +56,7 @@ class Protocol {
   virtual void trigger_close() = 0;
 
   virtual ceph::bufferlist do_sweep_messages(
-      const std::deque<MessageRef>& msgs,
+      const std::deque<MessageURef>& msgs,
       size_t num_msgs,
       bool require_keepalive,
       std::optional<utime_t> keepalive_ack,
@@ -65,6 +65,13 @@ class Protocol {
   virtual void notify_write() {};
 
   virtual void on_closed() {}
+ 
+ private:
+  ceph::bufferlist sweep_messages_and_move_to_sent(
+      size_t num_msgs,
+      bool require_keepalive,
+      std::optional<utime_t> keepalive_ack,
+      bool require_ack); 
 
  public:
   const proto_t proto_type;
@@ -83,7 +90,7 @@ class Protocol {
 
 // the write state-machine
  public:
-  seastar::future<> send(MessageRef msg);
+  seastar::future<> send(MessageURef msg);
   seastar::future<> keepalive();
 
 // TODO: encapsulate a SessionedSender class