11use std:: sync:: { Arc , Condvar , Mutex } ;
22
3- use jobserver:: HelperThread ;
3+ use rustc_data_structures :: jobserver:: { self , HelperThread } ;
44use rustc_errors:: DiagCtxtHandle ;
5- use rustc_session:: Session ;
65
76// FIXME don't panic when a worker thread panics
87
@@ -14,14 +13,13 @@ pub(super) struct ConcurrencyLimiter {
1413}
1514
1615impl ConcurrencyLimiter {
17- pub ( super ) fn new ( sess : & Session , pending_jobs : usize ) -> Self {
16+ pub ( super ) fn new ( pending_jobs : usize ) -> Self {
1817 let state = Arc :: new ( Mutex :: new ( state:: ConcurrencyLimiterState :: new ( pending_jobs) ) ) ;
1918 let available_token_condvar = Arc :: new ( Condvar :: new ( ) ) ;
2019
2120 let state_helper = state. clone ( ) ;
2221 let available_token_condvar_helper = available_token_condvar. clone ( ) ;
23- let helper_thread = sess
24- . jobserver
22+ let helper_thread = jobserver:: client ( )
2523 . clone ( )
2624 . into_helper_thread ( move |token| {
2725 let mut state = state_helper. lock ( ) . unwrap ( ) ;
@@ -113,7 +111,7 @@ impl Drop for ConcurrencyLimiterToken {
113111}
114112
115113mod state {
116- use jobserver:: Acquired ;
114+ use rustc_data_structures :: jobserver:: Acquired ;
117115
118116 #[ derive( Debug ) ]
119117 pub ( super ) struct ConcurrencyLimiterState {
0 commit comments