// i am (inactive) primary
if (!pg->is_peering() ||
(pg->need_up_thru && up_thru >= pg->info.history.same_acting_since))
- pg->peer(t, tfin, query_map, &info_map);
+ pg->do_peer(t, tfin, query_map, &info_map);
}
else if (pg->is_stray() &&
pg->get_primary() >= 0) {
wake_pg_waiters(pg->info.pgid);
- pg->peer(*t, fin->contexts, query_map, &info_map);
+ pg->do_peer(*t, fin->contexts, query_map, &info_map);
pg->update_stats();
pg->unlock();
created++;
creating_pgs.erase(pgid);
wake_pg_waiters(pg->info.pgid);
- pg->peer(*t, fin->contexts, query_map, &info_map);
+ pg->do_peer(*t, fin->contexts, query_map, &info_map);
pg->update_stats();
int tr = store->queue_transaction(&pg->osr, t, new ObjectStore::C_DeleteTransaction(t), fin);
pg->state_clear(PG_STATE_CLEAN);
}
- pg->peer(*t, fin->contexts, query_map, &info_map);
+ pg->do_peer(*t, fin->contexts, query_map, &info_map);
pg->update_stats();
}
int tr = store->queue_transaction(&pg->osr, t, new ObjectStore::C_DeleteTransaction(t), fin);
// peer
map< int, map<pg_t,PG::Query> > query_map;
- pg->peer(*t, fin->contexts, query_map, info_map);
+ pg->do_peer(*t, fin->contexts, query_map, info_map);
pg->update_stats();
do_queries(query_map);
}
map< int, map<pg_t,PG::Query> > query_map; // peer -> PG -> get_summary_since
ObjectStore::Transaction *t = new ObjectStore::Transaction;
C_Contexts *fin = new C_Contexts;
- pg->peer(*t, fin->contexts, query_map, NULL);
+ pg->do_peer(*t, fin->contexts, query_map, NULL);
do_queries(query_map);
if (pg->dirty_info)
pg->write_info(*t);
bool choose_acting(int newest_update_osd);
bool recover_master_log(map< int, map<pg_t,Query> >& query_map);
- void peer(ObjectStore::Transaction& t, list<Context*>& tfin,
- map< int, map<pg_t,Query> >& query_map,
- map<int, MOSDPGInfo*> *activator_map=0);
+ void do_peer(ObjectStore::Transaction& t, list<Context*>& tfin,
+ map< int, map<pg_t,Query> >& query_map,
+ map<int, MOSDPGInfo*> *activator_map=0);
void activate(ObjectStore::Transaction& t, list<Context*>& tfin,
map<int, MOSDPGInfo*> *activator_map=0);