diff options
| author | John Kåre Alsaker <john.kare.alsaker@gmail.com> | 2025-03-24 03:53:19 +0100 |
|---|---|---|
| committer | John Kåre Alsaker <john.kare.alsaker@gmail.com> | 2025-03-24 03:53:19 +0100 |
| commit | 38c39ffc6c6e19867f450c7204f341aeb0c495ec (patch) | |
| tree | 0f3d6053ca32174e2d916705bdf9133a5efae472 /compiler/rustc_query_system/src/query/job.rs | |
| parent | 14786ce645ef96c732f8b30154bc939ee4ba9faf (diff) | |
| download | rust-38c39ffc6c6e19867f450c7204f341aeb0c495ec.tar.gz rust-38c39ffc6c6e19867f450c7204f341aeb0c495ec.zip | |
Remove `QueryWaiter::notify`
Diffstat (limited to 'compiler/rustc_query_system/src/query/job.rs')
| -rw-r--r-- | compiler/rustc_query_system/src/query/job.rs | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/compiler/rustc_query_system/src/query/job.rs b/compiler/rustc_query_system/src/query/job.rs index e6ab7c4ef57..5ed8fb5393f 100644 --- a/compiler/rustc_query_system/src/query/job.rs +++ b/compiler/rustc_query_system/src/query/job.rs @@ -163,13 +163,6 @@ struct QueryWaiter { cycle: Mutex<Option<CycleError>>, } -impl QueryWaiter { - fn notify(&self, registry: &rayon_core::Registry) { - rayon_core::mark_unblocked(registry); - self.condvar.notify_one(); - } -} - #[derive(Debug)] struct QueryLatchInfo { complete: bool, @@ -232,7 +225,8 @@ impl QueryLatch { info.complete = true; let registry = rayon_core::Registry::current(); for waiter in info.waiters.drain(..) { - waiter.notify(®istry); + rayon_core::mark_unblocked(®istry); + waiter.condvar.notify_one(); } } |
