From 07c0a8b9add21a375415d17d77218b48ff8920f0 Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Sat, 5 Jul 2008 08:52:53 -0700 Subject: [PATCH] msgr: fix RESETSESSION handling --- src/msg/SimpleMessenger.cc | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc index dbf222ac7b9c4..92e937103e4e8 100644 --- a/src/msg/SimpleMessenger.cc +++ b/src/msg/SimpleMessenger.cc @@ -886,7 +886,7 @@ int Rank::Pipe::accept() assert(peer_cseq > existing->connect_seq); assert(peer_gseq >= existing->peer_global_seq); if (existing->connect_seq == 0) { - dout(10) << "accept we reset (peer sent cseq " << peer_cseq + dout(0) << "accept we reset (peer sent cseq " << peer_cseq << ", " << existing << ".cseq = " << existing->connect_seq << "), sending RESETSESSION" << dendl; rank.lock.Unlock(); @@ -905,7 +905,7 @@ int Rank::Pipe::accept() } // existing else if (peer_cseq > 0) { // we reset, and they are opening a new session - dout(10) << "accept we reset (peer sent cseq " << peer_cseq << "), sending RESETSESSION" << dendl; + dout(0) << "accept we reset (peer sent cseq " << peer_cseq << "), sending RESETSESSION" << dendl; rank.lock.Unlock(); char tag = CEPH_MSGR_TAG_RESETSESSION; if (tcp_write(sd, &tag, 1) < 0) @@ -1083,6 +1083,7 @@ int Rank::Pipe::connect() dout(0) << "connect got RESETSESSION" << dendl; was_session_reset(); + cseq = 0; lock.Unlock(); continue; } -- 2.39.5