import 15.2.0 Octopus source

[ceph.git] / ceph / src / mon / PaxosService.h

diff --git a/ceph/src/mon/PaxosService.h b/ceph/src/mon/PaxosService.h
index 36d39ad799b72ea85660a2d09846dd5ea9cb167b..bb59688594bad96cbdb725ce98a93a48e3eac692 100644 (file)
--- a/ceph/src/mon/PaxosService.h
+++ b/ceph/src/mon/PaxosService.h
@@ -124,6 +124,20 @@ public:
     }
   };
 
+  class C_ReplyOp : public C_MonOp {
+    Monitor *mon;
+    MonOpRequestRef op;
+    MessageRef reply;
+  public:
+    C_ReplyOp(PaxosService *s, MonOpRequestRef o, MessageRef r) :
+      C_MonOp(o), mon(s->mon), op(o), reply(r) { }
+    void _finish(int r) override {
+      if (r >= 0) {
+       mon->send_reply(op, reply.detach());
+      }
+    }
+  };
+
   /**
    * @}
    */