From 86d5f4ada9a90b33917a06f055cd0ca1cc3c7a48 Mon Sep 17 00:00:00 2001 From: Vlad Lazar Date: Mon, 17 Jun 2024 11:44:39 +0100 Subject: [PATCH] review: kick_waiters -> await_waiters_remainder --- storage_controller/src/service.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/storage_controller/src/service.rs b/storage_controller/src/service.rs index a16ae87968..51e5535e48 100644 --- a/storage_controller/src/service.rs +++ b/storage_controller/src/service.rs @@ -1908,7 +1908,7 @@ impl Service { /// Same as [`Service::await_waiters`], but returns the waiters which are still /// in progress - async fn kick_waiters( + async fn await_waiters_remainder( &self, waiters: Vec, timeout: Duration, @@ -5210,11 +5210,11 @@ impl Service { } } - waiters = self.kick_waiters(waiters, SHORT_RECONCILE_TIMEOUT).await; + waiters = self.await_waiters_remainder(waiters, SHORT_RECONCILE_TIMEOUT).await; } while !waiters.is_empty() { - waiters = self.kick_waiters(waiters, SHORT_RECONCILE_TIMEOUT).await; + waiters = self.await_waiters_remainder(waiters, SHORT_RECONCILE_TIMEOUT).await; } // At this point we have done the best we could to drain shards from this node. @@ -5367,11 +5367,11 @@ impl Service { } } - waiters = self.kick_waiters(waiters, SHORT_RECONCILE_TIMEOUT).await; + waiters = self.await_waiters_remainder(waiters, SHORT_RECONCILE_TIMEOUT).await; } while !waiters.is_empty() { - waiters = self.kick_waiters(waiters, SHORT_RECONCILE_TIMEOUT).await; + waiters = self.await_waiters_remainder(waiters, SHORT_RECONCILE_TIMEOUT).await; } if let Err(err) = self