#include "msg/Message.h"
-class MMonQuorumService : public MessageSubType<MMonQuorumService> {
+class MMonQuorumService : public Message {
public:
epoch_t epoch = 0;
version_t round = 0;
protected:
-template<typename... Args>
- MMonQuorumService(Args&&... args) : MessageSubType(std::forward<Args>(args)...) {}
-
+ MMonQuorumService(int type, int head)
+ : Message{type, head, 1}
+ {}
~MMonQuorumService() override { }
public:
-
void set_epoch(epoch_t e) {
epoch = e;
}
#include "msg/Message.h"
#include "osd/osd_types.h"
-class MOSDFastDispatchOp : public MessageSubType<MOSDFastDispatchOp> {
+class MOSDFastDispatchOp : public Message {
public:
-
-template<typename... Args>
- MOSDFastDispatchOp(Args&&... args) : MessageSubType(std::forward<Args>(args)...) {}
-
+ MOSDFastDispatchOp(int t, int version, int compat_version)
+ : Message{t, version, compat_version}
+ {}
virtual epoch_t get_map_epoch() const = 0;
virtual epoch_t get_min_epoch() const {
return get_map_epoch();
#include "osd/osd_types.h"
#include "osd/PGPeeringEvent.h"
-class MOSDPeeringOp : public MessageSubType<MOSDPeeringOp> {
+class MOSDPeeringOp : public Message {
public:
-
-template<typename... Args>
- MOSDPeeringOp(Args&&... args) : MessageSubType(std::forward<Args>(args)...) {}
+ MOSDPeeringOp(int t, int version, int compat_version)
+ : Message{t, version, compat_version} {}
void print(std::ostream& out) const override final {
out << get_type_name() << "("
#define CEPH_PAXOSSERVICEMESSAGE_H
#include "msg/Message.h"
-#include "msg/MessageRef.h"
#include "mon/Session.h"
-class PaxosServiceMessage : public MessageSubType<PaxosServiceMessage> {
+class PaxosServiceMessage : public Message {
public:
version_t version;
__s16 deprecated_session_mon;
epoch_t rx_election_epoch;
PaxosServiceMessage()
- : MessageSubType(MSG_PAXOS),
+ : Message{MSG_PAXOS},
version(0), deprecated_session_mon(-1), deprecated_session_mon_tid(0),
rx_election_epoch(0) { }
PaxosServiceMessage(int type, version_t v, int enc_version=1, int compat_enc_version=0)
- : MessageSubType(type, enc_version, compat_enc_version),
+ : Message{type, enc_version, compat_enc_version},
version(v), deprecated_session_mon(-1), deprecated_session_mon_tid(0),
rx_election_epoch(0) { }
protected: