import quincy beta 17.1.0

[ceph.git] / ceph / src / msg / async / rdma / RDMAStack.h

diff --git a/ceph/src/msg/async/rdma/RDMAStack.h b/ceph/src/msg/async/rdma/RDMAStack.h
index 8389fee8c70fa23f87d807a7d535ecdc4ccbbde2..aa64ca57e6faebe69270db32d8473c4017309fb8 100644 (file)
--- a/ceph/src/msg/async/rdma/RDMAStack.h
+++ b/ceph/src/msg/async/rdma/RDMAStack.h
@@ -326,16 +326,14 @@ class RDMAStack : public NetworkStack {
 
   std::atomic<bool> fork_finished = {false};
 
-  virtual Worker* create_worker(CephContext *c, unsigned worker_id) override {
-    return new RDMAWorker(c, worker_id);
-  }
+  virtual Worker* create_worker(CephContext *c, unsigned worker_id) override;
 
  public:
   explicit RDMAStack(CephContext *cct);
   virtual ~RDMAStack();
   virtual bool nonblock_connect_need_writable_event() const override { return false; }
 
-  virtual void spawn_worker(unsigned i, std::function<void ()> &&func) override;
+  virtual void spawn_worker(std::function<void ()> &&func) override;
   virtual void join_worker(unsigned i) override;
   virtual bool is_ready() override { return fork_finished.load(); };
   virtual void ready() override { fork_finished = true; };