}
-class MDS::C_MDS_RestartReplay : public Context {
+class MDS::C_MDS_StandbyReplayRestartFinish : public Context {
MDS *mds;
uint64_t old_read_pos;
public:
- C_MDS_RestartReplay(MDS *mds_, uint64_t old_read_pos_) :
+ C_MDS_StandbyReplayRestartFinish(MDS *mds_, uint64_t old_read_pos_) :
mds(mds_), old_read_pos(old_read_pos_) {}
void finish(int r) {
if (old_read_pos < mds->mdlog->get_journaler()->get_trimmed_pos()) {
cerr << "standby MDS fell behind active MDS journal's expire_pos, restarting" << std::endl;
mds->respawn(); /* we're too far back, and this is easier than
trying to reset everything in the cache, etc */
- }
- else {
+ } else {
mds->boot_start(3, r);
}
}
inline void MDS::standby_replay_restart()
{
mdlog->get_journaler()->reread_head_and_probe(
- new C_MDS_RestartReplay(this, mdlog->get_journaler()->get_read_pos()));
+ new C_MDS_StandbyReplayRestartFinish(this, mdlog->get_journaler()->get_read_pos()));
}
-class MDS::C_Standby_replay_start : public Context {
+class MDS::C_MDS_StandbyReplayRestart : public Context {
MDS *mds;
public:
- C_Standby_replay_start(MDS *m) : mds(m) {}
+ C_MDS_StandbyReplayRestart(MDS *m) : mds(m) {}
void finish(int r) {
assert(!r);
mds->standby_replay_restart();
standby_trim_segments();
dout(10) << "setting replay timer" << dendl;
timer.add_event_after(g_conf.mds_replay_interval,
- new C_Standby_replay_start(this));
+ new C_MDS_StandbyReplayRestart(this));
return;
}
void replay_done();
void standby_replay_restart();
void standby_trim_segments();
- class C_Standby_replay_start;
- class C_MDS_RestartReplay;
+ class C_MDS_StandbyReplayRestart;
+ class C_MDS_StandbyReplayRestartFinish;
void resolve_start();
void resolve_done();