import quincy beta 17.1.0

[ceph.git] / ceph / src / crimson / net / Protocol.h

diff --git a/ceph/src/crimson/net/Protocol.h b/ceph/src/crimson/net/Protocol.h
index dc4e4f2af8f33c188740fd10b6bae8a267191f8d..0343f026025aa9a7fcb56180e651f1f8513abf59 100644 (file)
--- 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