X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmessages%2FMOSDRepScrub.h;fp=src%2Fceph%2Fsrc%2Fmessages%2FMOSDRepScrub.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=ce800aac068b3543fb981a595d0b27578912affd;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/messages/MOSDRepScrub.h b/src/ceph/src/messages/MOSDRepScrub.h deleted file mode 100644 index ce800aa..0000000 --- a/src/ceph/src/messages/MOSDRepScrub.h +++ /dev/null @@ -1,120 +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_MOSDREPSCRUB_H -#define CEPH_MOSDREPSCRUB_H - -#include "MOSDFastDispatchOp.h" - -/* - * instruct an OSD initiate a replica scrub on a specific PG - */ - -struct MOSDRepScrub : public MOSDFastDispatchOp { - - static const int HEAD_VERSION = 7; - static const int COMPAT_VERSION = 6; - - spg_t pgid; // PG to scrub - eversion_t scrub_from; // only scrub log entries after scrub_from - eversion_t scrub_to; // last_update_applied when message sent - epoch_t map_epoch = 0, min_epoch = 0; - bool chunky; // true for chunky scrubs - hobject_t start; // lower bound of scrub, inclusive - hobject_t end; // upper bound of scrub, exclusive - bool deep; // true if scrub should be deep - uint32_t seed; // seed value for digest calculation - - epoch_t get_map_epoch() const override { - return map_epoch; - } - epoch_t get_min_epoch() const override { - return min_epoch; - } - spg_t get_spg() const override { - return pgid; - } - - MOSDRepScrub() - : MOSDFastDispatchOp(MSG_OSD_REP_SCRUB, HEAD_VERSION, COMPAT_VERSION), - chunky(false), - deep(false), - seed(0) { } - - MOSDRepScrub(spg_t pgid, eversion_t scrub_to, epoch_t map_epoch, epoch_t min_epoch, - hobject_t start, hobject_t end, bool deep, uint32_t seed) - : MOSDFastDispatchOp(MSG_OSD_REP_SCRUB, HEAD_VERSION, COMPAT_VERSION), - pgid(pgid), - scrub_to(scrub_to), - map_epoch(map_epoch), - min_epoch(min_epoch), - chunky(true), - start(start), - end(end), - deep(deep), - seed(seed) { } - - -private: - ~MOSDRepScrub() override {} - -public: - const char *get_type_name() const override { return "replica scrub"; } - void print(ostream& out) const override { - out << "replica scrub(pg: "; - out << pgid << ",from:" << scrub_from << ",to:" << scrub_to - << ",epoch:" << map_epoch << "/" << min_epoch - << ",start:" << start << ",end:" << end - << ",chunky:" << chunky - << ",deep:" << deep - << ",seed:" << seed - << ",version:" << header.version; - out << ")"; - } - - void encode_payload(uint64_t features) override { - ::encode(pgid.pgid, payload); - ::encode(scrub_from, payload); - ::encode(scrub_to, payload); - ::encode(map_epoch, payload); - ::encode(chunky, payload); - ::encode(start, payload); - ::encode(end, payload); - ::encode(deep, payload); - ::encode(pgid.shard, payload); - ::encode(seed, payload); - ::encode(min_epoch, payload); - } - void decode_payload() override { - bufferlist::iterator p = payload.begin(); - ::decode(pgid.pgid, p); - ::decode(scrub_from, p); - ::decode(scrub_to, p); - ::decode(map_epoch, p); - ::decode(chunky, p); - ::decode(start, p); - ::decode(end, p); - ::decode(deep, p); - ::decode(pgid.shard, p); - ::decode(seed, p); - if (header.version >= 7) { - ::decode(min_epoch, p); - } else { - min_epoch = map_epoch; - } - } -}; - -#endif