*** empty log message ***

git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@613 29311d96-e01e-0410-9327-a35deaab8ce9

diff --git a/ceph/msg/TCPMessenger.cc b/ceph/msg/TCPMessenger.cc
index 5ce22208cf6e933ae2d74c62f68bcc4c12af4a89..3e92cc703f4b2c8487199ffbfd6b5ed4127bc5e7 100644 (file)
--- a/ceph/msg/TCPMessenger.cc
+++ b/ceph/msg/TCPMessenger.cc
@@ -174,6 +174,7 @@ public:
          logger = new Logger(name, (LogType*)&rank_logtype);
          rank_logtype.add_set("num");
          rank_logtype.add_inc("in");
+         rank_logtype.add_inc("inb");
          rank_logtype.add_inc("dis");
          rank_logtype.add_set("inq");
          rank_logtype.add_set("inqb");
@@ -684,16 +685,18 @@ void *tcp_inthread(void *r)
        incoming_lock.Lock();
 
        stat_inq++;
-       stat_inqb += m->get_payload().length();
+       size_t sz = m->get_payload().length();
+       stat_inqb += sz;
 
        incoming.push_back(m);
        incoming_cond.Signal();
        incoming_lock.Unlock();
 
        if (logger) {
+         logger->inc("in");
+         logger->inc("inb", sz);
          logger->set("inqb", stat_inqb);
          logger->set("inq", stat_inq);
-         logger->inc("in");
        }
   }
 
@@ -1054,7 +1057,7 @@ int TCPMessenger::shutdown()
   directory_lock.Unlock();
 
   // last one?
-         if (lastone) {
+  if (lastone) {
        dout(2) << "shutdown last tcpmessenger on rank " << my_rank << " shut down" << endl;
        //pthread_t whoami = pthread_self();