From: Haomai Wang <haomai@xsky.com>
Date: Sun, 22 May 2016 15:43:47 +0000 (+0800)
Subject: test_msgr: add verbose info for pending connections
X-Git-Tag: v11.0.0~455^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F9255%2Fhead;p=ceph.git

test_msgr: add verbose info for pending connections

Signed-off-by: Haomai Wang <haomai@xsky.com>
---

diff --git a/src/test/msgr/test_msgr.cc b/src/test/msgr/test_msgr.cc
index b41f260c6df5..f1d1cfb73f44 100644
--- a/src/test/msgr/test_msgr.cc
+++ b/src/test/msgr/test_msgr.cc
@@ -997,10 +997,15 @@ class SyntheticWorkload {
     ASSERT_EQ(available_connections.erase(conn), 1U);
   }
 
-  void print_internal_state() {
+  void print_internal_state(bool detail=false) {
     Mutex::Locker l(lock);
     cerr << "available_connections: " << available_connections.size()
          << " inflight messages: " << dispatcher.get_pending() << std::endl;
+    if (detail && !available_connections.empty()) {
+      for (auto &&c : available_connections)
+        cerr << "available connection: " << c.first;
+      cerr << std::endl;
+    }
   }
 
   void wait_for_done() {
@@ -1008,7 +1013,7 @@ class SyntheticWorkload {
     while (dispatcher.get_pending()) {
       usleep(1000*100);
       if (i++ % 50 == 0)
-        print_internal_state();
+        print_internal_state(true);
     }
     for (set<Messenger*>::iterator it = available_servers.begin();
          it != available_servers.end(); ++it) {