]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
msg/Pipe: a bit of additional debug output
authorSage Weil <sage@inktank.com>
Tue, 16 Jul 2013 21:17:05 +0000 (14:17 -0700)
committerSage Weil <sage@inktank.com>
Wed, 24 Jul 2013 23:20:37 +0000 (16:20 -0700)
Signed-off-by: Sage Weil <sage@inktank.com>
(cherry picked from commit 16568d9e1fb8ac0c06ebaa1e1dc1d6a432a5e4d4)

src/msg/Pipe.cc

index c47ac6b5dfd1191b1040931dd004e1d3af88f902..fbf28f8ce98b4430446c449b0e89bbe5ef3b8333 100644 (file)
@@ -341,8 +341,11 @@ int Pipe::accept()
     set_peer_type(connect.host_type);
     policy = msgr->get_policy(connect.host_type);
     ldout(msgr->cct,10) << "accept of host_type " << connect.host_type
-            << ", policy.lossy=" << policy.lossy
-            << dendl;
+                       << ", policy.lossy=" << policy.lossy
+                       << " policy.server=" << policy.server
+                       << " policy.standby=" << policy.standby
+                       << " policy.resetcheck=" << policy.resetcheck
+                       << dendl;
 
     memset(&reply, 0, sizeof(reply));
     reply.protocol_version = msgr->get_proto_version(peer_type, false);
@@ -1014,6 +1017,8 @@ int Pipe::connect()
           ldout(msgr->cct,2) << "connect read error on newly_acked_seq" << dendl;
           goto fail_locked;
         }
+       ldout(msgr->cct,2) << " got newly_acked_seq " << newly_acked_seq
+                          << " vs out_seq " << out_seq << dendl;
        while (newly_acked_seq > out_seq) {
          Message *m = _get_next_outgoing();
          assert(m);