From: Haomai Wang <haomai@xsky.com>
Date: Tue, 28 Feb 2017 16:16:55 +0000 (+0800)
Subject: msg/async: avoid lossy connection sending ack message
X-Git-Tag: v12.0.1~91^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=17c464b1a0c2dcb1ada2f2b1027b69e18e179637;p=ceph.git

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 082942cc4448..824fd272d2c8 100644
--- 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);