From: Haomai Wang <haomai@xsky.com>
Date: Sun, 19 Jun 2016 15:04:46 +0000 (+0800)
Subject: test/test_msgr: add shutdown hang debug info
X-Git-Tag: v10.2.3~100^2~2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=42ef435554a21dfd5daec53002440a38f4d9f705;p=ceph.git

test/test_msgr: add shutdown hang debug info

Signed-off-by: Haomai Wang <haomai@xsky.com>
(cherry picked from commit 37b53d69d3d8c848d4627475fd63c80e15e118e7)
---

diff --git a/src/test/msgr/test_msgr.cc b/src/test/msgr/test_msgr.cc
index e1fa612d6e7f..b28c7580bc7e 100644
--- a/src/test/msgr/test_msgr.cc
+++ b/src/test/msgr/test_msgr.cc
@@ -826,6 +826,14 @@ class SyntheticDispatcher : public Dispatcher {
       sent.erase(*it);
     conn_sent.erase(con);
   }
+
+  void print() {
+    for (auto && p : conn_sent) {
+      if (!p.second.empty()) {
+        cerr << __func__ << " " << p.first << " wait " << p.second.size() << std::endl;
+      }
+    }
+  }
 };
 
 
@@ -1003,8 +1011,9 @@ class SyntheticWorkload {
          << " inflight messages: " << dispatcher.get_pending() << std::endl;
     if (detail && !available_connections.empty()) {
       for (auto &&c : available_connections)
-        cerr << "available connection: " << c.first;
+        cerr << "available connection: " << c.first << " ";
       cerr << std::endl;
+      dispatcher.print();
     }
   }