From a15341805a50db2ca3ebea27641f10d2157d3fa7 Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Tue, 9 Sep 2008 16:11:30 -0700 Subject: [PATCH] msgr: relax seq checking on lossy channels (incomplete fix) --- src/msg/SimpleMessenger.cc | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc index d63ad532e8f40..21f30f32dd6dd 100644 --- a/src/msg/SimpleMessenger.cc +++ b/src/msg/SimpleMessenger.cc @@ -1423,7 +1423,10 @@ void Rank::Pipe::reader() } in_seq++; - if (in_seq != m->get_seq()) { + if (in_seq == 1) + policy = rank.policy_map[m->get_source().type()]; /* apply policy */ + + if (!policy.is_lossy() && 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 @@ -1434,9 +1437,6 @@ void Rank::Pipe::reader() continue; } - if (in_seq == 1) - policy = rank.policy_map[m->get_source().type()]; /* apply policy */ - cond.Signal(); // wake up writer, to ack this lock.Unlock(); -- 2.39.5