}
}
- hobject_t backfill_pos =
- std::min(backfill_info.begin, earliest_peer_backfill());
-
for (set<hobject_t>::iterator i = add_to_stat.begin();
i != add_to_stat.end();
++i) {
pgbackend->run_recovery_op(h, get_recovery_op_priority());
+ hobject_t backfill_pos =
+ std::min(backfill_info.begin, earliest_peer_backfill());
dout(5) << "backfill_pos is " << backfill_pos << dendl;
for (set<hobject_t>::iterator i = backfills_in_flight.begin();
i != backfills_in_flight.end();
pending_backfill_updates.erase(i++)) {
dout(20) << " pending_backfill_update " << i->first << dendl;
ceph_assert(i->first > new_last_backfill);
+ // carried from a previous round – if we are here, then we had to
+ // be requeued (by e.g. on_global_recover()) and those operations
+ // are done.
recovery_state.update_complete_backfill_object_stats(
i->first,
i->second);