msg/async: avoid lossy connection sending ack message

Signed-off-by: Haomai Wang <haomai@xsky.com>

diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc
index 082942cc4448c09f5bc55182f9ddebeea2a7a91b..824fd272d2c84b892a7d20107ad2da01b447da79 100644 (file)
--- a/src/msg/async/AsyncConnection.cc
+++ b/src/msg/async/AsyncConnection.cc
@@ -768,8 +768,10 @@ void AsyncConnection::process()
                                     << message->get_seq() << " " << message
                                    << " " << *message << dendl;
 
-          ack_left.inc();
-          need_dispatch_writer = true;
+          if (!policy.lossy) {
+            ack_left.inc();
+            need_dispatch_writer = true;
+          }
           state = STATE_OPEN;
 
           logger->inc(l_msgr_recv_messages);