void Elector::start()
{
- if (!participating) {
+ if (!logic.participating) {
dout(0) << "not starting new election -- not participating" << dendl;
return;
}
case MSG_MON_ELECTION:
{
- if (!participating) {
+ if (!logic.participating) {
return;
}
if (op->get_req()->get_source().num() >= mon->monmap->size()) {
void Elector::start_participating()
{
- if (!participating) {
- participating = true;
- }
+ logic.participating = true;
}
public:
Elector *elector;
epoch_t epoch;
+ bool participating;
bool electing_me;
set<int> acked_me;
int leader_acked;
- ElectionLogic(Elector *e) : elector(e), epoch(0),
+ ElectionLogic(Elector *e) : elector(e), epoch(0), participating(true),
electing_me(false), leader_acked(-1) {}
void init();
void bump_epoch(epoch_t e);
* have to call Elector::start_participating for us to resume
* participating in the quorum.
*/
- bool participating;
+ // bool participating;
// electing me
/**
*/
explicit Elector(Monitor *m) : logic(this),
elector(this),
- mon(m),
- participating(true) {}
+ mon(m) {}
/**
* Initiate the Elector class.
*
* @post @p participating is false
*/
- void stop_participating() { participating = false; }
+ void stop_participating() { logic.participating = false; }
/**
* Start participating in Elections.
*