AsyncConnection: add log for reap_dead and clean_handler

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

diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc
index 9c1b250fbcba53fd1c2d787e601710c0cbe47f02..38be59d3cf0373341bbb419ab8a7a388d8311b3e 100644 (file)
--- a/src/msg/async/AsyncConnection.cc
+++ b/src/msg/async/AsyncConnection.cc
@@ -2570,3 +2570,16 @@ void AsyncConnection::local_deliver()
     write_lock.Lock();
   }
 }
+
+void AsyncConnection::cleanup_handler()
+{
+  ldout(async_msgr->cct, 1) << __func__ << dendl;
+
+  delete read_handler;
+  delete write_handler;
+  delete reset_handler;
+  delete remote_reset_handler;
+  delete connect_handler;
+  delete local_deliver_handler;
+  delete wakeup_handler;
+}

diff --git a/src/msg/async/AsyncConnection.h b/src/msg/async/AsyncConnection.h
index 40a9887344f1a9844de89c783dfa9c5f9de8407a..31a6e0d96da2a09f8039a6b93dc07cbb107349db 100644 (file)
--- a/src/msg/async/AsyncConnection.h
+++ b/src/msg/async/AsyncConnection.h
@@ -315,15 +315,7 @@ class AsyncConnection : public Connection {
     lock.Unlock();
     mark_down();
   }
-  void cleanup_handler() {
-    delete read_handler;
-    delete write_handler;
-    delete reset_handler;
-    delete remote_reset_handler;
-    delete connect_handler;
-    delete local_deliver_handler;
-    delete wakeup_handler;
-  }
+  void cleanup_handler();
   PerfCounters *get_perf_counter() {
     return logger;
   }

diff --git a/src/msg/async/AsyncMessenger.cc b/src/msg/async/AsyncMessenger.cc
index 31158a4d27c8b28544f4061617073785a7056cb3..9d7619dc1c0d36c3bbb74b6e96e2b459b75121a5 100644 (file)
--- a/src/msg/async/AsyncMessenger.cc
+++ b/src/msg/async/AsyncMessenger.cc
@@ -741,6 +741,7 @@ void AsyncMessenger::learned_addr(const entity_addr_t &peer_addr_for_me)
 
 int AsyncMessenger::reap_dead()
 {
+  ldout(cct, 1) << __func__ << " start" << dendl;
   int num = 0;
 
   Mutex::Locker l1(lock);