From 26d95559a735a2690f9c95ccd600ea3c27ecb140 Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Tue, 29 Jul 2008 06:57:10 -0700 Subject: [PATCH] msgr: warn+fault on bad seq. but keep assert, for now. --- src/msg/SimpleMessenger.cc | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc index 69239e52950d6..db1d8cfadfa26 100644 --- a/src/msg/SimpleMessenger.cc +++ b/src/msg/SimpleMessenger.cc @@ -1422,7 +1422,17 @@ void Rank::Pipe::reader() continue; } in_seq++; - assert(in_seq == m->get_seq()); + + if (in_seq != m->get_seq()) { + dout(0) << "reader got bad seq " << m->get_seq() << " expected " << in_seq + << " for " << *m << " from " << m->get_source() << dendl; + derr(0) << "reader got bad seq " << m->get_seq() << " expected " << in_seq + << " for " << *m << " from " << m->get_source() << dendl; + assert(in_seq == m->get_seq()); // for now! + fault(); + delete m; + continue; + } if (in_seq == 1) policy = rank.policy_map[m->get_source().type()]; /* apply policy */ -- 2.39.5