]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
msg/AsyncMessenger: move C_handle_reap class to cc 10113/head
authorMichal Jarzabek <stiopa@gmail.com>
Sat, 2 Jul 2016 09:06:22 +0000 (10:06 +0100)
committerMichal Jarzabek <stiopa@gmail.com>
Sat, 2 Jul 2016 09:06:22 +0000 (10:06 +0100)
Signed-off-by: Michal Jarzabek <stiopa@gmail.com>
src/msg/async/AsyncMessenger.cc
src/msg/async/AsyncMessenger.h

index 90bb30dac6487ae8388fa8f529a8750d94795157..d36a1b8bca559e559f7379f46bc198cc133307e1 100644 (file)
@@ -485,6 +485,16 @@ void WorkerPool::barrier()
   ldout(cct, 10) << __func__ << " end." << dendl;
 }
 
+class C_handle_reap : public EventCallback {
+  AsyncMessenger *msgr;
+
+  public:
+  explicit C_handle_reap(AsyncMessenger *m): msgr(m) {}
+  void do_request(int id) {
+    // judge whether is a time event
+    msgr->reap_dead();
+  }
+};
 
 /*******************
  * AsyncMessenger
index d4270b8c828962517e3a8b6daf4ec6a08117af20..87811d0ae3759a7cb53b8cf8ec0f9872cfc92356 100644 (file)
@@ -285,16 +285,6 @@ private:
   friend class Processor;
   DispatchQueue dispatch_queue;
 
-  class C_handle_reap : public EventCallback {
-    AsyncMessenger *msgr;
-
-   public:
-    explicit C_handle_reap(AsyncMessenger *m): msgr(m) {}
-    void do_request(int id) {
-      // judge whether is a time event
-      msgr->reap_dead();
-    }
-  };
   // the worker run messenger's cron jobs
   Worker *local_worker;