RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-20 10:01:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source 
Signed-off-by: Ricardo Dias <rdias@suse.com>
This commit is contained in:
Ricardo Dias 2019-01-25 19:42:37 +00:00
parent 5145120c2e
commit 1b097e8164
No known key found for this signature in database
GPG Key ID: 74390C579BD37B68
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/msg/async/ProtocolV1.cc
View File

@ -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;

2
src/msg/async/ProtocolV2.cc
View File

@ -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;