@@ -482,7 +482,6 @@ mod imp {
482
482
use std:: os:: unix:: prelude:: * ;
483
483
use std:: process:: Command ;
484
484
use std:: ptr;
485
- use std:: sync:: atomic:: { AtomicBool , Ordering } ;
486
485
use std:: sync:: { Arc , Once } ;
487
486
use std:: thread:: { self , Builder , JoinHandle } ;
488
487
use std:: time:: Duration ;
@@ -678,9 +677,9 @@ mod imp {
678
677
}
679
678
680
679
pub ( crate ) fn spawn_helper (
681
- client : :: Client ,
680
+ client : crate :: Client ,
682
681
state : Arc < super :: HelperState > ,
683
- mut f : Box < dyn FnMut ( io:: Result < :: Acquired > ) + Send > ,
682
+ mut f : Box < dyn FnMut ( io:: Result < crate :: Acquired > ) + Send > ,
684
683
) -> io:: Result < Helper > {
685
684
static USR1_INIT : Once = Once :: new ( ) ;
686
685
let mut err = None ;
@@ -996,9 +995,9 @@ mod imp {
996
995
}
997
996
998
997
pub ( crate ) fn spawn_helper (
999
- client : :: Client ,
998
+ client : crate :: Client ,
1000
999
state : Arc < super :: HelperState > ,
1001
- mut f : Box < dyn FnMut ( io:: Result < :: Acquired > ) + Send > ,
1000
+ mut f : Box < dyn FnMut ( io:: Result < crate :: Acquired > ) + Send > ,
1002
1001
) -> io:: Result < Helper > {
1003
1002
let event = unsafe {
1004
1003
let r = CreateEventA ( ptr:: null_mut ( ) , TRUE , FALSE , ptr:: null ( ) ) ;
@@ -1016,7 +1015,7 @@ mod imp {
1016
1015
const WAIT_OBJECT_1 : u32 = WAIT_OBJECT_0 + 1 ;
1017
1016
match unsafe { WaitForMultipleObjects ( 2 , objects. as_ptr ( ) , FALSE , INFINITE ) } {
1018
1017
WAIT_OBJECT_0 => return ,
1019
- WAIT_OBJECT_1 => f ( Ok ( :: Acquired {
1018
+ WAIT_OBJECT_1 => f ( Ok ( crate :: Acquired {
1020
1019
client : client. inner . clone ( ) ,
1021
1020
data : Acquired ,
1022
1021
disabled : false ,
@@ -1119,9 +1118,9 @@ mod imp {
1119
1118
}
1120
1119
1121
1120
pub ( crate ) fn spawn_helper (
1122
- client : :: Client ,
1121
+ client : crate :: Client ,
1123
1122
state : Arc < super :: HelperState > ,
1124
- mut f : Box < dyn FnMut ( io:: Result < :: Acquired > ) + Send > ,
1123
+ mut f : Box < dyn FnMut ( io:: Result < crate :: Acquired > ) + Send > ,
1125
1124
) -> io:: Result < Helper > {
1126
1125
let thread = Builder :: new ( ) . spawn ( move || {
1127
1126
state. for_each_request ( || f ( client. acquire ( ) ) ) ;
0 commit comments