We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4b9def8 commit bf694f2Copy full SHA for bf694f2
src/crimson/osd/pg.h
@@ -357,10 +357,17 @@ class PG : public boost::intrusive_ref_counter<
357
shard_services.remove_want_pg_temp(orderer, pgid.pgid);
358
}
359
void check_recovery_sources(const OSDMapRef& newmap) final {
360
+ LOG_PREFIX(PG::check_recovery_sources);
361
recovery_backend->for_each_recovery_waiter(
- [newmap, FNAME](auto &, auto &waiter) {
362
+ [newmap, FNAME, this](auto &, auto &waiter) {
363
if (waiter->is_pulling() &&
364
newmap->is_down(waiter->pull_info->from.osd)) {
365
+ SUBDEBUGDPP(
366
+ osd,
367
+ " repeating pulling for {}, due to osd {} down",
368
+ *this,
369
+ waiter->pull_info->soid,
370
+ waiter->pull_info->from.osd);
371
waiter->repeat_pull();
372
373
});
0 commit comments