}
check_subs();
- update_logger();
}
void MDSMonitor::init()
return floor;
}
-void MDSMonitor::update_logger()
-{
- dout(10) << "update_logger" << dendl;
-
- uint64_t up = 0;
- uint64_t in = 0;
- uint64_t failed = 0;
- for (const auto &i : fsmap.filesystems) {
- const MDSMap &mds_map = i.second->mds_map;
-
- up += mds_map.get_num_up_mds();
- in += mds_map.get_num_in_mds();
- failed += mds_map.get_num_failed_mds();
- }
- mon->cluster_logger->set(l_cluster_num_mds_up, up);
- mon->cluster_logger->set(l_cluster_num_mds_in, in);
- mon->cluster_logger->set(l_cluster_num_mds_failed, failed);
- mon->cluster_logger->set(l_cluster_mds_epoch, fsmap.get_epoch());
-}
-
bool MDSMonitor::preprocess_query(MonOpRequestRef op)
{
op->mark_mdsmon_event(__func__);
void MDSMonitor::on_active()
{
tick();
- update_logger();
if (mon->is_leader()) {
mon->clog->debug() << "fsmap " << fsmap;
// my helpers
void print_map(FSMap &m, int dbl=7);
- void update_logger();
void _updated(MonOpRequestRef op);
pcb.add_u64(l_cluster_num_object_misplaced, "num_object_misplaced", "Misplaced (wrong location in the cluster) objects");
pcb.add_u64(l_cluster_num_object_unfound, "num_object_unfound", "Unfound objects");
pcb.add_u64(l_cluster_num_bytes, "num_bytes", "Size of all objects");
- pcb.add_u64(l_cluster_num_mds_up, "num_mds_up", "MDSs that are up");
- pcb.add_u64(l_cluster_num_mds_in, "num_mds_in", "MDS in state \"in\" (they are in cluster)");
- pcb.add_u64(l_cluster_num_mds_failed, "num_mds_failed", "Failed MDS");
- pcb.add_u64(l_cluster_mds_epoch, "mds_epoch", "Current epoch of MDS map");
cluster_logger = pcb.create_perf_counters();
}
l_cluster_num_object_misplaced,
l_cluster_num_object_unfound,
l_cluster_num_bytes,
- l_cluster_num_mds_up,
- l_cluster_num_mds_in,
- l_cluster_num_mds_failed,
- l_cluster_mds_epoch,
l_cluster_last,
};