}
// degraded?
- if (get_osdmap()->get_pg_size(info.pgid.pgid) > acting.size())
+ if (get_osdmap()->get_pg_size(info.pgid.pgid) > actingset.size())
state_set(PG_STATE_DEGRADED);
}
pg->dirty_big_info = true;
}
- for (vector<int>::iterator p = pg->want_acting.begin();
- p != pg->want_acting.end(); ++p) {
- if (!advmap.osdmap->is_up(*p)) {
- assert((std::find(pg->acting.begin(), pg->acting.end(), *p) !=
- pg->acting.end()) ||
- (std::find(pg->up.begin(), pg->up.end(), *p) !=
- pg->up.end()));
+ for (size_t i = 0; i < pg->want_acting.size(); i++) {
+ int osd = pg->want_acting[i];
+ if (!advmap.osdmap->is_up(osd)) {
+ pg_shard_t osd_with_shard(osd, shard_id_t(i));
+ assert(pg->is_acting(osd_with_shard) || pg->is_up(osd_with_shard));
}
}
* this does not matter) */
if (advmap.lastmap->get_pg_size(pg->info.pgid.pgid) !=
pg->get_osdmap()->get_pg_size(pg->info.pgid.pgid)) {
- if (pg->get_osdmap()->get_pg_size(pg->info.pgid.pgid) <= pg->acting.size())
+ if (pg->get_osdmap()->get_pg_size(pg->info.pgid.pgid) <= pg->actingset.size())
pg->state_clear(PG_STATE_DEGRADED);
else
pg->state_set(PG_STATE_DEGRADED);