diff --git a/src/msg/async/rdma/RDMAStack.cc b/src/msg/async/rdma/RDMAStack.cc index fa60a59f45e..3a6bda44a45 100644 --- a/src/msg/async/rdma/RDMAStack.cc +++ b/src/msg/async/rdma/RDMAStack.cc @@ -43,9 +43,8 @@ RDMADispatcher::~RDMADispatcher() delete async_handler; } -RDMADispatcher::RDMADispatcher(CephContext* c, RDMAStack* s, shared_ptr& ib) - : cct(c), ib(ib), async_handler(new C_handle_cq_async(this)), - stack(s) +RDMADispatcher::RDMADispatcher(CephContext* c, shared_ptr& ib) + : cct(c), ib(ib), async_handler(new C_handle_cq_async(this)) { PerfCountersBuilder plb(cct, "AsyncMessenger::RDMADispatcher", l_msgr_rdma_dispatcher_first, l_msgr_rdma_dispatcher_last); @@ -656,7 +655,7 @@ void RDMAWorker::handle_pending_message() } RDMAStack::RDMAStack(CephContext *cct, const string &t) - : NetworkStack(cct, t), ib(make_shared(cct)), dispatcher(cct, this, ib) + : NetworkStack(cct, t), ib(make_shared(cct)), dispatcher(cct, ib) { ldout(cct, 20) << __func__ << " constructing RDMAStack..." << dendl; diff --git a/src/msg/async/rdma/RDMAStack.h b/src/msg/async/rdma/RDMAStack.h index cf180f892f5..a92b925efe0 100644 --- a/src/msg/async/rdma/RDMAStack.h +++ b/src/msg/async/rdma/RDMAStack.h @@ -78,7 +78,6 @@ class RDMADispatcher { ceph::make_mutex("RDMADispatcher::for worker pending list"); // fixme: lockfree std::list pending_workers; - RDMAStack* stack; class C_handle_cq_async : public EventCallback { RDMADispatcher *dispatcher; @@ -93,7 +92,7 @@ class RDMADispatcher { public: PerfCounters *perf_logger; - explicit RDMADispatcher(CephContext* c, RDMAStack* s, shared_ptr& ib); + explicit RDMADispatcher(CephContext* c, shared_ptr& ib); virtual ~RDMADispatcher(); void handle_async_event(); @@ -109,7 +108,6 @@ class RDMADispatcher { pending_workers.push_back(w); ++num_pending_workers; } - RDMAStack* get_stack() { return stack; } RDMAConnectedSocketImpl* get_conn_lockless(uint32_t qp); QueuePair* get_qp(uint32_t qp); void erase_qpn_lockless(uint32_t qpn);