]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
test_msgr: add verbose info for pending connections 9255/head
authorHaomai Wang <haomai@xsky.com>
Sun, 22 May 2016 15:43:47 +0000 (23:43 +0800)
committerHaomai Wang <haomai@xsky.com>
Sun, 22 May 2016 15:53:05 +0000 (23:53 +0800)
Signed-off-by: Haomai Wang <haomai@xsky.com>
src/test/msgr/test_msgr.cc

index b41f260c6df58186c3f7da2f6199db0bb82613cf..f1d1cfb73f44d3f114644789bd0d9bb2d1953409 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) {