ceph/src/osd/mClockOpClassSupport.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) 2017 Red Hat 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
  16 #pragma once
  17
  18 #include <bitset>
  19
  20 #include "dmclock/src/dmclock_server.h"
  21 #include "osd/OpRequest.h"
  22 #include "osd/OpQueueItem.h"
  23
  24
  25 namespace ceph {
  26   namespace mclock {
  27
  28     using op_item_type_t = OpQueueItem::OpQueueable::op_type_t;
  29
  30     enum class osd_op_type_t {
  31       client_op, osd_rep_op, bg_snaptrim, bg_recovery, bg_scrub, bg_pg_delete,
  32       peering_event
  33     };
  34
  35     class OpClassClientInfoMgr {
  36       crimson::dmclock::ClientInfo client_op;
  37       crimson::dmclock::ClientInfo osd_rep_op;
  38       crimson::dmclock::ClientInfo snaptrim;
  39       crimson::dmclock::ClientInfo recov;
  40       crimson::dmclock::ClientInfo scrub;
  41       crimson::dmclock::ClientInfo pg_delete;
  42       crimson::dmclock::ClientInfo peering_event;
  43
  44       static constexpr std::size_t rep_op_msg_bitset_size = 128;
  45       std::bitset<rep_op_msg_bitset_size> rep_op_msg_bitset;
  46       void add_rep_op_msg(int message_code);
  47
  48     public:
  49
  50       OpClassClientInfoMgr(CephContext *cct);
  51
  52       inline const crimson::dmclock::ClientInfo*
  53       get_client_info(osd_op_type_t type) {
  54         switch(type) {
  55         case osd_op_type_t::client_op:
  56           return &client_op;
  57         case osd_op_type_t::osd_rep_op:
  58           return &osd_rep_op;
  59         case osd_op_type_t::bg_snaptrim:
  60           return &snaptrim;
  61         case osd_op_type_t::bg_recovery:
  62           return &recov;
  63         case osd_op_type_t::bg_scrub:
  64           return &scrub;
  65         case osd_op_type_t::bg_pg_delete:
  66           return &pg_delete;
  67         case osd_op_type_t::peering_event:
  68           return &peering_event;
  69         default:
  70           ceph_abort();
  71           return nullptr;
  72         }
  73       }
  74
  75       // converts operation type from op queue internal to mclock
  76       // equivalent
  77       inline static osd_op_type_t convert_op_type(op_item_type_t t) {
  78         switch(t) {
  79         case op_item_type_t::client_op:
  80           return osd_op_type_t::client_op;
  81         case op_item_type_t::bg_snaptrim:
  82           return osd_op_type_t::bg_snaptrim;
  83         case op_item_type_t::bg_recovery:
  84           return osd_op_type_t::bg_recovery;
  85         case op_item_type_t::bg_scrub:
  86           return osd_op_type_t::bg_scrub;
  87         case op_item_type_t::bg_pg_delete:
  88           return osd_op_type_t::bg_pg_delete;
  89         case op_item_type_t::peering_event:
  90           return osd_op_type_t::peering_event;
  91         default:
  92           ceph_abort();
  93         }
  94       }
  95
  96       osd_op_type_t osd_op_type(const OpQueueItem&) const;
  97
  98       // used for debugging since faster implementation can be done
  99       // with rep_op_msg_bitmap
 100       static bool is_rep_op(uint16_t);
 101     }; // OpClassClientInfoMgr
 102   } // namespace mclock
 103 } // namespace ceph