}
} else {
assert(sub->type == "mgrdigest");
- if (digest_callback == nullptr) {
+ if (digest_event == nullptr) {
send_digests();
}
}
*/
void MgrMonitor::send_digests()
{
- digest_callback = nullptr;
+ digest_event = nullptr;
const std::string type = "mgrdigest";
if (mon->session_map.subs.count(type) == 0)
sub->session->con->send_message(mdigest);
}
- digest_callback = new C_MonContext(mon, [this](int){
+ digest_event = new C_MonContext(mon, [this](int){
send_digests();
});
- mon->timer.add_event_after(g_conf->mon_mgr_digest_period, digest_callback);
+ mon->timer.add_event_after(g_conf->mon_mgr_digest_period, digest_event);
}
void MgrMonitor::on_active()
void MgrMonitor::init()
{
- if (digest_callback == nullptr) {
+ if (digest_event == nullptr) {
send_digests(); // To get it to schedule its own event
}
}
void MgrMonitor::on_shutdown()
{
- if (digest_callback) {
- mon->timer.cancel_event(digest_callback);
+ if (digest_event) {
+ mon->timer.cancel_event(digest_event);
}
}
-
void drop_active();
void drop_standby(uint64_t gid);
- Context *digest_callback;
+ Context *digest_event = nullptr;
bool check_caps(MonOpRequestRef op, const uuid_d& fsid);
public:
MgrMonitor(Monitor *mn, Paxos *p, const string& service_name)
- : PaxosService(mn, p, service_name), digest_callback(nullptr)
+ : PaxosService(mn, p, service_name)
{}
void init() override;