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 781518c132235751784804a5e7641d71d953dfb8..0240707a30189fbcf36d61b34f36f698bf01459c 100644 (file)
--- 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 6cf8732bfef1ccf644f4f65413b62da2f8dc0538..bff2a61882e8565284962ddb633c8b7396439b0f 100644 (file)
--- 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;