]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
msg/async: clean Processor constructor 12832/head
authorWei Jin <wjin.cn@gmail.com>
Mon, 9 Jan 2017 11:12:41 +0000 (19:12 +0800)
committerWei Jin <wjin.cn@gmail.com>
Mon, 9 Jan 2017 11:12:41 +0000 (19:12 +0800)
Signed-off-by: Wei Jin <wjin.cn@gmail.com>
src/msg/async/AsyncMessenger.cc
src/msg/async/AsyncMessenger.h

index f1cb9f776c4dfa0b64b4e727d060519a69d667f4..5a8d107117b81617186a1905df13ce244f2bac26 100644 (file)
@@ -51,7 +51,7 @@ class Processor::C_processor_accept : public EventCallback {
   }
 };
 
-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)) {}
 
@@ -256,7 +256,7 @@ AsyncMessenger::AsyncMessenger(CephContext *cct, entity_name_t name,
   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));
 }
 
 /**
index d3bb2090f74dfbf9bf21b6b16edef5c0f51cf7b9..1eb2a6b982a20b1dab31aff2501ecb116af98e57 100644 (file)
@@ -53,7 +53,7 @@ class Processor {
   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();