From: Haomai Wang <haomaiwang@gmail.com>
Date: Wed, 28 Jan 2015 15:57:16 +0000 (+0800)
Subject: async: add same behavior when message seq mismatch with simple
X-Git-Tag: v0.93~136^2~1
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=1cb10d7aa79b06d16cd508692aa78033af4d9c99;p=ceph.git

async: add same behavior when message seq mismatch with simple

Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
---

diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc
index d2db0ebd0adf..3ca6a1163965 100644
--- a/src/msg/async/AsyncConnection.cc
+++ b/src/msg/async/AsyncConnection.cc
@@ -830,8 +830,15 @@ void AsyncConnection::process()
             message->put();
             if (has_feature(CEPH_FEATURE_RECONNECT_SEQ) && async_msgr->cct->_conf->ms_die_on_old_message)
               assert(0 == "old msgs despite reconnect_seq feature");
-            goto fail;
+            break;
           }
+          if (message->get_seq() > in_seq + 1) {
+            ldout(async_msgr->cct, 0) << __func__ << " missed message?  skipped from seq "
+                                      << in_seq << " to " << message->get_seq() << dendl;
+            if (async_msgr->cct->_conf->ms_die_on_skipped_message)
+              assert(0 == "skipped incoming seq");
+          }
+
           message->set_connection(this);
 
           // note last received message.