]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
AsyncMessenger: add perf counter for inline message sent
authorHaomai Wang <haomai@xsky.com>
Wed, 27 Jan 2016 16:47:16 +0000 (00:47 +0800)
committerHaomai Wang <haomai@xsky.com>
Mon, 1 Feb 2016 07:28:21 +0000 (15:28 +0800)
Signed-off-by: Haomai Wang <haomai@xsky.com>
src/msg/async/AsyncConnection.cc
src/msg/async/AsyncMessenger.h

index 7e9694768e48b5d8c7478cb36ccbaa1455497c67..1e03d2118cd85466ab4ed0cb2fe2a1389336d605 100644 (file)
@@ -2064,6 +2064,7 @@ int AsyncConnection::send_message(Message *m)
   if (!is_queued() && can_write == CANWRITE) {
     if (!can_fast_prepare)
       prepare_send_message(get_features(), m, bl);
+    logger->inc(l_msgr_send_messages_inline);
     if (write_message(m, bl) < 0) {
       ldout(async_msgr->cct, 1) << __func__ << " send msg failed" << dendl;
       // we want to handle fault within internal thread
index 5206a81f77678e7a148721e76075d24719a38f80..e5831a7ea99a605ebec55e4eb3cb099bb779abf4 100644 (file)
@@ -45,6 +45,7 @@ enum {
   l_msgr_first = 94000,
   l_msgr_recv_messages,
   l_msgr_send_messages,
+  l_msgr_send_messages_inline,
   l_msgr_recv_bytes,
   l_msgr_send_bytes,
   l_msgr_created_connections,
@@ -74,6 +75,7 @@ class Worker : public Thread {
 
     plb.add_u64_counter(l_msgr_recv_messages, "msgr_recv_messages", "Network received messages");
     plb.add_u64_counter(l_msgr_send_messages, "msgr_send_messages", "Network sent messages");
+    plb.add_u64_counter(l_msgr_send_messages_inline, "msgr_send_messages_inline", "Network sent inline messages");
     plb.add_u64_counter(l_msgr_recv_bytes, "msgr_recv_bytes", "Network received bytes");
     plb.add_u64_counter(l_msgr_send_bytes, "msgr_send_bytes", "Network received bytes");
     plb.add_u64_counter(l_msgr_created_connections, "msgr_active_connections", "Active connection number");