From 82160fb59152f1f2aeea4b1e25b60dee22c7a718 Mon Sep 17 00:00:00 2001 From: Casey Bodley Date: Tue, 25 Aug 2015 12:49:50 -0400 Subject: [PATCH] blkin: add traces to SimpleMessenger Signed-off-by: Casey Bodley --- src/msg/simple/Pipe.cc | 4 ++++ src/msg/simple/SimpleMessenger.cc | 1 + 2 files changed, 5 insertions(+) diff --git a/src/msg/simple/Pipe.cc b/src/msg/simple/Pipe.cc index 9e7b0bc9bc28..cece32f0baad 100644 --- a/src/msg/simple/Pipe.cc +++ b/src/msg/simple/Pipe.cc @@ -1718,6 +1718,8 @@ void Pipe::reader() continue; } + m->trace.event("pipe read message"); + if (state == STATE_CLOSED || state == STATE_CONNECTING) { in_q->dispatch_throttle_release(m->get_dispatch_throttle_size()); @@ -1952,6 +1954,8 @@ void Pipe::writer() pipe_lock.Unlock(); + m->trace.event("pipe writing message"); + ldout(msgr->cct,20) << "writer sending " << m->get_seq() << " " << m << dendl; int rc = write_message(header, footer, blist); diff --git a/src/msg/simple/SimpleMessenger.cc b/src/msg/simple/SimpleMessenger.cc index 600f26c3f1c2..efd8ede137d0 100644 --- a/src/msg/simple/SimpleMessenger.cc +++ b/src/msg/simple/SimpleMessenger.cc @@ -443,6 +443,7 @@ void SimpleMessenger::submit_message(Message *m, PipeConnection *con, const entity_addr_t& dest_addr, int dest_type, bool already_locked) { + m->trace.event("simple submitting message"); if (cct->_conf->ms_dump_on_send) { m->encode(-1, true); ldout(cct, 0) << "submit_message " << *m << "\n"; -- 2.47.3