]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
crimson/osd/pg_recovery: remove new_started, fix parallel_for_each call
authorSamuel Just <sjust@redhat.com>
Sat, 7 May 2022 06:55:31 +0000 (23:55 -0700)
committerSamuel Just <sjust@redhat.com>
Sat, 7 May 2022 06:56:09 +0000 (23:56 -0700)
Presumably typo from b7e2b11595c6e2cd2c638135ef6f044c40efaa87.

Fixes: https://tracker.ceph.com/issues/55565
Signed-off-by: Samuel Just <sjust@redhat.com>
src/crimson/osd/pg_recovery.cc

index 4b0c3f0fbac3367966ff1e34c0cbfff06ec2c35e..ccdd4980afb630c5fbe289cd4b254a4f7f418ca2 100644 (file)
@@ -51,9 +51,7 @@ PGRecovery::start_recovery_ops(
   assert(!pg->is_backfilling());
   assert(!pg->get_peering_state().is_deleting());
 
-  std::vector<RecoveryBackend::interruptible_future<>> new_started;
   std::vector<interruptible_future<>> 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<crimson::osd::IOInterruptCondition>;
-  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] {