From 7d4bd9400853d0890dbec176b468ab148d206ef7 Mon Sep 17 00:00:00 2001 From: Radoslaw Zarzynski Date: Sat, 2 Mar 2019 14:07:17 +0100 Subject: [PATCH] msg/async, v2: failure of msg decode doesn't block throtlles. Signed-off-by: Radoslaw Zarzynski --- src/msg/async/ProtocolV2.cc | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/msg/async/ProtocolV2.cc b/src/msg/async/ProtocolV2.cc index a34762b1e87..5230436f7e8 100644 --- a/src/msg/async/ProtocolV2.cc +++ b/src/msg/async/ProtocolV2.cc @@ -1328,7 +1328,6 @@ CtPtr ProtocolV2::handle_message() { ltt_recv_stamp = ceph_clock_now(); #endif recv_stamp = ceph_clock_now(); - state = READ_MESSAGE_COMPLETE; // yeah, footer is conveying header ;-). Renaming needed. FIXME. auto header_frame = MessageHeaderFrame::Decode( @@ -1380,6 +1379,8 @@ CtPtr ProtocolV2::handle_message() { if (!message) { ldout(cct, 1) << __func__ << " decode message failed " << dendl; return _fault(); + } else { + state = READ_MESSAGE_COMPLETE; } INTERCEPT(17); -- 2.39.5