1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
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
|
