std::vector<char> buffer;
buffer.reserve(512);
- PerfCountersCollection *coll = m_parent->m_cct->GetPerfCountersCollection();
+ PerfCountersCollection *coll = m_parent->m_cct->get_perfcounters_collection();
if (coll) {
coll->write_json_to_buf(buffer, schema);
}
return _module_type;
}
-PerfCountersCollection *CephContext::GetPerfCountersCollection()
+PerfCountersCollection *CephContext::get_perfcounters_collection()
{
return _perf_counters_collection;
}
uint32_t get_module_type() const;
/* Get the PerfCountersCollection of this CephContext */
- PerfCountersCollection *GetPerfCountersCollection();
+ PerfCountersCollection *get_perfcounters_collection();
ceph::HeartbeatMap *get_heartbeat_map() {
return _heartbeat_map;
{
if (journaler) { delete journaler; journaler = 0; }
if (logger) {
- g_ceph_context->GetPerfCountersCollection()->remove(logger);
+ g_ceph_context->get_perfcounters_collection()->remove(logger);
delete logger;
logger = 0;
}
// logger
logger = plb.create_perf_counters();
- g_ceph_context->GetPerfCountersCollection()->add(logger);
+ g_ceph_context->get_perfcounters_collection()->add(logger);
}
void MDLog::init_journaler()
if (objecter) { delete objecter; objecter = 0; }
if (logger) {
- g_ceph_context->GetPerfCountersCollection()->remove(logger);
+ g_ceph_context->get_perfcounters_collection()->remove(logger);
delete logger;
logger = 0;
}
if (mlogger) {
- g_ceph_context->GetPerfCountersCollection()->remove(logger);
+ g_ceph_context->get_perfcounters_collection()->remove(logger);
delete mlogger;
mlogger = 0;
}
mds_plb.add_u64_counter(l_mds_im, "im");
mds_plb.add_u64_counter(l_mds_iim, "iim");
logger = mds_plb.create_perf_counters();
- g_ceph_context->GetPerfCountersCollection()->add(logger);
+ g_ceph_context->get_perfcounters_collection()->add(logger);
}
{
mdm_plb.add_u64(l_mdm_malloc, "malloc");
mdm_plb.add_u64(l_mdm_buf, "buf");
mlogger = mdm_plb.create_perf_counters();
- g_ceph_context->GetPerfCountersCollection()->add(mlogger);
+ g_ceph_context->get_perfcounters_collection()->add(mlogger);
}
mdlog->create_logger();
plb.add_u64_counter(l_mdss_dcreq, "dcreq"); // dispatch client req
plb.add_u64_counter(l_mdss_dsreq, "dsreq"); // slave
logger = plb.create_perf_counters();
- g_ceph_context->GetPerfCountersCollection()->add(logger);
+ g_ceph_context->get_perfcounters_collection()->add(logger);
}
terminating_sessions(false) {
}
~Server() {
- g_ceph_context->GetPerfCountersCollection()->remove(logger);
+ g_ceph_context->get_perfcounters_collection()->remove(logger);
delete logger;
}
timer.init();
- g_ceph_context->GetPerfCountersCollection()->add(logger);
+ g_ceph_context->get_perfcounters_collection()->add(logger);
// all okay.
return 0;
journal_stop();
- g_ceph_context->GetPerfCountersCollection()->remove(logger);
+ g_ceph_context->get_perfcounters_collection()->remove(logger);
op_finisher.stop();
ondisk_finisher.stop();
delete authorize_handler_registry;
delete map_in_progress_cond;
delete class_handler;
- g_ceph_context->GetPerfCountersCollection()->remove(logger);
+ g_ceph_context->get_perfcounters_collection()->remove(logger);
delete logger;
delete store;
}
osd_plb.add_u64_counter(l_osd_mape_dup, "map_message_epoch_dups"); // dup osdmap epochs
logger = osd_plb.create_perf_counters();
- g_ceph_context->GetPerfCountersCollection()->add(logger);
+ g_ceph_context->get_perfcounters_collection()->add(logger);
}
int OSD::shutdown()
pcb.add_u64(l_osdc_osd_laggy, "osd_laggy");
logger = pcb.create_perf_counters();
- cct->GetPerfCountersCollection()->add(logger);
+ cct->get_perfcounters_collection()->add(logger);
}
timer.add_event_after(cct->_conf->objecter_tick_interval, new C_Tick(this));
}
if (logger) {
- cct->GetPerfCountersCollection()->remove(logger);
+ cct->get_perfcounters_collection()->remove(logger);
delete logger;
logger = NULL;
}
}
TEST(PerfCounters, SinglePerfCounters) {
- PerfCountersCollection *coll = g_ceph_context->GetPerfCountersCollection();
+ PerfCountersCollection *coll = g_ceph_context->get_perfcounters_collection();
PerfCounters* fake_pf = setup_test_perfcounters1(g_ceph_context);
coll->add(fake_pf);
g_ceph_context->_conf->set_val_or_die("admin_socket", get_rand_socket_path());
}
TEST(PerfCounters, MultiplePerfCounters) {
- PerfCountersCollection *coll = g_ceph_context->GetPerfCountersCollection();
+ PerfCountersCollection *coll = g_ceph_context->get_perfcounters_collection();
coll->clear();
PerfCounters* fake_pf1 = setup_test_perfcounters1(g_ceph_context);
PerfCounters* fake_pf2 = setup_test_perfcounter2(g_ceph_context);