]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
blkin: add traces to AsyncMessenger
authorCasey Bodley <cbodley@redhat.com>
Tue, 25 Aug 2015 18:40:48 +0000 (14:40 -0400)
committerSage Weil <sage@redhat.com>
Fri, 5 May 2017 17:59:47 +0000 (13:59 -0400)
Signed-off-by: Casey Bodley <cbodley@redhat.com>
src/msg/async/AsyncConnection.cc

index 69518697e6021b8149d8b47a4c7641b01fa762e8..8eec5968458529a4a41b2a056fcdc6ab08ab4dda 100644 (file)
@@ -1948,6 +1948,7 @@ int AsyncConnection::send_message(Message *m)
                                << " Drop message " << m << dendl;
     m->put();
   } else {
+    m->trace.event("async enqueueing message");
     out_q[m->get_priority()].emplace_back(std::move(bl), m);
     ldout(async_msgr->cct, 15) << __func__ << " inline write is denied, reschedule m=" << m << dendl;
     if (can_write != WriteStatus::REPLACING)
@@ -2266,6 +2267,7 @@ ssize_t AsyncConnection::write_message(Message *m, bufferlist& bl, bool more)
     outcoming_bl.append((char*)&old_footer, sizeof(old_footer));
   }
 
+  m->trace.event("async writing message");
   logger->inc(l_msgr_send_bytes, outcoming_bl.length() - original_bl_len);
   ldout(async_msgr->cct, 20) << __func__ << " sending " << m->get_seq()
                              << " " << m << dendl;