X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmessages%2FMOSDPGUpdateLogMissingReply.h;fp=src%2Fceph%2Fsrc%2Fmessages%2FMOSDPGUpdateLogMissingReply.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=8df6d9be5c84d9cf0e015d6beca8454c57acec4a;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/messages/MOSDPGUpdateLogMissingReply.h b/src/ceph/src/messages/MOSDPGUpdateLogMissingReply.h deleted file mode 100644 index 8df6d9b..0000000 --- a/src/ceph/src/messages/MOSDPGUpdateLogMissingReply.h +++ /dev/null @@ -1,105 +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_MOSDPGUPDATELOGMISSINGREPLY_H -#define CEPH_MOSDPGUPDATELOGMISSINGREPLY_H - -#include "MOSDFastDispatchOp.h" - -class MOSDPGUpdateLogMissingReply : public MOSDFastDispatchOp { - - static const int HEAD_VERSION = 2; - static const int COMPAT_VERSION = 1; - - -public: - epoch_t map_epoch, min_epoch; - spg_t pgid; - shard_id_t from; - ceph_tid_t rep_tid; - - epoch_t get_epoch() const { return map_epoch; } - spg_t get_pgid() const { return pgid; } - epoch_t get_query_epoch() const { return map_epoch; } - ceph_tid_t get_tid() const { return rep_tid; } - pg_shard_t get_from() const { - return pg_shard_t(get_source().num(), from); - } - 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; - } - - MOSDPGUpdateLogMissingReply() - : MOSDFastDispatchOp( - MSG_OSD_PG_UPDATE_LOG_MISSING_REPLY, - HEAD_VERSION, - COMPAT_VERSION) - {} - MOSDPGUpdateLogMissingReply( - spg_t pgid, - shard_id_t from, - epoch_t epoch, - epoch_t min_epoch, - ceph_tid_t rep_tid) - : MOSDFastDispatchOp( - MSG_OSD_PG_UPDATE_LOG_MISSING_REPLY, - HEAD_VERSION, - COMPAT_VERSION), - map_epoch(epoch), - min_epoch(min_epoch), - pgid(pgid), - from(from), - rep_tid(rep_tid) - {} - -private: - ~MOSDPGUpdateLogMissingReply() override {} - -public: - const char *get_type_name() const override { return "PGUpdateLogMissingReply"; } - void print(ostream& out) const override { - out << "pg_update_log_missing_reply(" << pgid << " epoch " << map_epoch - << "/" << min_epoch - << " rep_tid " << rep_tid << ")"; - } - - void encode_payload(uint64_t features) override { - ::encode(map_epoch, payload); - ::encode(pgid, payload); - ::encode(from, payload); - ::encode(rep_tid, payload); - ::encode(min_epoch, payload); - } - void decode_payload() override { - bufferlist::iterator p = payload.begin(); - ::decode(map_epoch, p); - ::decode(pgid, p); - ::decode(from, p); - ::decode(rep_tid, p); - if (header.version >= 2) { - ::decode(min_epoch, p); - } else { - min_epoch = map_epoch; - } - } -}; - -#endif