encode_health(next, t);
}
-void OSDMonitor::trim_creating_pgs(creating_pgs_t* creating_pgs,
- const ceph::unordered_map<pg_t,pg_stat_t>& pg_stat)
-{
- auto p = creating_pgs->pgs.begin();
- while (p != creating_pgs->pgs.end()) {
- auto q = pg_stat.find(p->first);
- if (q != pg_stat.end() &&
- !(q->second.state & PG_STATE_CREATING)) {
- dout(20) << __func__ << " pgmap shows " << p->first << " is created"
- << dendl;
- p = creating_pgs->pgs.erase(p);
- } else {
- ++p;
- }
- }
-}
-
int OSDMonitor::load_metadata(int osd, map<string, string>& m, ostream *err)
{
bufferlist bl;
creating_pgs_t update_pending_pgs(const OSDMap::Incremental& inc,
const OSDMap& nextmap);
- void trim_creating_pgs(creating_pgs_t *creating_pgs,
- const ceph::unordered_map<pg_t,pg_stat_t>& pgm);
unsigned scan_for_creating_pgs(
const mempool::osdmap::map<int64_t,pg_pool_t>& pools,
const mempool::osdmap::set<int64_t>& removed_pools,
assert(osd < acting_rmap.size());
return acting_rmap[osd];
}
- /* unsued
- const std::vector<pg_t>& get_osd_up_pgs(unsigned osd) {
- assert(osd < up_rmap.size());
- return up_rmap[osd];
- }
- */
void update(const OSDMap& map);
void update(const OSDMap& map, pg_t pgid);