diff --git a/src/crimson/osd/backfill_facades.h b/src/crimson/osd/backfill_facades.h index ddebfced603..21b18a8b3b0 100644 --- a/src/crimson/osd/backfill_facades.h +++ b/src/crimson/osd/backfill_facades.h @@ -35,9 +35,12 @@ struct BackfillState::PeeringFacade { return peering_state.get_info().log_tail; } - decltype(auto) get_pg_log() const { - return peering_state.get_pg_log(); + template + void scan_log_after(Args&&... args) const { + peering_state.get_pg_log().get_log().scan_log_after( + std::forward(args)...); } + bool is_backfill_target(pg_shard_t peer) const { return peering_state.is_backfill_target(peer); } diff --git a/src/crimson/osd/backfill_state.cc b/src/crimson/osd/backfill_state.cc index 3d1191ec9c0..3a173a75758 100644 --- a/src/crimson/osd/backfill_state.cc +++ b/src/crimson/osd/backfill_state.cc @@ -127,7 +127,7 @@ void BackfillState::Enqueuing::maybe_update_range() primary_bi.version, pg().get_projected_last_update()); logger().debug("{}: scanning pg log first", __func__); - peering_state().get_pg_log().get_log().scan_log_after(primary_bi.version, + peering_state().scan_log_after(primary_bi.version, [&](const pg_log_entry_t& e) { logger().debug("maybe_update_range(lambda): updating from version {}", e.version);