src/ceph/src/dmclock/sim/src/test_dmclock.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) 2016 Red Hat Inc.
   6  */
   7
   8
   9 #include "dmclock_recs.h"
  10 #include "dmclock_server.h"
  11 #include "dmclock_client.h"
  12
  13 #include "sim_recs.h"
  14 #include "sim_server.h"
  15 #include "sim_client.h"
  16
  17 #include "simulate.h"
  18
  19
  20 namespace crimson {
  21   namespace test_dmc {
  22
  23     namespace dmc = crimson::dmclock;
  24     namespace sim = crimson::qos_simulation;
  25
  26     struct DmcAccum {
  27       uint64_t reservation_count = 0;
  28       uint64_t proportion_count = 0;
  29     };
  30
  31     using DmcQueue = dmc::PushPriorityQueue<ClientId,sim::TestRequest>;
  32
  33     using DmcServer = sim::SimulatedServer<DmcQueue,
  34                                            dmc::ReqParams,
  35                                            dmc::PhaseType,
  36                                            DmcAccum>;
  37
  38     using DmcClient = sim::SimulatedClient<dmc::ServiceTracker<ServerId>,
  39                                            dmc::ReqParams,
  40                                            dmc::PhaseType,
  41                                            DmcAccum>;
  42
  43     using CreateQueueF = std::function<DmcQueue*(DmcQueue::CanHandleRequestFunc,
  44                                                  DmcQueue::HandleRequestFunc)>;
  45
  46     using MySim = sim::Simulation<ServerId,ClientId,DmcServer,DmcClient>;
  47
  48     using SubmitFunc = DmcClient::SubmitFunc;
  49
  50     extern void dmc_server_accumulate_f(DmcAccum& a,
  51                                         const dmc::PhaseType& phase);
  52
  53     extern void dmc_client_accumulate_f(DmcAccum& a,
  54                                         const dmc::PhaseType& phase);
  55   } // namespace test_dmc
  56 } // namespace crimson