1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 * Ceph - scalable distributed file system
6 * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
8 * This is free software; you can redistribute it and/or
9 * modify it under the terms of the GNU Lesser General Public
10 * License version 2.1, as published by the Free Software
11 * Foundation. See file COPYING.
16 #ifndef CEPH_MMONPAXOS_H
17 #define CEPH_MMONPAXOS_H
19 #include "messages/PaxosServiceMessage.h"
20 #include "mon/mon_types.h"
21 #include "include/ceph_features.h"
23 class MMonPaxos
: public Message
{
25 static constexpr int HEAD_VERSION
= 4;
26 static constexpr int COMPAT_VERSION
= 3;
30 static constexpr int OP_COLLECT
= 1; // proposer: propose round
31 static constexpr int OP_LAST
= 2; // voter: accept proposed round
32 static constexpr int OP_BEGIN
= 3; // proposer: value proposed for this round
33 static constexpr int OP_ACCEPT
= 4; // voter: accept propsed value
34 static constexpr int OP_COMMIT
= 5; // proposer: notify learners of agreed value
35 static constexpr int OP_LEASE
= 6; // leader: extend peon lease
36 static constexpr int OP_LEASE_ACK
= 7; // peon: lease ack
37 static const char *get_opname(int op
) {
39 case OP_COLLECT
: return "collect";
40 case OP_LAST
: return "last";
41 case OP_BEGIN
: return "begin";
42 case OP_ACCEPT
: return "accept";
43 case OP_COMMIT
: return "commit";
44 case OP_LEASE
: return "lease";
45 case OP_LEASE_ACK
: return "lease_ack";
46 default: ceph_abort(); return 0;
50 epoch_t epoch
= 0; // monitor epoch
51 __s32 op
= 0; // paxos op
53 version_t first_committed
= 0; // i've committed to
54 version_t last_committed
= 0; // i've committed to
55 version_t pn_from
= 0; // i promise to accept after
56 version_t pn
= 0; // with with proposal
57 version_t uncommitted_pn
= 0; // previous pn, if we are a LAST with an uncommitted value
58 utime_t lease_timestamp
;
59 utime_t sent_timestamp
;
61 version_t latest_version
= 0;
62 bufferlist latest_value
;
64 map
<version_t
,bufferlist
> values
;
66 bufferlist feature_map
;
68 MMonPaxos() : Message
{MSG_MON_PAXOS
, HEAD_VERSION
, COMPAT_VERSION
} { }
69 MMonPaxos(epoch_t e
, int o
, utime_t now
) :
70 Message
{MSG_MON_PAXOS
, HEAD_VERSION
, COMPAT_VERSION
},
73 first_committed(0), last_committed(0), pn_from(0), pn(0), uncommitted_pn(0),
79 ~MMonPaxos() override
{}
82 std::string_view
get_type_name() const override
{ return "paxos"; }
84 void print(ostream
& out
) const override
{
85 out
<< "paxos(" << get_opname(op
)
86 << " lc " << last_committed
87 << " fc " << first_committed
88 << " pn " << pn
<< " opn " << uncommitted_pn
;
90 out
<< " latest " << latest_version
<< " (" << latest_value
.length() << " bytes)";
94 void encode_payload(uint64_t features
) override
{
96 header
.version
= HEAD_VERSION
;
97 encode(epoch
, payload
);
99 encode(first_committed
, payload
);
100 encode(last_committed
, payload
);
101 encode(pn_from
, payload
);
103 encode(uncommitted_pn
, payload
);
104 encode(lease_timestamp
, payload
);
105 encode(sent_timestamp
, payload
);
106 encode(latest_version
, payload
);
107 encode(latest_value
, payload
);
108 encode(values
, payload
);
109 encode(feature_map
, payload
);
111 void decode_payload() override
{
112 auto p
= payload
.cbegin();
115 decode(first_committed
, p
);
116 decode(last_committed
, p
);
119 decode(uncommitted_pn
, p
);
120 decode(lease_timestamp
, p
);
121 decode(sent_timestamp
, p
);
122 decode(latest_version
, p
);
123 decode(latest_value
, p
);
125 if (header
.version
>= 4) {
126 decode(feature_map
, p
);
130 template<class T
, typename
... Args
>
131 friend boost::intrusive_ptr
<T
> ceph::make_message(Args
&&... args
);