diff options
Diffstat (limited to 'src/messages/MOSDPGPushReply.h')
-rw-r--r-- | src/messages/MOSDPGPushReply.h | 18 |
1 files changed, 12 insertions, 6 deletions
diff --git a/src/messages/MOSDPGPushReply.h b/src/messages/MOSDPGPushReply.h index 793709e1650..52e3ddd8a58 100644 --- a/src/messages/MOSDPGPushReply.h +++ b/src/messages/MOSDPGPushReply.h @@ -15,10 +15,9 @@ #ifndef MOSDPGPUSHREPLY_H #define MOSDPGPUSHREPLY_H -#include "msg/Message.h" -#include "osd/osd_types.h" +#include "MOSDFastDispatchOp.h" -class MOSDPGPushReply : public Message { +class MOSDPGPushReply : public MOSDFastDispatchOp { static const int HEAD_VERSION = 2; static const int COMPAT_VERSION = 1; @@ -29,9 +28,16 @@ public: vector<PushReplyOp> replies; uint64_t cost; - MOSDPGPushReply() : - Message(MSG_OSD_PG_PUSH_REPLY, HEAD_VERSION, COMPAT_VERSION), - cost(0) + epoch_t get_map_epoch() const override { + return map_epoch; + } + spg_t get_spg() const override { + return pgid; + } + + MOSDPGPushReply() + : MOSDFastDispatchOp(MSG_OSD_PG_PUSH_REPLY, HEAD_VERSION, COMPAT_VERSION), + cost(0) {} void compute_cost(CephContext *cct) { |