ceph/src/messages/MTimeCheck2.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) 2012 Inktank, Inc.
   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 #pragma once
  16
  17 class MTimeCheck2 : public MessageInstance<MTimeCheck2> {
  18 public:
  19   friend factory;
  20
  21   static constexpr int HEAD_VERSION = 1;
  22   static constexpr int COMPAT_VERSION = 1;
  23
  24   enum {
  25     OP_PING = 1,
  26     OP_PONG = 2,
  27     OP_REPORT = 3,
  28   };
  29
  30   int op = 0;
  31   version_t epoch = 0;
  32   version_t round = 0;
  33
  34   utime_t timestamp;
  35   map<int, double> skews;
  36   map<int, double> latencies;
  37
  38   MTimeCheck2() : MessageInstance(MSG_TIMECHECK2, HEAD_VERSION, COMPAT_VERSION) { }
  39   MTimeCheck2(int op) :
  40     MessageInstance(MSG_TIMECHECK2, HEAD_VERSION, COMPAT_VERSION),
  41     op(op)
  42   { }
  43
  44 private:
  45   ~MTimeCheck2() override { }
  46
  47 public:
  48   std::string_view get_type_name() const override { return "time_check2"; }
  49   const char *get_op_name() const {
  50     switch (op) {
  51     case OP_PING: return "ping";
  52     case OP_PONG: return "pong";
  53     case OP_REPORT: return "report";
  54     }
  55     return "???";
  56   }
  57   void print(ostream &o) const override {
  58     o << "time_check( " << get_op_name()
  59       << " e " << epoch << " r " << round;
  60     if (op == OP_PONG) {
  61       o << " ts " << timestamp;
  62     } else if (op == OP_REPORT) {
  63       o << " #skews " << skews.size()
  64         << " #latencies " << latencies.size();
  65     }
  66     o << " )";
  67   }
  68
  69   void decode_payload() override {
  70     auto p = payload.cbegin();
  71     decode(op, p);
  72     decode(epoch, p);
  73     decode(round, p);
  74     decode(timestamp, p);
  75     decode(skews, p);
  76     decode(latencies, p);
  77   }
  78
  79   void encode_payload(uint64_t features) override {
  80     using ceph::encode;
  81     encode(op, payload);
  82     encode(epoch, payload);
  83     encode(round, payload);
  84     encode(timestamp, payload);
  85     encode(skews, payload, features);
  86     encode(latencies, payload, features);
  87   }
  88 };