about summary refs log tree commit diff
path: root/compiler/rustc_query_system/src/query/job.rs
diff options
context:
space:
mode:
authorJohn Kåre Alsaker <john.kare.alsaker@gmail.com>2025-03-24 03:53:19 +0100
committerJohn Kåre Alsaker <john.kare.alsaker@gmail.com>2025-03-24 03:53:19 +0100
commit38c39ffc6c6e19867f450c7204f341aeb0c495ec (patch)
tree0f3d6053ca32174e2d916705bdf9133a5efae472 /compiler/rustc_query_system/src/query/job.rs
parent14786ce645ef96c732f8b30154bc939ee4ba9faf (diff)
downloadrust-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.rs10
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(&registry);
+            rayon_core::mark_unblocked(&registry);
+            waiter.condvar.notify_one();
         }
     }