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 a34762b1e8730c8b9325cae04f9003daeae51f85..5230436f7e86a9ee688963b94ee4d17eb3afc873 100644 (file)
--- 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);