msg/async/rdma: remove unused variable

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

diff --git a/src/msg/async/rdma/RDMAStack.cc b/src/msg/async/rdma/RDMAStack.cc
index 7e8a9d1251dabce9a9efa093ba87414c5e7fd4c5..1f0a84ad71a09e430eece03f5ba33bbdaea142a9 100644 (file)
--- a/src/msg/async/rdma/RDMAStack.cc
+++ b/src/msg/async/rdma/RDMAStack.cc
@@ -338,7 +338,7 @@ void RDMADispatcher::handle_post_fork()
 
 RDMAWorker::RDMAWorker(CephContext *c, unsigned i)
   : Worker(c, i), stack(nullptr), infiniband(NULL),
-    tx_handler(new C_handle_cq_tx(this)), memory_manager(NULL), lock("RDMAWorker::lock"), pended(false)
+    tx_handler(new C_handle_cq_tx(this)), memory_manager(NULL), lock("RDMAWorker::lock")
 {
   // initialize perf_logger
   char name[128];
@@ -471,7 +471,6 @@ void RDMAWorker::post_tx_buffer(std::vector<Chunk*> &chunks)
   memory_manager->return_tx(chunks);
   ldout(cct, 30) << __func__ << " release " << chunks.size() << " chunks, inflight " << stack->get_dispatcher()->inflight << dendl;
 
-  pended = false;
   std::set<RDMAConnectedSocketImpl*> done;
   Mutex::Locker l(lock);
   while (!pending_sent_conns.empty()) {

diff --git a/src/msg/async/rdma/RDMAStack.h b/src/msg/async/rdma/RDMAStack.h
index 446b335d816c9880ff783b931a7860005e270cc6..322d89d86b79cdca0e502c9a20345cf4e5639961 100644 (file)
--- a/src/msg/async/rdma/RDMAStack.h
+++ b/src/msg/async/rdma/RDMAStack.h
@@ -165,7 +165,6 @@ class RDMAWorker : public Worker {
   int notify_fd = -1;
   Mutex lock;
   std::vector<ibv_wc> wc;
-  bool pended;
 
   class C_handle_cq_tx : public EventCallback {
     RDMAWorker *worker;