X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmessages%2FMMonScrub.h;fp=src%2Fceph%2Fsrc%2Fmessages%2FMMonScrub.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=b66a34d7e1d55048918f94f2c8999825dec3d2a1;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/messages/MMonScrub.h b/src/ceph/src/messages/MMonScrub.h deleted file mode 100644 index b66a34d..0000000 --- a/src/ceph/src/messages/MMonScrub.h +++ /dev/null @@ -1,87 +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) 2013 Inktank, Inc. -* -* 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_MMONSCRUB_H -#define CEPH_MMONSCRUB_H - -#include "msg/Message.h" -#include "mon/mon_types.h" - -class MMonScrub : public Message -{ - static const int HEAD_VERSION = 2; - static const int COMPAT_VERSION = 2; - -public: - typedef enum { - OP_SCRUB = 1, // leader->peon: scrub (a range of) keys - OP_RESULT = 2, // peon->leader: result of a scrub - } op_type_t; - - static const char *get_opname(op_type_t op) { - switch (op) { - case OP_SCRUB: return "scrub"; - case OP_RESULT: return "result"; - default: assert(0 == "unknown op type"); return NULL; - } - } - - op_type_t op; - version_t version; - ScrubResult result; - int32_t num_keys; - pair key; - - MMonScrub() - : Message(MSG_MON_SCRUB, HEAD_VERSION, COMPAT_VERSION), - num_keys(-1) - { } - - MMonScrub(op_type_t op, version_t v, int32_t num_keys) - : Message(MSG_MON_SCRUB, HEAD_VERSION, COMPAT_VERSION), - op(op), version(v), num_keys(num_keys) - { } - - const char *get_type_name() const override { return "mon_scrub"; } - - void print(ostream& out) const override { - out << "mon_scrub(" << get_opname((op_type_t)op); - out << " v " << version; - if (op == OP_RESULT) - out << " " << result; - out << " num_keys " << num_keys; - out << " key (" << key << ")"; - out << ")"; - } - - void encode_payload(uint64_t features) override { - uint8_t o = op; - ::encode(o, payload); - ::encode(version, payload); - ::encode(result, payload); - ::encode(num_keys, payload); - ::encode(key, payload); - } - - void decode_payload() override { - bufferlist::iterator p = payload.begin(); - uint8_t o; - ::decode(o, p); - op = (op_type_t)o; - ::decode(version, p); - ::decode(result, p); - ::decode(num_keys, p); - ::decode(key, p); - } -}; - -#endif /* CEPH_MMONSCRUB_H */