From: Ricardo Dias <rdias@suse.com>
Date: Fri, 25 Jan 2019 19:42:37 +0000 (+0000)
Subject: msg/async: msgr2: don't force write event on every message received
X-Git-Tag: v14.1.0~271^2~10
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=1b097e8164896c4e463a6fbfe174451ef4c6c878;p=ceph.git

msg/async: msgr2: don't force write event on every message received

Signed-off-by: Ricardo Dias <rdias@suse.com>
---

diff --git a/src/msg/async/ProtocolV1.cc b/src/msg/async/ProtocolV1.cc
index 781518c13223..0240707a3018 100644
--- a/src/msg/async/ProtocolV1.cc
+++ b/src/msg/async/ProtocolV1.cc
@@ -983,7 +983,7 @@ CtPtr ProtocolV1::handle_message_footer(char *buffer, int r) {
                 << message->get_seq() << " " << message << " " << *message
                 << dendl;
 
-  bool need_dispatch_writer = true;
+  bool need_dispatch_writer = false;
   if (!connection->policy.lossy) {
     ack_left++;
     need_dispatch_writer = true;
diff --git a/src/msg/async/ProtocolV2.cc b/src/msg/async/ProtocolV2.cc
index 6cf8732bfef1..bff2a61882e8 100644
--- a/src/msg/async/ProtocolV2.cc
+++ b/src/msg/async/ProtocolV2.cc
@@ -1944,7 +1944,7 @@ CtPtr ProtocolV2::handle_message_complete() {
                 << " from=" << message->get_source() << " type=" << header.type
                 << " " << *message << dendl;
 
-  bool need_dispatch_writer = true;
+  bool need_dispatch_writer = false;
   if (!connection->policy.lossy) {
     ack_left++;
     need_dispatch_writer = true;