X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmessages%2FMMonProbe.h;fp=src%2Fceph%2Fsrc%2Fmessages%2FMMonProbe.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=c98fc3a759493528c9d489fb65958157deefb819;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/messages/MMonProbe.h b/src/ceph/src/messages/MMonProbe.h deleted file mode 100644 index c98fc3a..0000000 --- a/src/ceph/src/messages/MMonProbe.h +++ /dev/null @@ -1,130 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab -/* - * Ceph - scalable distributed file system - * - * Copyright (C) 2004-2006 Sage Weil - * - * This is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License version 2.1, as published by the Free Software - * Foundation. See file COPYING. - * - */ - - -#ifndef CEPH_MMONPROBE_H -#define CEPH_MMONPROBE_H - -#include "include/ceph_features.h" -#include "msg/Message.h" -#include "mon/MonMap.h" - -class MMonProbe : public Message { -public: - static const int HEAD_VERSION = 6; - static const int COMPAT_VERSION = 5; - - enum { - OP_PROBE = 1, - OP_REPLY = 2, - OP_SLURP = 3, - OP_SLURP_LATEST = 4, - OP_DATA = 5, - OP_MISSING_FEATURES = 6, - }; - - static const char *get_opname(int o) { - switch (o) { - case OP_PROBE: return "probe"; - case OP_REPLY: return "reply"; - case OP_SLURP: return "slurp"; - case OP_SLURP_LATEST: return "slurp_latest"; - case OP_DATA: return "data"; - case OP_MISSING_FEATURES: return "missing_features"; - default: ceph_abort(); return 0; - } - } - - uuid_d fsid; - int32_t op = 0; - string name; - set quorum; - bufferlist monmap_bl; - version_t paxos_first_version = 0; - version_t paxos_last_version = 0; - bool has_ever_joined = 0; - uint64_t required_features = 0; - - MMonProbe() - : Message(MSG_MON_PROBE, HEAD_VERSION, COMPAT_VERSION) {} - MMonProbe(const uuid_d& f, int o, const string& n, bool hej) - : Message(MSG_MON_PROBE, HEAD_VERSION, COMPAT_VERSION), - fsid(f), - op(o), - name(n), - paxos_first_version(0), - paxos_last_version(0), - has_ever_joined(hej), - required_features(0) {} -private: - ~MMonProbe() override {} - -public: - const char *get_type_name() const override { return "mon_probe"; } - void print(ostream& out) const override { - out << "mon_probe(" << get_opname(op) << " " << fsid << " name " << name; - if (quorum.size()) - out << " quorum " << quorum; - if (op == OP_REPLY) { - out << " paxos(" - << " fc " << paxos_first_version - << " lc " << paxos_last_version - << " )"; - } - if (!has_ever_joined) - out << " new"; - if (required_features) - out << " required_features " << required_features; - out << ")"; - } - - void encode_payload(uint64_t features) override { - if (monmap_bl.length() && - ((features & CEPH_FEATURE_MONENC) == 0 || - (features & CEPH_FEATURE_MSG_ADDR2) == 0)) { - // reencode old-format monmap - MonMap t; - t.decode(monmap_bl); - monmap_bl.clear(); - t.encode(monmap_bl, features); - } - - ::encode(fsid, payload); - ::encode(op, payload); - ::encode(name, payload); - ::encode(quorum, payload); - ::encode(monmap_bl, payload); - ::encode(has_ever_joined, payload); - ::encode(paxos_first_version, payload); - ::encode(paxos_last_version, payload); - ::encode(required_features, payload); - } - void decode_payload() override { - bufferlist::iterator p = payload.begin(); - ::decode(fsid, p); - ::decode(op, p); - ::decode(name, p); - ::decode(quorum, p); - ::decode(monmap_bl, p); - ::decode(has_ever_joined, p); - ::decode(paxos_first_version, p); - ::decode(paxos_last_version, p); - if (header.version >= 6) - ::decode(required_features, p); - else - required_features = 0; - } -}; - -#endif