shard_services.remove_want_pg_temp(orderer, pgid.pgid);
}
void check_recovery_sources(const OSDMapRef& newmap) final {
+ LOG_PREFIX(PG::check_recovery_sources);
recovery_backend->for_each_recovery_waiter(
- [newmap, FNAME](auto &, auto &waiter) {
+ [newmap, FNAME, this](auto &, auto &waiter) {
if (waiter->is_pulling() &&
newmap->is_down(waiter->pull_info->from.osd)) {
+ SUBDEBUGDPP(
+ osd,
+ " repeating pulling for {}, due to osd {} down",
+ *this,
+ waiter->pull_info->soid,
+ waiter->pull_info->from.osd);
waiter->repeat_pull();
}
});