From 1cb10d7aa79b06d16cd508692aa78033af4d9c99 Mon Sep 17 00:00:00 2001 From: Haomai Wang Date: Wed, 28 Jan 2015 23:57:16 +0800 Subject: [PATCH] async: add same behavior when message seq mismatch with simple Signed-off-by: Haomai Wang --- src/msg/async/AsyncConnection.cc | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc index d2db0ebd0adf9..3ca6a11639655 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. -- 2.39.5