Signed-off-by: Colin McCabe <colinm@hq.newdream.net>
version_t map_ver[PAXOS_NUM];
-version_t last_seen_version = 0;
-
void handle_observe(MMonObserve *observe)
{
dout(1) << observe->get_source() << " -> " << get_paxos_name(observe->machine_id)
timer.add_event_after(seconds, new C_ObserverRefresh(false));
}
-
-
-
-int lines = 0;
-
void handle_ack(MMonCommandAck *ack)
{
lock.Lock();
void send_command()
{
+ version_t last_seen_version = 0;
MMonCommand *m = new MMonCommand(mc.monmap.fsid, last_seen_version);
m->cmd = pending_cmd;
m->set_data(pending_bl);