Monitor::~Monitor()
{
- for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); p++)
+ for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); ++p)
delete *p;
delete paxos;
assert(session_map.sessions.empty());
}
// clean up
- for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); p++)
+ for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); ++p)
(*p)->shutdown();
finish_contexts(g_ceph_context, waitfor_quorum, -ECANCELED);
paxos->restart();
- for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); p++)
+ for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); ++p)
(*p)->restart();
}
<< " won leader election with quorum " << quorum << "\n";
paxos->leader_init();
- for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); p++)
+ for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); ++p)
(*p)->election_finished();
finish_election();
sync_role &= ~SYNC_ROLE_LEADER;
paxos->peon_init();
- for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); p++)
+ for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); ++p)
(*p)->election_finished();
finish_election();
for (vector<PaxosService*>::iterator p = paxos_service.begin();
p != paxos_service.end();
- p++) {
+ ++p) {
PaxosService *s = *p;
s->get_health(summary, detailbl ? &detail : NULL);
}
int mon = get_leader();
for (map<uint64_t, RoutedRequest*>::iterator p = routed_requests.begin();
p != routed_requests.end();
- p++) {
+ ++p) {
RoutedRequest *rr = p->second;
bufferlist::iterator q = rr->request_bl.begin();
assert(!s->closed);
for (set<uint64_t>::iterator p = s->routed_request_tids.begin();
p != s->routed_request_tids.end();
- p++) {
+ ++p) {
if (routed_requests.count(*p)) {
RoutedRequest *rr = routed_requests[*p];
dout(10) << " dropping routed request " << rr->tid << dendl;
s->until += g_conf->mon_subscribe_interval;
for (map<string,ceph_mon_subscribe_item>::iterator p = m->what.begin();
p != m->what.end();
- p++) {
+ ++p) {
// if there are any non-onetime subscriptions, we need to reply to start the resubscribe timer
if ((p->second.flags & CEPH_SUBSCRIBE_ONETIME) == 0)
reply = true;
// ok go.
dout(11) << "tick" << dendl;
- for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); p++) {
+ for (vector<PaxosService*>::iterator p = paxos_service.begin(); p != paxos_service.end(); ++p) {
(*p)->tick();
}