}
}
-LogClient::LogClient(Messenger *m, MonMap *mm, MonClient *mc, enum logclient_flag_t flags) :
- Dispatcher(m->cct),
+LogClient::LogClient(CephContext *cct, Messenger *m, MonMap *mm,
+ MonClient *mc, enum logclient_flag_t flags) :
+ Dispatcher(cct),
messenger(m), monmap(mm), monc(mc), is_mon(flags & FLAG_MON),
log_lock("LogClient::log_lock"), last_log_sent(0), last_log(0)
{
FLAG_MON = 0x1,
};
- LogClient(Messenger *m, MonMap *mm, MonClient *mc, enum logclient_flag_t flags);
+ LogClient(CephContext *cct, Messenger *m, MonMap *mm,
+ MonClient *mc, enum logclient_flag_t flags);
void handle_log_ack(MLogAck *m);
standby_replaying(false),
messenger(m),
monc(mc),
- clog(messenger, &mc->monmap, mc, LogClient::NO_FLAGS),
+ clog(m->cct, messenger, &mc->monmap, mc, LogClient::NO_FLAGS),
sessionmap(this) {
orig_argc = 0;
lock("Monitor::lock"),
timer(lock),
monmap(map),
- clog(messenger, monmap, NULL, LogClient::FLAG_MON),
+ clog(cct_, messenger, monmap, NULL, LogClient::FLAG_MON),
store(s),
state(STATE_STARTING), stopping(false),
logger(NULL), logger_started(false),
store(NULL),
map_in_progress(false),
- clog(client_messenger, &mc->monmap, mc, LogClient::NO_FLAGS),
+ clog(hbm->cct, client_messenger, &mc->monmap, mc, LogClient::NO_FLAGS),
whoami(id),
dev_path(dev), journal_path(jdev),
dispatch_running(false),