]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mon/MonClient: move C_CancelMonCommand to cc file 10392/head
authorMichal Jarzabek <stiopa@gmail.com>
Thu, 21 Jul 2016 13:29:58 +0000 (14:29 +0100)
committerMichal Jarzabek <stiopa@gmail.com>
Thu, 21 Jul 2016 13:29:58 +0000 (14:29 +0100)
Signed-off-by: Michal Jarzabek <stiopa@gmail.com>
src/mon/MonClient.cc
src/mon/MonClient.h

index 6ae7b45740657e95a78b8030d0a9a504bfe702d6..5204320a0daa505b0856254a802fe7fab1bf0e4d 100644 (file)
@@ -1008,6 +1008,16 @@ int MonClient::start_mon_command(const vector<string>& cmd,
   r->prs = outs;
   r->onfinish = onfinish;
   if (cct->_conf->rados_mon_op_timeout > 0) {
+    class C_CancelMonCommand : public Context
+    {
+      uint64_t tid;
+      MonClient *monc;
+      public:
+      C_CancelMonCommand(uint64_t tid, MonClient *monc) : tid(tid), monc(monc) {}
+      void finish(int r) {
+       monc->_cancel_mon_command(tid, -ETIMEDOUT);
+      }
+    };
     r->ontimeout = new C_CancelMonCommand(r->tid, this);
     timer.add_event_after(cct->_conf->rados_mon_op_timeout, r->ontimeout);
   }
index 4e08ceb6d6c0aca5384aec27cf9189af8e1f3034..4d823aea2a051b6f98e253a847522f30aeb06b68 100644 (file)
@@ -410,17 +410,6 @@ private:
   };
   map<uint64_t,MonCommand*> mon_commands;
 
-  class C_CancelMonCommand : public Context
-  {
-    uint64_t tid;
-    MonClient *monc;
-  public:
-    C_CancelMonCommand(uint64_t tid, MonClient *monc) : tid(tid), monc(monc) {}
-    void finish(int r) {
-      monc->_cancel_mon_command(tid, -ETIMEDOUT);
-    }
-  };
-
   void _send_command(MonCommand *r);
   void _resend_mon_commands();
   int _cancel_mon_command(uint64_t tid, int r);