From d0708b5452017b7be4be78df0444102a531fccba Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Fri, 6 May 2022 23:55:31 -0700 Subject: [PATCH] crimson/osd/pg_recovery: remove new_started, fix parallel_for_each call Presumably typo from b7e2b11595c6e2cd2c638135ef6f044c40efaa87. Fixes: https://tracker.ceph.com/issues/55565 Signed-off-by: Samuel Just --- src/crimson/osd/pg_recovery.cc | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/crimson/osd/pg_recovery.cc b/src/crimson/osd/pg_recovery.cc index 4b0c3f0fbac..ccdd4980afb 100644 --- a/src/crimson/osd/pg_recovery.cc +++ b/src/crimson/osd/pg_recovery.cc @@ -51,9 +51,7 @@ PGRecovery::start_recovery_ops( assert(!pg->is_backfilling()); assert(!pg->get_peering_state().is_deleting()); - std::vector> new_started; std::vector> started; - new_started.reserve(max_to_start); started.reserve(max_to_start); max_to_start -= start_primary_recovery_ops(trigger, max_to_start, &started); if (max_to_start > 0) { @@ -61,7 +59,7 @@ PGRecovery::start_recovery_ops( } using interruptor = crimson::interruptible::interruptor; - return interruptor::parallel_for_each(std::move(new_started), + return interruptor::parallel_for_each(std::move(started), [] (auto&& ifut) { return std::move(ifut); }).then_interruptible([this] { -- 2.47.3