ceph/src/messages/MOSDPGLeaseAck.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 #pragma once
   5
   6 #include "msg/Message.h"
   7 #include "osd/osd_types.h"
   8
   9 class MOSDPGLeaseAck final : public MOSDPeeringOp {
  10 private:
  11   static constexpr int HEAD_VERSION = 1;
  12   static constexpr int COMPAT_VERSION = 1;
  13
  14   epoch_t epoch = 0;
  15   spg_t spgid;
  16   pg_lease_ack_t lease_ack;
  17
  18 public:
  19   spg_t get_spg() const {
  20     return spgid;
  21   }
  22   epoch_t get_map_epoch() const {
  23     return epoch;
  24   }
  25   epoch_t get_min_epoch() const {
  26     return epoch;
  27   }
  28   PGPeeringEvent *get_event() override {
  29     return new PGPeeringEvent(
  30       epoch,
  31       epoch,
  32       MLeaseAck(epoch, get_source().num(), lease_ack));
  33   }
  34
  35   MOSDPGLeaseAck() : MOSDPeeringOp{MSG_OSD_PG_LEASE_ACK,
  36                                    HEAD_VERSION, COMPAT_VERSION} {}
  37   MOSDPGLeaseAck(version_t mv, spg_t p, pg_lease_ack_t lease_ack) :
  38     MOSDPeeringOp{MSG_OSD_PG_LEASE_ACK,
  39                   HEAD_VERSION, COMPAT_VERSION},
  40     epoch(mv),
  41     spgid(p),
  42     lease_ack(lease_ack) { }
  43 private:
  44   ~MOSDPGLeaseAck() final {}
  45
  46 public:
  47   std::string_view get_type_name() const override { return "pg_lease_ack"; }
  48   void inner_print(std::ostream& out) const override {
  49     out << lease_ack;
  50   }
  51
  52   void encode_payload(uint64_t features) override {
  53     using ceph::encode;
  54     encode(epoch, payload);
  55     encode(spgid, payload);
  56     encode(lease_ack, payload);
  57   }
  58   void decode_payload() override {
  59     using ceph::decode;
  60     auto p = payload.cbegin();
  61     decode(epoch, p);
  62     decode(spgid, p);
  63     decode(lease_ack, p);
  64   }
  65 private:
  66   template<class T, typename... Args>
  67   friend boost::intrusive_ptr<T> ceph::make_message(Args&&... args);
  68 };