ceph/src/messages/MOSDPGRecoveryDelete.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 #ifndef CEPH_MOSDPGRECOVERYDELETE_H
   5 #define CEPH_MOSDPGRECOVERYDELETE_H
   6
   7 #include "MOSDFastDispatchOp.h"
   8
   9 /*
  10  * instruct non-primary to remove some objects during recovery
  11  */
  12
  13 struct MOSDPGRecoveryDelete : public MOSDFastDispatchOp {
  14
  15   static const int HEAD_VERSION = 1;
  16   static const int COMPAT_VERSION = 1;
  17
  18   pg_shard_t from;
  19   spg_t pgid;            ///< target spg_t
  20   epoch_t map_epoch, min_epoch;
  21   list<pair<hobject_t, eversion_t> > objects;    ///< objects to remove
  22
  23 private:
  24   uint64_t cost;
  25
  26 public:
  27   int get_cost() const override {
  28     return cost;
  29   }
  30
  31   epoch_t get_map_epoch() const override {
  32     return map_epoch;
  33   }
  34   epoch_t get_min_epoch() const override {
  35     return min_epoch;
  36   }
  37   spg_t get_spg() const override {
  38     return pgid;
  39   }
  40
  41   void set_cost(uint64_t c) {
  42     cost = c;
  43   }
  44
  45   MOSDPGRecoveryDelete()
  46     : MOSDFastDispatchOp(MSG_OSD_PG_RECOVERY_DELETE, HEAD_VERSION,
  47                          COMPAT_VERSION), cost(0) {}
  48
  49   MOSDPGRecoveryDelete(pg_shard_t from, spg_t pgid, epoch_t map_epoch,
  50                        epoch_t min_epoch)
  51     : MOSDFastDispatchOp(MSG_OSD_PG_RECOVERY_DELETE, HEAD_VERSION,
  52                          COMPAT_VERSION),
  53       from(from),
  54       pgid(pgid),
  55       map_epoch(map_epoch),
  56       min_epoch(min_epoch),
  57       cost(0) {}
  58
  59 private:
  60   ~MOSDPGRecoveryDelete() {}
  61
  62 public:
  63   const char *get_type_name() const { return "recovery_delete"; }
  64   void print(ostream& out) const {
  65     out << "MOSDPGRecoveryDelete(" << pgid << " e" << map_epoch << ","
  66         << min_epoch << " " << objects << ")";
  67   }
  68
  69   void encode_payload(uint64_t features) {
  70     ::encode(from, payload);
  71     ::encode(pgid, payload);
  72     ::encode(map_epoch, payload);
  73     ::encode(min_epoch, payload);
  74     ::encode(cost, payload);
  75     ::encode(objects, payload);
  76   }
  77   void decode_payload() {
  78     bufferlist::iterator p = payload.begin();
  79     ::decode(from, p);
  80     ::decode(pgid, p);
  81     ::decode(map_epoch, p);
  82     ::decode(min_epoch, p);
  83     ::decode(cost, p);
  84     ::decode(objects, p);
  85   }
  86 };
  87
  88
  89
  90 #endif