Signed-off-by: Joao Eduardo Luis <joao@suse.de>
}
scrub_result.clear();
- scrub_version = paxos->get_version();
scrub_state.reset(new ScrubState);
scrub();
assert(is_leader());
assert(scrub_state);
+ wait_for_paxos_write();
+ scrub_version = paxos->get_version();
+
// scrub all keys if we're the only monitor in the quorum
int32_t num_keys =
(quorum.size() == 1 ? -1 : cct->_conf->mon_scrub_max_keys);
{
if (!is_peon())
break;
+
+ wait_for_paxos_write();
+
if (m->version != paxos->get_version())
break;