]>
Commit | Line | Data |
---|---|---|
7c673cae FG |
1 | // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- |
2 | // vim: ts=8 sw=2 smarttab | |
3 | /* | |
4 | * Ceph - scalable distributed file system | |
5 | * | |
6 | * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net> | |
7 | * | |
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. | |
12 | * | |
13 | */ | |
14 | ||
15 | ||
16 | #ifndef CEPH_MMONPROBE_H | |
17 | #define CEPH_MMONPROBE_H | |
18 | ||
19 | #include "include/ceph_features.h" | |
9f95a23c | 20 | #include "common/ceph_releases.h" |
7c673cae FG |
21 | #include "msg/Message.h" |
22 | #include "mon/MonMap.h" | |
23 | ||
f67539c2 | 24 | class MMonProbe final : public Message { |
7c673cae | 25 | public: |
b3b6e05e | 26 | static constexpr int HEAD_VERSION = 8; |
11fdf7f2 | 27 | static constexpr int COMPAT_VERSION = 5; |
7c673cae FG |
28 | |
29 | enum { | |
30 | OP_PROBE = 1, | |
31 | OP_REPLY = 2, | |
32 | OP_SLURP = 3, | |
33 | OP_SLURP_LATEST = 4, | |
34 | OP_DATA = 5, | |
35 | OP_MISSING_FEATURES = 6, | |
36 | }; | |
37 | ||
38 | static const char *get_opname(int o) { | |
39 | switch (o) { | |
40 | case OP_PROBE: return "probe"; | |
41 | case OP_REPLY: return "reply"; | |
42 | case OP_SLURP: return "slurp"; | |
43 | case OP_SLURP_LATEST: return "slurp_latest"; | |
44 | case OP_DATA: return "data"; | |
45 | case OP_MISSING_FEATURES: return "missing_features"; | |
46 | default: ceph_abort(); return 0; | |
47 | } | |
48 | } | |
49 | ||
50 | uuid_d fsid; | |
d2e6a577 | 51 | int32_t op = 0; |
f67539c2 TL |
52 | std::string name; |
53 | std::set<int32_t> quorum; | |
b3b6e05e | 54 | int leader = -1; |
f67539c2 | 55 | ceph::buffer::list monmap_bl; |
d2e6a577 FG |
56 | version_t paxos_first_version = 0; |
57 | version_t paxos_last_version = 0; | |
58 | bool has_ever_joined = 0; | |
59 | uint64_t required_features = 0; | |
9f95a23c | 60 | ceph_release_t mon_release{ceph_release_t::unknown}; |
7c673cae FG |
61 | |
62 | MMonProbe() | |
9f95a23c | 63 | : Message{MSG_MON_PROBE, HEAD_VERSION, COMPAT_VERSION} {} |
f67539c2 | 64 | MMonProbe(const uuid_d& f, int o, const std::string& n, bool hej, ceph_release_t mr) |
9f95a23c | 65 | : Message{MSG_MON_PROBE, HEAD_VERSION, COMPAT_VERSION}, |
7c673cae FG |
66 | fsid(f), |
67 | op(o), | |
68 | name(n), | |
69 | paxos_first_version(0), | |
70 | paxos_last_version(0), | |
71 | has_ever_joined(hej), | |
11fdf7f2 | 72 | required_features(0), |
9f95a23c | 73 | mon_release{mr} {} |
7c673cae | 74 | private: |
f67539c2 | 75 | ~MMonProbe() final {} |
7c673cae | 76 | |
f67539c2 | 77 | public: |
11fdf7f2 | 78 | std::string_view get_type_name() const override { return "mon_probe"; } |
f67539c2 | 79 | void print(std::ostream& out) const override { |
7c673cae FG |
80 | out << "mon_probe(" << get_opname(op) << " " << fsid << " name " << name; |
81 | if (quorum.size()) | |
82 | out << " quorum " << quorum; | |
b3b6e05e | 83 | out << " leader " << leader; |
7c673cae FG |
84 | if (op == OP_REPLY) { |
85 | out << " paxos(" | |
86 | << " fc " << paxos_first_version | |
87 | << " lc " << paxos_last_version | |
88 | << " )"; | |
89 | } | |
90 | if (!has_ever_joined) | |
91 | out << " new"; | |
92 | if (required_features) | |
93 | out << " required_features " << required_features; | |
9f95a23c TL |
94 | if (mon_release != ceph_release_t::unknown) |
95 | out << " mon_release " << mon_release; | |
7c673cae FG |
96 | out << ")"; |
97 | } | |
f67539c2 | 98 | |
7c673cae | 99 | void encode_payload(uint64_t features) override { |
11fdf7f2 | 100 | using ceph::encode; |
7c673cae FG |
101 | if (monmap_bl.length() && |
102 | ((features & CEPH_FEATURE_MONENC) == 0 || | |
103 | (features & CEPH_FEATURE_MSG_ADDR2) == 0)) { | |
104 | // reencode old-format monmap | |
105 | MonMap t; | |
106 | t.decode(monmap_bl); | |
107 | monmap_bl.clear(); | |
108 | t.encode(monmap_bl, features); | |
109 | } | |
110 | ||
11fdf7f2 TL |
111 | encode(fsid, payload); |
112 | encode(op, payload); | |
113 | encode(name, payload); | |
114 | encode(quorum, payload); | |
115 | encode(monmap_bl, payload); | |
116 | encode(has_ever_joined, payload); | |
117 | encode(paxos_first_version, payload); | |
118 | encode(paxos_last_version, payload); | |
119 | encode(required_features, payload); | |
120 | encode(mon_release, payload); | |
b3b6e05e | 121 | encode(leader, payload); |
7c673cae FG |
122 | } |
123 | void decode_payload() override { | |
f67539c2 | 124 | using ceph::decode; |
11fdf7f2 TL |
125 | auto p = payload.cbegin(); |
126 | decode(fsid, p); | |
127 | decode(op, p); | |
128 | decode(name, p); | |
129 | decode(quorum, p); | |
130 | decode(monmap_bl, p); | |
131 | decode(has_ever_joined, p); | |
132 | decode(paxos_first_version, p); | |
133 | decode(paxos_last_version, p); | |
7c673cae | 134 | if (header.version >= 6) |
11fdf7f2 | 135 | decode(required_features, p); |
7c673cae FG |
136 | else |
137 | required_features = 0; | |
11fdf7f2 TL |
138 | if (header.version >= 7) |
139 | decode(mon_release, p); | |
140 | else | |
9f95a23c | 141 | mon_release = ceph_release_t::unknown; |
b3b6e05e TL |
142 | if (header.version >= 8) { |
143 | decode(leader, p); | |
144 | } else if (quorum.size()) { | |
145 | leader = *quorum.begin(); | |
146 | } | |
7c673cae | 147 | } |
9f95a23c TL |
148 | private: |
149 | template<class T, typename... Args> | |
150 | friend boost::intrusive_ptr<T> ceph::make_message(Args&&... args); | |
7c673cae FG |
151 | }; |
152 | ||
153 | #endif |