Skip to content

Commit 2ea904b

Browse files
committed
Better communicate role of LimitedCoordinator
1 parent b6948c1 commit 2ea904b

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

compiler/base/orchestrator/src/coordinator.rs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2780,12 +2780,12 @@ mod tests {
27802780
static CONCURRENT_TEST_SEMAPHORE: Lazy<Arc<Semaphore>> =
27812781
Lazy::new(|| Arc::new(Semaphore::new(*MAX_CONCURRENT_TESTS)));
27822782

2783-
struct RestrictedCoordinator<T> {
2783+
struct LimitedCoordinator<T> {
27842784
_permit: OwnedSemaphorePermit,
27852785
coordinator: Coordinator<T>,
27862786
}
27872787

2788-
impl<T> RestrictedCoordinator<T>
2788+
impl<T> LimitedCoordinator<T>
27892789
where
27902790
T: Backend,
27912791
{
@@ -2810,29 +2810,29 @@ mod tests {
28102810
}
28112811
}
28122812

2813-
impl<T> ops::Deref for RestrictedCoordinator<T> {
2813+
impl<T> ops::Deref for LimitedCoordinator<T> {
28142814
type Target = Coordinator<T>;
28152815

28162816
fn deref(&self) -> &Self::Target {
28172817
&self.coordinator
28182818
}
28192819
}
28202820

2821-
impl<T> ops::DerefMut for RestrictedCoordinator<T> {
2821+
impl<T> ops::DerefMut for LimitedCoordinator<T> {
28222822
fn deref_mut(&mut self) -> &mut Self::Target {
28232823
&mut self.coordinator
28242824
}
28252825
}
28262826

2827-
async fn new_coordinator_test() -> RestrictedCoordinator<impl Backend> {
2828-
RestrictedCoordinator::with(|| Coordinator::new(TestBackend::new())).await
2827+
async fn new_coordinator_test() -> LimitedCoordinator<impl Backend> {
2828+
LimitedCoordinator::with(|| Coordinator::new(TestBackend::new())).await
28292829
}
28302830

2831-
async fn new_coordinator_docker() -> RestrictedCoordinator<impl Backend> {
2832-
RestrictedCoordinator::with(|| Coordinator::new_docker()).await
2831+
async fn new_coordinator_docker() -> LimitedCoordinator<impl Backend> {
2832+
LimitedCoordinator::with(|| Coordinator::new_docker()).await
28332833
}
28342834

2835-
async fn new_coordinator() -> RestrictedCoordinator<impl Backend> {
2835+
async fn new_coordinator() -> LimitedCoordinator<impl Backend> {
28362836
#[cfg(not(force_docker))]
28372837
{
28382838
new_coordinator_test().await

0 commit comments

Comments
 (0)