}
}
-void AuthMonitor::committed()
-{
-
-}
-
void AuthMonitor::election_finished()
{
dout(10) << "AuthMonitor::election_starting" << dendl;
uint64_t assign_global_id(MAuth *m, bool should_increase_max);
void encode_pending(bufferlist &bl); // propose pending update to peers
- void committed();
-
bool preprocess_query(PaxosServiceMessage *m); // true if processed.
bool prepare_update(PaxosServiceMessage *m);
}
}
-void LogMonitor::committed()
-{
-
-}
-
bool LogMonitor::preprocess_log(MLog *m)
{
dout(10) << "preprocess_log " << *m << " from " << m->get_orig_source() << dendl;
void create_pending(); // prepare a new pending
void encode_pending(bufferlist &bl); // propose pending update to peers
- void committed();
-
bool preprocess_query(PaxosServiceMessage *m); // true if processed.
bool prepare_update(PaxosServiceMessage *m);
m->put();
}
-
-void MDSMonitor::committed()
-{
-}
-
void MDSMonitor::on_active()
{
tick();
bool prepare_update(PaxosServiceMessage *m);
bool should_propose(double& delay);
- void committed();
void on_active();
void _note_beacon(class MMDSBeacon *m);
return true;
}
-void MonmapMonitor::committed()
-{
- //Nothing useful to do here.
-}
-
void MonmapMonitor::tick()
{
update_from_paxos();
*/
bool should_propose(double& delay);
- void committed();
-
void tick();
private:
}
-void OSDMonitor::committed()
-{
-}
-
void OSDMonitor::share_map_with_random_osd()
{
// tell any osd
void create_pending(); // prepare a new pending
void encode_pending(bufferlist &bl);
- void committed();
void share_map_with_random_osd();
void handle_query(PaxosServiceMessage *m);
}
}
-void PGMonitor::committed()
-{
-
-}
-
void PGMonitor::handle_statfs(MStatfs *statfs)
{
// check caps
void create_pending(); // prepare a new pending
void encode_pending(bufferlist &bl); // propose pending update to peers
- void committed();
-
bool preprocess_query(PaxosServiceMessage *m); // true if processed.
bool prepare_update(PaxosServiceMessage *m);
create_pending();
have_pending = true;
}
-
- committed();
}
}
*/
virtual void on_restart() { }
- virtual void committed() = 0; // [leader] called after a proposed value commits
-
virtual void tick() {}
virtual enum health_status_t get_health(std::ostream& os) const { return HEALTH_OK; }