msg/async/rdma: add log to show correct destruct queuepair

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

diff --git a/src/msg/async/rdma/Infiniband.cc b/src/msg/async/rdma/Infiniband.cc
index f66bcaddd67f9bdbb22816cac48955282c0ee0fb..6856b911b22e59df150ee3b217147beba7e590b7 100644 (file)
--- a/src/msg/async/rdma/Infiniband.cc
+++ b/src/msg/async/rdma/Infiniband.cc
@@ -945,8 +945,10 @@ void Infiniband::gid_to_wire_gid(const union ibv_gid *gid, char wgid[])
 
 Infiniband::QueuePair::~QueuePair()
 {
-  if (qp)
+  if (qp) {
+    ldout(cct, 20) << __func__ << " destroy qp=" << qp << dendl;
     assert(!ibv_destroy_qp(qp));
+  }
 }
 
 /**

diff --git a/src/msg/async/rdma/RDMAConnectedSocketImpl.cc b/src/msg/async/rdma/RDMAConnectedSocketImpl.cc
index 45683ee2705004290a439087fadc46bbc80218da..8f852455a63ec09d32254fa2f874532cdeda7ef6 100644 (file)
--- a/src/msg/async/rdma/RDMAConnectedSocketImpl.cc
+++ b/src/msg/async/rdma/RDMAConnectedSocketImpl.cc
@@ -39,6 +39,7 @@ RDMAConnectedSocketImpl::RDMAConnectedSocketImpl(CephContext *cct, Infiniband* i
 
 RDMAConnectedSocketImpl::~RDMAConnectedSocketImpl()
 {
+  ldout(cct, 20) << __func__ << " destruct." << dendl;
   worker->remove_pending_conn(this);
   dispatcher->erase_qpn(my_msg.qpn);
   cleanup();