From: Samuel Just Date: Sat, 7 May 2022 06:55:31 +0000 (-0700) Subject: crimson/osd/pg_recovery: remove new_started, fix parallel_for_each call X-Git-Tag: v18.0.0~937^2~1 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=d0708b5452017b7be4be78df0444102a531fccba;p=ceph.git 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 --- diff --git a/src/crimson/osd/pg_recovery.cc b/src/crimson/osd/pg_recovery.cc index 4b0c3f0fbac3..ccdd4980afb6 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] {