}
}
+Worker* RDMAStack::create_worker(CephContext *c, unsigned worker_id)
+{
+ return new RDMAWorker(c, worker_id);
+}
+
void RDMAStack::spawn_worker(unsigned i, std::function<void ()> &&func)
{
threads.resize(i+1);
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);