We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 54aa510 commit afef64cCopy full SHA for afef64c
src/concurrency_limiter.rs
@@ -1,6 +1,7 @@
1
use std::sync::{Arc, Condvar, Mutex};
2
3
use jobserver::HelperThread;
4
+use rustc_errors::DiagCtxtHandle;
5
use rustc_session::Session;
6
7
// FIXME don't panic when a worker thread panics
@@ -46,7 +47,7 @@ impl ConcurrencyLimiter {
46
47
}
48
49
- pub(super) fn acquire(&self, dcx: &rustc_errors::DiagCtxt) -> ConcurrencyLimiterToken {
50
+ pub(super) fn acquire(&self, dcx: DiagCtxtHandle<'_>) -> ConcurrencyLimiterToken {
51
let mut state = self.state.lock().unwrap();
52
loop {
53
state.assert_invariants();
0 commit comments