src/ceph/src/dmclock/src/dmclock_recs.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 /*
   5  * Copyright (C) 2017 Red Hat Inc.
   6  */
   7
   8
   9 #pragma once
  10
  11
  12 #include <ostream>
  13 #include <assert.h>
  14
  15
  16 namespace crimson {
  17   namespace dmclock {
  18     using Counter = uint64_t;
  19
  20     enum class PhaseType { reservation, priority };
  21
  22     inline std::ostream& operator<<(std::ostream& out, const PhaseType& phase) {
  23       out << (PhaseType::reservation == phase ? "reservation" : "priority");
  24       return out;
  25     }
  26
  27     struct ReqParams {
  28       // count of all replies since last request; MUSTN'T BE 0
  29       uint32_t delta;
  30
  31       // count of reservation replies since last request; MUSTN'T BE 0
  32       uint32_t rho;
  33
  34       ReqParams(uint32_t _delta, uint32_t _rho) :
  35         delta(_delta),
  36         rho(_rho)
  37       {
  38         assert(0 != delta && 0 != rho && rho <= delta);
  39       }
  40
  41       ReqParams() :
  42         ReqParams(1, 1)
  43       {
  44         // empty
  45       }
  46
  47       ReqParams(const ReqParams& other) :
  48         delta(other.delta),
  49         rho(other.rho)
  50       {
  51         // empty
  52       }
  53
  54       friend std::ostream& operator<<(std::ostream& out, const ReqParams& rp) {
  55         out << "ReqParams{ delta:" << rp.delta <<
  56           ", rho:" << rp.rho << " }";
  57         return out;
  58       }
  59     }; // class ReqParams
  60   }
  61 }