import ceph pacific 16.2.5

[ceph.git] / ceph / src / messages / MMonJoin.h

diff --git a/ceph/src/messages/MMonJoin.h b/ceph/src/messages/MMonJoin.h
index 309035e5b0b98b2ac52b4aa50d7487ca894cdaca..cf662f514187d9b7d732a2946069afc96aede506 100644 (file)
--- a/ceph/src/messages/MMonJoin.h
+++ b/ceph/src/messages/MMonJoin.h
@@ -19,18 +19,30 @@
 
 class MMonJoin final : public PaxosServiceMessage {
 public:
-  static constexpr int HEAD_VERSION = 2;
+  static constexpr int HEAD_VERSION = 3;
   static constexpr int COMPAT_VERSION = 2;
 
   uuid_d fsid;
   std::string name;
   entity_addrvec_t addrs;
+  /* The location members are for stretch mode. crush_loc is the location
+   * (generally just a "datacenter=<foo>" statement) of the monitor. The
+   * force_loc is whether the mon cluster should replace a previously-known
+   * location. Generally the monitor will force an update if it's given a
+   * location from the CLI on boot-up, and then never force again (so that it
+   * can be moved/updated via the ceph tool from elsewhere). */
+  map<string,string> crush_loc;
+  bool force_loc{false};
 
   MMonJoin() : PaxosServiceMessage{MSG_MON_JOIN, 0, HEAD_VERSION, COMPAT_VERSION} {}
   MMonJoin(uuid_d &f, std::string n, const entity_addrvec_t& av)
     : PaxosServiceMessage{MSG_MON_JOIN, 0, HEAD_VERSION, COMPAT_VERSION},
       fsid(f), name(n), addrs(av)
   { }
+  MMonJoin(uuid_d &f, std::string n, const entity_addrvec_t& av, const map<string,string>& cloc, bool force)
+    : PaxosServiceMessage{MSG_MON_JOIN, 0, HEAD_VERSION, COMPAT_VERSION},
+      fsid(f), name(n), addrs(av), crush_loc(cloc), force_loc(force)
+  { }
   
 private:
   ~MMonJoin() final {}
@@ -38,7 +50,7 @@ private:
 public:
   std::string_view get_type_name() const override { return "mon_join"; }
   void print(std::ostream& o) const override {
-    o << "mon_join(" << name << " " << addrs << ")";
+    o << "mon_join(" << name << " " << addrs << " " << crush_loc << ")";
   }
 
   void encode_payload(uint64_t features) override {
@@ -50,6 +62,8 @@ public:
       header.version = HEAD_VERSION;
       header.compat_version = COMPAT_VERSION;
       encode(addrs, payload, features);
+      encode(crush_loc, payload);
+      encode(force_loc, payload);
     } else {
       header.version = 1;
       header.compat_version = 1;
@@ -68,6 +82,10 @@ public:
       addrs = entity_addrvec_t(addr);
     } else {
       decode(addrs, p);
+      if (header.version >= 3) {
+       decode(crush_loc, p);
+       decode(force_loc, p);
+      }
     }
   }
 };