]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
test_msgr: add verbose info for pending connections
authorHaomai Wang <haomai@xsky.com>
Sun, 22 May 2016 15:43:47 +0000 (23:43 +0800)
committerLoic Dachary <ldachary@redhat.com>
Wed, 29 Jun 2016 08:19:10 +0000 (10:19 +0200)
Signed-off-by: Haomai Wang <haomai@xsky.com>
(cherry picked from commit 39515b0f7c49d0cedbec0cf0dc2196b9d6d6339c)

src/test/msgr/test_msgr.cc

index eebf3cf9861676d343a34aa3c3112756709e119c..e1fa612d6e7f0646fe1bc118a8ef4ece21954213 100644 (file)
@@ -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) {