]>
git.proxmox.com Git - ceph.git/blob - ceph/src/mgr/MDSPerfMetricCollector.cc
1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #include "common/debug.h"
5 #include "common/errno.h"
7 #include "messages/MMgrReport.h"
8 #include "mgr/MDSPerfMetricTypes.h"
9 #include "mgr/MDSPerfMetricCollector.h"
11 #define dout_context g_ceph_context
12 #define dout_subsys ceph_subsys_mgr
14 #define dout_prefix *_dout << "mgr.mds_perf_metric_collector " << __func__ << " "
16 MDSPerfMetricCollector::MDSPerfMetricCollector(MetricListener
&listener
)
17 : MetricCollector
<MDSPerfMetricQuery
,
20 MDSPerfMetrics
>(listener
) {
23 void MDSPerfMetricCollector::process_reports(const MetricPayload
&payload
) {
24 const MDSPerfMetricReport
&metric_report
= boost::get
<MDSMetricPayload
>(payload
).metric_report
;
26 std::lock_guard
locker(lock
);
27 process_reports_generic(
28 metric_report
.reports
, [](PerformanceCounter
*counter
, const PerformanceCounter
&update
) {
29 counter
->first
= update
.first
;
30 counter
->second
= update
.second
;
33 // update delayed rank set
34 delayed_ranks
= metric_report
.rank_metrics_delayed
;
35 dout(20) << ": delayed ranks=[" << delayed_ranks
<< "]" << dendl
;
38 int MDSPerfMetricCollector::get_counters(PerfCollector
*collector
) {
39 MDSPerfCollector
*c
= static_cast<MDSPerfCollector
*>(collector
);
41 std::lock_guard
locker(lock
);
43 int r
= get_counters_generic(c
->query_id
, &c
->counters
);
48 get_delayed_ranks(&c
->delayed_ranks
);
53 void MDSPerfMetricCollector::get_delayed_ranks(std::set
<mds_rank_t
> *ranks
) {
54 ceph_assert(ceph_mutex_is_locked(lock
));
55 *ranks
= delayed_ranks
;