From 39515b0f7c49d0cedbec0cf0dc2196b9d6d6339c Mon Sep 17 00:00:00 2001 From: Haomai Wang Date: Sun, 22 May 2016 23:43:47 +0800 Subject: [PATCH] test_msgr: add verbose info for pending connections Signed-off-by: Haomai Wang --- src/test/msgr/test_msgr.cc | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/test/msgr/test_msgr.cc b/src/test/msgr/test_msgr.cc index b41f260c6df58..f1d1cfb73f44d 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::iterator it = available_servers.begin(); it != available_servers.end(); ++it) { -- 2.39.5