}
};
-Processor::Processor(AsyncMessenger *r, Worker *w, CephContext *c, uint64_t n)
+Processor::Processor(AsyncMessenger *r, Worker *w, CephContext *c)
: msgr(r), net(c), worker(w),
listen_handler(new C_processor_accept(this)) {}
if (stack->support_local_listen_table())
processor_num = stack->get_num_worker();
for (unsigned i = 0; i < processor_num; ++i)
- processors.push_back(new Processor(this, stack->get_worker(i), cct, _nonce));
+ processors.push_back(new Processor(this, stack->get_worker(i), cct));
}
/**
class C_processor_accept;
public:
- Processor(AsyncMessenger *r, Worker *w, CephContext *c, uint64_t n);
+ Processor(AsyncMessenger *r, Worker *w, CephContext *c);
~Processor() { delete listen_handler; };
void stop();