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-17 14:39:04 -0700
commit16568d9e1fb8ac0c06ebaa1e1dc1d6a432a5e4d4 (patch)
treedbc4b55d9628c931028407db6f88422d251f3cbd
parentecab4bb9513385bd765cca23e4e2fadb7ac4bac2 (diff)
downloadceph-16568d9e1fb8ac0c06ebaa1e1dc1d6a432a5e4d4.tar.gz
msg/Pipe: a bit of additional debug output
Signed-off-by: Sage Weil <sage@inktank.com>
-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 3fba9a7e41b..e3600c8e2e6 100644
--- a/src/msg/Pipe.cc
+++ b/src/msg/Pipe.cc
@@ -339,8 +339,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);
@@ -1019,6 +1022,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);