// then kick all pgs,
for (hash_map<pg_t, PG*>::iterator p = pg_map.begin();
p != pg_map.end();
- p++) {
+ ++p) {
dout(20) << " kicking pg " << p->first << dendl;
p->second->lock();
p->second->kick();
// tell pgs we're shutting down
for (hash_map<pg_t, PG*>::iterator p = pg_map.begin();
p != pg_map.end();
- p++) {
+ ++p) {
p->second->lock();
p->second->on_shutdown();
p->second->unlock();
// close pgs
for (hash_map<pg_t, PG*>::iterator p = pg_map.begin();
p != pg_map.end();
- p++) {
+ ++p) {
PG *pg = p->second;
pg->put();
}
unsigned removed = 0;
for (vector<hobject_t>::iterator p = objects.begin();
p != objects.end();
- p++, removed++) {
+ ++p, removed++) {
t.collection_remove(tmp, *p);
if (removed > 300) {
int r = store->apply_transaction(t);
map<pg_t, interval_set<snapid_t> > pgs;
for (vector<coll_t>::iterator it = ls.begin();
it != ls.end();
- it++) {
+ ++it) {
pg_t pgid;
snapid_t snap;
epoch_t cur_epoch = superblock.newest_map;
for (hash_map<pg_t, PG*>::iterator i = pg_map.begin();
i != pg_map.end();
- i++) {
+ ++i) {
PG *pg = i->second;
epoch_t start, end;
osd_stat.kb_avail = stbuf.f_bavail * stbuf.f_bsize / 1024;
osd_stat.hb_in.clear();
- for (map<int,HeartbeatInfo>::iterator p = heartbeat_peers.begin(); p != heartbeat_peers.end(); p++)
+ for (map<int,HeartbeatInfo>::iterator p = heartbeat_peers.begin(); p != heartbeat_peers.end(); ++p)
osd_stat.hb_in.push_back(p->first);
osd_stat.hb_out.clear();
// build heartbeat from set
for (hash_map<pg_t, PG*>::iterator i = pg_map.begin();
i != pg_map.end();
- i++) {
+ ++i) {
PG *pg = i->second;
pg->heartbeat_peer_lock.Lock();
dout(20) << i->first << " heartbeat_peers " << pg->heartbeat_peers << dendl;
cutoff -= g_conf->osd_heartbeat_grace;
for (map<int,HeartbeatInfo>::iterator p = heartbeat_peers.begin();
p != heartbeat_peers.end();
- p++) {
+ ++p) {
dout(25) << "heartbeat_check osd." << p->first
<< " first_tx " << p->second.first_tx
<< " last_tx " << p->second.last_tx
// send heartbeats
for (map<int,HeartbeatInfo>::iterator i = heartbeat_peers.begin();
i != heartbeat_peers.end();
- i++) {
+ ++i) {
int peer = i->first;
dout(30) << "heartbeat allocating ping for osd." << peer << dendl;
Message *m = new MOSDPing(monc->get_fsid(),
if (r >= 0) {
ss << "header=" << string(hdrbl.c_str(), hdrbl.length());
for (map<string, bufferlist>::iterator it = keyvals.begin();
- it != keyvals.end(); it++)
+ it != keyvals.end(); ++it)
ss << " key=" << (*it).first << " val="
<< string((*it).second.c_str(), (*it).second.length());
} else {
if (m->scrub_pgs.empty()) {
for (hash_map<pg_t, PG*>::iterator p = pg_map.begin();
p != pg_map.end();
- p++) {
+ ++p) {
PG *pg = p->second;
pg->lock();
if (pg->is_primary()) {
} else {
for (vector<pg_t>::iterator p = m->scrub_pgs.begin();
p != m->scrub_pgs.end();
- p++)
+ ++p)
if (pg_map.count(*p)) {
PG *pg = pg_map[*p];
pg->lock();
// kill connections to newly down osds
set<int> old;
osdmap->get_all_osds(old);
- for (set<int>::iterator p = old.begin(); p != old.end(); p++) {
+ for (set<int>::iterator p = old.begin(); p != old.end(); ++p) {
if (*p != whoami &&
osdmap->have_inst(*p) && // in old map
(!newmap->exists(*p) || !newmap->is_up(*p))) { // but not the new one
// scan pg's
for (hash_map<pg_t,PG*>::iterator it = pg_map.begin();
it != pg_map.end();
- it++) {
+ ++it) {
PG *pg = it->second;
pg->lock();
if (pg->is_primary())
// scan pg's
for (hash_map<pg_t,PG*>::iterator it = pg_map.begin();
it != pg_map.end();
- it++) {
+ ++it) {
PG *pg = it->second;
pg->lock();
pg->queue_null(osdmap->get_epoch(), osdmap->get_epoch());
map<pg_t,PG*> children;
for (set<pg_t>::iterator q = childpgids.begin();
q != childpgids.end();
- q++) {
+ ++q) {
pg_history_t history;
history.epoch_created = history.same_up_since =
history.same_interval_since = history.same_primary_since =
// unlock parent, children
parent->unlock();
- for (map<pg_t,PG*>::iterator q = children.begin(); q != children.end(); q++) {
+ for (map<pg_t,PG*>::iterator q = children.begin(); q != children.end(); ++q) {
PG *pg = q->second;
pg->handle_create(&rctx);
pg->write_if_dirty(t);
vector<hobject_t> olist;
store->collection_list(coll_t(parent->info.pgid), olist);
- for (vector<hobject_t>::iterator p = olist.begin(); p != olist.end(); p++) {
+ for (vector<hobject_t>::iterator p = olist.begin(); p != olist.end(); ++p) {
hobject_t poid = *p;
object_locator_t oloc(parentid.pool());
if (poid.get_key().size())
list<pg_log_entry_t>::iterator p = parent->log.log.begin();
while (p != parent->log.log.end()) {
list<pg_log_entry_t>::iterator cur = p;
- p++;
+ ++p;
hobject_t& poid = cur->soid;
object_locator_t oloc(parentid.pool());
if (poid.get_key().size())
for (map<pg_t,PG*>::iterator p = children.begin();
p != children.end();
- p++) {
+ ++p) {
PG *child = p->second;
// fix log bounds
for (map<pg_t,pg_create_t>::iterator p = m->mkpg.begin();
p != m->mkpg.end();
- p++) {
+ ++p) {
pg_t pgid = p->first;
epoch_t created = p->second.created;
pg_t parent = p->second.parent;
dout(10) << "mkpg " << pgid << " e" << created
<< " h " << history
<< " : querying priors " << pset << dendl;
- for (set<int>::iterator p = pset.begin(); p != pset.end(); p++)
+ for (set<int>::iterator p = pset.begin(); p != pset.end(); ++p)
if (osdmap->is_up(*p))
(*rctx.query_map)[*p][pgid] = pg_query_t(pg_query_t::INFO, history,
osdmap->get_epoch());
{
for (map< int, vector<pair<pg_notify_t,pg_interval_map_t> > >::iterator it = notify_list.begin();
it != notify_list.end();
- it++) {
+ ++it) {
if (it->first == whoami) {
dout(7) << "do_notify osd." << it->first << " is self, skipping" << dendl;
continue;
{
for (map< int, map<pg_t,pg_query_t> >::iterator pit = query_map.begin();
pit != query_map.end();
- pit++) {
+ ++pit) {
if (!curmap->is_up(pit->first))
continue;
int who = pit->first;
for (vector<pair<pg_notify_t, pg_interval_map_t> >::iterator it = m->get_pg_list().begin();
it != m->get_pg_list().end();
- it++) {
+ ++it) {
PG *pg = 0;
if (it->first.info.pgid.preferred() >= 0) {
for (map<pg_t,pg_query_t>::iterator it = m->pg_list.begin();
it != m->pg_list.end();
- it++) {
+ ++it) {
pg_t pgid = it->first;
if (pgid.preferred() >= 0) {
for (vector<pg_t>::iterator it = m->pg_list.begin();
it != m->pg_list.end();
- it++) {
+ ++it) {
pg_t pgid = *it;
if (pgid.preferred() >= 0) {
dout(10) << "ignoring localized pg " << pgid << dendl;
}
replay_queue_lock.Unlock();
- for (list< pair<pg_t,utime_t> >::iterator p = pgids.begin(); p != pgids.end(); p++) {
+ for (list< pair<pg_t,utime_t> >::iterator p = pgids.begin(); p != pgids.end(); ++p) {
pg_t pgid = p->first;
if (pg_map.count(pgid)) {
PG *pg = _lookup_lock_pg_with_map_lock_held(pgid);