msg/Pipe: if we send a wait, make sure we follow through

Mark our outgoing connection attempt if we send a WAIT in accept().  This
ensures we don't go to standby or closed in fault() on the outgoing
connection for any reason.

Signed-off-by: Sage Weil <sage@inktank.com>

diff --git a/src/msg/Pipe.cc b/src/msg/Pipe.cc
index 2a89f9b7a5b70a28328549d2e1c85dfd935dc46d..609c6c795f88ee01c07af60e4ebcbde23a6cd0f8 100644 (file)
--- a/src/msg/Pipe.cc
+++ b/src/msg/Pipe.cc
@@ -382,6 +382,8 @@ int Pipe::accept()
                             << " == " << connect.connect_seq
                             << dendl;
          assert(existing->state == STATE_CONNECTING);
+         // make sure our outgoing connection will follow through
+         existing->_send_keepalive();
          reply.tag = CEPH_MSGR_TAG_WAIT;
          existing->pipe_lock.Unlock();
          msgr->lock.Unlock();