ceph/src/messages/MOSDPGReadyToMerge.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 class MOSDPGReadyToMerge : public PaxosServiceMessage {
   7 public:
   8   pg_t pgid;
   9   eversion_t source_version, target_version;
  10   epoch_t last_epoch_started = 0;
  11   epoch_t last_epoch_clean = 0;
  12   bool ready = true;
  13
  14   MOSDPGReadyToMerge()
  15     : PaxosServiceMessage{MSG_OSD_PG_READY_TO_MERGE, 0}
  16   {}
  17   MOSDPGReadyToMerge(pg_t p, eversion_t sv, eversion_t tv,
  18                      epoch_t les, epoch_t lec, bool r, epoch_t v)
  19     : PaxosServiceMessage{MSG_OSD_PG_READY_TO_MERGE, v},
  20       pgid(p),
  21       source_version(sv),
  22       target_version(tv),
  23       last_epoch_started(les),
  24       last_epoch_clean(lec),
  25       ready(r)
  26   {}
  27   void encode_payload(uint64_t features) override {
  28     using ceph::encode;
  29     paxos_encode();
  30     encode(pgid, payload);
  31     encode(source_version, payload);
  32     encode(target_version, payload);
  33     encode(last_epoch_started, payload);
  34     encode(last_epoch_clean, payload);
  35     encode(ready, payload);
  36   }
  37   void decode_payload() override {
  38     bufferlist::const_iterator p = payload.begin();
  39     paxos_decode(p);
  40     decode(pgid, p);
  41     decode(source_version, p);
  42     decode(target_version, p);
  43     decode(last_epoch_started, p);
  44     decode(last_epoch_clean, p);
  45     decode(ready, p);
  46   }
  47   std::string_view get_type_name() const override { return "osd_pg_ready_to_merge"; }
  48   void print(ostream &out) const {
  49     out << get_type_name()
  50         << "(" << pgid
  51         << " sv " << source_version
  52         << " tv " << target_version
  53         << " les/c " << last_epoch_started << "/" << last_epoch_clean
  54         << (ready ? " ready" : " NOT READY")
  55         << " v" << version << ")";
  56   }
  57 private:
  58   template<class T, typename... Args>
  59   friend boost::intrusive_ptr<T> ceph::make_message(Args&&... args);
  60 };