We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
QueryWaiter::notify
1 parent 14786ce commit 38c39ffCopy full SHA for 38c39ff
compiler/rustc_query_system/src/query/job.rs
@@ -163,13 +163,6 @@ struct QueryWaiter {
163
cycle: Mutex<Option<CycleError>>,
164
}
165
166
-impl QueryWaiter {
167
- fn notify(&self, registry: &rayon_core::Registry) {
168
- rayon_core::mark_unblocked(registry);
169
- self.condvar.notify_one();
170
- }
171
-}
172
-
173
#[derive(Debug)]
174
struct QueryLatchInfo {
175
complete: bool,
@@ -232,7 +225,8 @@ impl QueryLatch {
232
225
info.complete = true;
233
226
let registry = rayon_core::Registry::current();
234
227
for waiter in info.waiters.drain(..) {
235
- waiter.notify(®istry);
228
+ rayon_core::mark_unblocked(®istry);
229
+ waiter.condvar.notify_one();
236
230
237
231
238
0 commit comments