diff options
Diffstat (limited to 'src/osd/mClockOpClassSupport.cc')
| -rw-r--r-- | src/osd/mClockOpClassSupport.cc | 117 |
1 files changed, 117 insertions, 0 deletions
diff --git a/src/osd/mClockOpClassSupport.cc b/src/osd/mClockOpClassSupport.cc new file mode 100644 index 00000000..d35c2cbe --- /dev/null +++ b/src/osd/mClockOpClassSupport.cc @@ -0,0 +1,117 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab +/* + * Ceph - scalable distributed file system + * + * Copyright (C) 2017 Red Hat Inc. + * + * This is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software + * Foundation. See file COPYING. + * + */ + + +#include "common/dout.h" +#include "osd/mClockOpClassSupport.h" +#include "osd/OpQueueItem.h" + +#include "include/ceph_assert.h" + +namespace ceph { + + namespace mclock { + + OpClassClientInfoMgr::OpClassClientInfoMgr(CephContext *cct) : + client_op(cct->_conf->osd_op_queue_mclock_client_op_res, + cct->_conf->osd_op_queue_mclock_client_op_wgt, + cct->_conf->osd_op_queue_mclock_client_op_lim), + osd_rep_op(cct->_conf->osd_op_queue_mclock_osd_rep_op_res, + cct->_conf->osd_op_queue_mclock_osd_rep_op_wgt, + cct->_conf->osd_op_queue_mclock_osd_rep_op_lim), + snaptrim(cct->_conf->osd_op_queue_mclock_snap_res, + cct->_conf->osd_op_queue_mclock_snap_wgt, + cct->_conf->osd_op_queue_mclock_snap_lim), + recov(cct->_conf->osd_op_queue_mclock_recov_res, + cct->_conf->osd_op_queue_mclock_recov_wgt, + cct->_conf->osd_op_queue_mclock_recov_lim), + scrub(cct->_conf->osd_op_queue_mclock_scrub_res, + cct->_conf->osd_op_queue_mclock_scrub_wgt, + cct->_conf->osd_op_queue_mclock_scrub_lim), + pg_delete(cct->_conf->osd_op_queue_mclock_pg_delete_res, + cct->_conf->osd_op_queue_mclock_pg_delete_wgt, + cct->_conf->osd_op_queue_mclock_pg_delete_lim), + peering_event(cct->_conf->osd_op_queue_mclock_peering_event_res, + cct->_conf->osd_op_queue_mclock_peering_event_wgt, + cct->_conf->osd_op_queue_mclock_peering_event_lim) + { + constexpr int rep_ops[] = { + MSG_OSD_REPOP, + MSG_OSD_REPOPREPLY, + MSG_OSD_PG_UPDATE_LOG_MISSING, + MSG_OSD_PG_UPDATE_LOG_MISSING_REPLY, + MSG_OSD_EC_WRITE, + MSG_OSD_EC_WRITE_REPLY, + MSG_OSD_EC_READ, + MSG_OSD_EC_READ_REPLY + }; + for (auto op : rep_ops) { + add_rep_op_msg(op); + } + + lgeneric_subdout(cct, osd, 20) << + "mClock OpClass settings:: " << + "client_op:" << client_op << + "; osd_rep_op:" << osd_rep_op << + "; snaptrim:" << snaptrim << + "; recov:" << recov << + "; scrub:" << scrub << + dendl; + + lgeneric_subdout(cct, osd, 30) << + "mClock OpClass message bit set:: " << + rep_op_msg_bitset.to_string() << dendl; + } + + void OpClassClientInfoMgr::add_rep_op_msg(int message_code) { + ceph_assert(message_code >= 0 && message_code < int(rep_op_msg_bitset_size)); + rep_op_msg_bitset.set(message_code); + } + + osd_op_type_t + OpClassClientInfoMgr::osd_op_type(const OpQueueItem& op) const { + osd_op_type_t type = convert_op_type(op.get_op_type()); + if (osd_op_type_t::client_op != type) { + return type; + } else { + // get_header returns ceph_msg_header type, ceph_msg_header + // stores type as unsigned little endian, so be sure to + // convert to CPU byte ordering + boost::optional<OpRequestRef> op_ref_maybe = op.maybe_get_op(); + ceph_assert(op_ref_maybe); + __le16 mtype_le = (*op_ref_maybe)->get_req()->get_header().type; + __u16 mtype = le16_to_cpu(mtype_le); + if (rep_op_msg_bitset.test(mtype)) { + return osd_op_type_t::osd_rep_op; + } else { + return osd_op_type_t::client_op; + } + } + } + + // used for debugging since faster implementation can be done + // with rep_op_msg_bitmap + bool OpClassClientInfoMgr::is_rep_op(uint16_t mtype) { + return + MSG_OSD_REPOP == mtype || + MSG_OSD_REPOPREPLY == mtype || + MSG_OSD_PG_UPDATE_LOG_MISSING == mtype || + MSG_OSD_PG_UPDATE_LOG_MISSING_REPLY == mtype || + MSG_OSD_EC_WRITE == mtype || + MSG_OSD_EC_WRITE_REPLY == mtype || + MSG_OSD_EC_READ == mtype || + MSG_OSD_EC_READ_REPLY == mtype; + } + } // namespace mclock +} // namespace ceph |