From e2ca4eb7da315c5e24fa0e840078716f34813b3f Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Tue, 15 Dec 2009 14:11:16 -0800 Subject: [PATCH] msgr: don't keep sent messages on lossy connections --- src/msg/SimpleMessenger.cc | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc index 665a1e3ce9084..fef87a8d54afa 100644 --- a/src/msg/SimpleMessenger.cc +++ b/src/msg/SimpleMessenger.cc @@ -1577,8 +1577,11 @@ void SimpleMessenger::Pipe::writer() Message *m = _get_next_outgoing(); if (m) { m->set_seq(++out_seq); - sent.push_back(m); // move to sent list - m->get(); + if (!policy.lossy) { + // put on sent list + sent.push_back(m); + m->get(); + } pipe_lock.Unlock(); dout(20) << "writer encoding " << m->get_seq() << " " << m << " " << *m << dendl; -- 2.39.5