blkin: add traces to SimpleMessenger

Signed-off-by: Casey Bodley <cbodley@redhat.com>

diff --git a/src/msg/simple/Pipe.cc b/src/msg/simple/Pipe.cc
index 9e7b0bc9bc28efc3782984e404c2ee070b0a15f5..cece32f0baadbfafddb4bdaeafb428fb39e4695a 100644 (file)
--- 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 600f26c3f1c224fbe6136a96d2aca557a29ab813..efd8ede137d0dcb3a26b7c1de706e27669908f74 100644 (file)
--- 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";