msgr: don't keep sent messages on lossy connections

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 665a1e3ce90849a67e534d4be5a3f788f5ded0b2..fef87a8d54afad169b8b776a3cc4ca2ddaa6391d 100644 (file)
--- 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;