From: Radoslaw Zarzynski <rzarzyns@redhat.com>
Date: Sat, 2 Mar 2019 13:07:17 +0000 (+0100)
Subject: msg/async, v2: failure of msg decode doesn't block throtlles.
X-Git-Tag: v14.1.1~70^2~4
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=7d4bd9400853d0890dbec176b468ab148d206ef7;p=ceph.git

msg/async, v2: failure of msg decode doesn't block throtlles.

Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
---

diff --git a/src/msg/async/ProtocolV2.cc b/src/msg/async/ProtocolV2.cc
index a34762b1e873..5230436f7e86 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);