summaryrefslogtreecommitdiffstats
path: root/src/messages/MOSDPGPushReply.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/messages/MOSDPGPushReply.h')
-rw-r--r--src/messages/MOSDPGPushReply.h18
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) {