src/ceph/src/messages/MRecoveryReserve.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3 /*
   4  * Ceph - scalable distributed file system
   5  *
   6  * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
   7  *
   8  * This is free software; you can redistribute it and/or
   9  * modify it under the terms of the GNU Lesser General Public
  10  * License version 2.1, as published by the Free Software
  11  * Foundation.  See file COPYING.
  12  *
  13  */
  14
  15 #ifndef CEPH_MRECOVERY_H
  16 #define CEPH_MRECOVERY_H
  17
  18 #include "msg/Message.h"
  19
  20 class MRecoveryReserve : public Message {
  21   static const int HEAD_VERSION = 2;
  22   static const int COMPAT_VERSION = 2;
  23 public:
  24   spg_t pgid;
  25   epoch_t query_epoch;
  26   enum {
  27     REQUEST = 0,
  28     GRANT = 1,
  29     RELEASE = 2,
  30   };
  31   int type;
  32
  33   MRecoveryReserve()
  34     : Message(MSG_OSD_RECOVERY_RESERVE, HEAD_VERSION, COMPAT_VERSION),
  35       query_epoch(0), type(-1) {}
  36   MRecoveryReserve(int type,
  37                    spg_t pgid,
  38                    epoch_t query_epoch)
  39     : Message(MSG_OSD_RECOVERY_RESERVE, HEAD_VERSION, COMPAT_VERSION),
  40       pgid(pgid), query_epoch(query_epoch),
  41       type(type) {}
  42
  43   const char *get_type_name() const override {
  44     return "MRecoveryReserve";
  45   }
  46
  47   void print(ostream& out) const override {
  48     out << "MRecoveryReserve(" << pgid;
  49     switch (type) {
  50     case REQUEST:
  51       out << " REQUEST";
  52       break;
  53     case GRANT:
  54       out << " GRANT";
  55       break;
  56     case RELEASE:
  57       out << " RELEASE";
  58       break;
  59     }
  60     out << " e" << query_epoch << ")";
  61     return;
  62   }
  63
  64   void decode_payload() override {
  65     bufferlist::iterator p = payload.begin();
  66     ::decode(pgid.pgid, p);
  67     ::decode(query_epoch, p);
  68     ::decode(type, p);
  69     ::decode(pgid.shard, p);
  70   }
  71
  72   void encode_payload(uint64_t features) override {
  73     ::encode(pgid.pgid, payload);
  74     ::encode(query_epoch, payload);
  75     ::encode(type, payload);
  76     ::encode(pgid.shard, payload);
  77   }
  78 };
  79
  80 #endif