derr << "failed to list pgs: " << cpp_strerror(-r) << dendl;
}
- set<spg_t> pgs;
+ bool has_upgraded = false;
+
for (vector<coll_t>::iterator it = ls.begin();
it != ls.end();
++it) {
spg_t pgid;
- if (it->is_temp(&pgid) ||
- it->is_removal(&pgid) ||
- (it->is_pg(&pgid) && PG::_has_removal_flag(store, pgid))) {
+ if (it->is_temp(&pgid) || it->is_removal(&pgid) ||
+ (it->is_pg(&pgid) && PG::_has_removal_flag(store, pgid))) {
dout(10) << "load_pgs " << *it << " clearing temp" << dendl;
recursive_remove_collection(store, pgid, *it);
continue;
}
- if (it->is_pg(&pgid)) {
- pgs.insert(pgid);
+ if (!it->is_pg(&pgid)) {
+ dout(10) << "load_pgs ignoring unrecognized " << *it << dendl;
continue;
}
- dout(10) << "load_pgs ignoring unrecognized " << *it << dendl;
- }
-
- bool has_upgraded = false;
- for (set<spg_t>::iterator i = pgs.begin(); i != pgs.end(); ++i) {
- spg_t pgid(*i);
-
if (pgid.preferred() >= 0) {
dout(10) << __func__ << ": skipping localized PG " << pgid << dendl;
// FIXME: delete it too, eventually