Signed-off-by: Sage Weil <sage@newdream.net>
pg->update_stats();
}
- if (pg->is_active() && pg->missing.have_missing()) {
+ if (pg->is_active() && pg->have_unfound()) {
// Make sure we've requested MISSING information from every OSD
// we know about.
map< int, map<pg_t,PG::Query> > query_map;
// i am PRIMARY
if (pg->is_active()) {
// PG is ACTIVE
- if (pg->missing.have_missing()) {
+ if (pg->have_unfound()) {
dout(10) << *pg << " searching osd" << from << " log for missing items." << dendl;
pg->search_for_missing(info, missing, from);
void activate(ObjectStore::Transaction& t, list<Context*>& tfin,
map<int, MOSDPGInfo*> *activator_map=0);
+ bool have_unfound() const {
+ return missing.num_missing() > missing_loc.size();
+ }
+
virtual void clean_up_local(ObjectStore::Transaction& t) = 0;
virtual int start_recovery_ops(int max) = 0;