Signed-off-by: Michal Jarzabek <stiopa@gmail.com>
g_ceph_context->get_heartbeat_map()->reset_timeout(hb, g_conf->mds_beacon_grace, 0);
}
-bool MDSRank::is_stale_message(Message *m)
+bool MDSRank::is_stale_message(Message *m) const
{
// from bad mds?
if (m->get_source().is_mds()) {
ceph::heartbeat_handle_d *hb; // Heartbeat for threads using mds_lock
void heartbeat_reset();
- bool is_stale_message(Message *m);
+ bool is_stale_message(Message *m) const;
map<mds_rank_t, version_t> peer_mdsmap_epoch;
MDSMap *get_mds_map() { return mdsmap; }
- int get_req_rate() { return logger->get(l_mds_request); }
+ int get_req_rate() const { return logger->get(l_mds_request); }
int get_mds_slow_req_count() const { return mds_slow_req_count; }