rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-16 18:02:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

review: kick_waiters -> await_waiters_remainder

Browse Source
This commit is contained in:
Vlad Lazar
2024-06-17 11:44:39 +01:00
parent 089edb55e8
commit 86d5f4ada9
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
storage_controller/src/service.rs
View File

@@ -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<ReconcilerWaiter>,
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