blob: 62298aba36a01b00d859327ad05c8332240f56ec (
plain)
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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "common/debug.h"
#include "common/errno.h"
#include "messages/MMgrReport.h"
#include "mgr/MDSPerfMetricTypes.h"
#include "mgr/MDSPerfMetricCollector.h"
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mgr
#undef dout_prefix
#define dout_prefix *_dout << "mgr.mds_perf_metric_collector " << __func__ << " "
MDSPerfMetricCollector::MDSPerfMetricCollector(MetricListener &listener)
: MetricCollector<MDSPerfMetricQuery,
MDSPerfMetricLimit,
MDSPerfMetricKey,
MDSPerfMetrics>(listener) {
}
void MDSPerfMetricCollector::process_reports(const MetricPayload &payload) {
const MDSPerfMetricReport &metric_report = boost::get<MDSMetricPayload>(payload).metric_report;
std::lock_guard locker(lock);
process_reports_generic(
metric_report.reports, [](PerformanceCounter *counter, const PerformanceCounter &update) {
counter->first = update.first;
counter->second = update.second;
});
// update delayed rank set
delayed_ranks = metric_report.rank_metrics_delayed;
dout(20) << ": delayed ranks=[" << delayed_ranks << "]" << dendl;
clock_gettime(CLOCK_MONOTONIC_COARSE, &last_updated_mono);
}
int MDSPerfMetricCollector::get_counters(PerfCollector *collector) {
MDSPerfCollector *c = static_cast<MDSPerfCollector *>(collector);
std::lock_guard locker(lock);
int r = get_counters_generic(c->query_id, &c->counters);
if (r != 0) {
return r;
}
get_delayed_ranks(&c->delayed_ranks);
get_last_updated(&c->last_updated_mono);
return r;
}
void MDSPerfMetricCollector::get_delayed_ranks(std::set<mds_rank_t> *ranks) {
ceph_assert(ceph_mutex_is_locked(lock));
*ranks = delayed_ranks;
}
void MDSPerfMetricCollector::get_last_updated(utime_t *ts) {
ceph_assert(ceph_mutex_is_locked(lock));
*ts = utime_t(last_updated_mono);
}
|
