summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSage Weil <sage@inktank.com>2013-07-16 14:17:05 -0700
committerSage Weil <sage@inktank.com>2013-07-24 16:20:37 -0700
commit45bda482fa8a23f4b80d115e29d6f04cb5e226d6 (patch)
tree82f5f889623f680b8a9e826a8cf9f5f8536873d9
parent806eab59ad1a32aedb662c51de3b4a1d61fcbb62 (diff)
downloadceph-45bda482fa8a23f4b80d115e29d6f04cb5e226d6.tar.gz
msg/Pipe: a bit of additional debug output
Signed-off-by: Sage Weil <sage@inktank.com> (cherry picked from commit 16568d9e1fb8ac0c06ebaa1e1dc1d6a432a5e4d4)
-rw-r--r--src/msg/Pipe.cc9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/msg/Pipe.cc b/src/msg/Pipe.cc
index c47ac6b5dfd..fbf28f8ce98 100644
--- a/src/msg/Pipe.cc
+++ b/src/msg/Pipe.cc
@@ -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);