@@ -64,19 +64,15 @@ use std::sync::Arc;
64
64
use std:: task:: { Context , Poll , Waker } ;
65
65
use std:: time:: { Duration , Instant } ;
66
66
67
- #[ cfg( all( not( async_io_no_io_safety) , unix) ) ]
68
- use std:: os:: unix:: io:: { AsFd , BorrowedFd , OwnedFd } ;
69
67
#[ cfg( unix) ]
70
68
use std:: {
71
- os:: unix:: io:: { AsRawFd , RawFd } ,
69
+ os:: unix:: io:: { AsFd , AsRawFd , BorrowedFd , OwnedFd , RawFd } ,
72
70
os:: unix:: net:: { SocketAddr as UnixSocketAddr , UnixDatagram , UnixListener , UnixStream } ,
73
71
path:: Path ,
74
72
} ;
75
73
76
74
#[ cfg( windows) ]
77
- use std:: os:: windows:: io:: { AsRawSocket , RawSocket } ;
78
- #[ cfg( all( not( async_io_no_io_safety) , windows) ) ]
79
- use std:: os:: windows:: io:: { AsSocket , BorrowedSocket , OwnedSocket } ;
75
+ use std:: os:: windows:: io:: { AsRawSocket , AsSocket , BorrowedSocket , OwnedSocket , RawSocket } ;
80
76
81
77
use futures_io:: { AsyncRead , AsyncWrite } ;
82
78
use futures_lite:: stream:: { self , Stream } ;
@@ -685,14 +681,14 @@ impl<T: AsRawFd> AsRawFd for Async<T> {
685
681
}
686
682
}
687
683
688
- #[ cfg( all ( not ( async_io_no_io_safety ) , unix) ) ]
684
+ #[ cfg( unix) ]
689
685
impl < T : AsFd > AsFd for Async < T > {
690
686
fn as_fd ( & self ) -> BorrowedFd < ' _ > {
691
687
self . get_ref ( ) . as_fd ( )
692
688
}
693
689
}
694
690
695
- #[ cfg( all ( not ( async_io_no_io_safety ) , unix) ) ]
691
+ #[ cfg( unix) ]
696
692
impl < T : AsRawFd + From < OwnedFd > > TryFrom < OwnedFd > for Async < T > {
697
693
type Error = io:: Error ;
698
694
@@ -701,7 +697,7 @@ impl<T: AsRawFd + From<OwnedFd>> TryFrom<OwnedFd> for Async<T> {
701
697
}
702
698
}
703
699
704
- #[ cfg( all ( not ( async_io_no_io_safety ) , unix) ) ]
700
+ #[ cfg( unix) ]
705
701
impl < T : Into < OwnedFd > > TryFrom < Async < T > > for OwnedFd {
706
702
type Error = io:: Error ;
707
703
@@ -761,14 +757,14 @@ impl<T: AsRawSocket> AsRawSocket for Async<T> {
761
757
}
762
758
}
763
759
764
- #[ cfg( all ( not ( async_io_no_io_safety ) , windows) ) ]
760
+ #[ cfg( windows) ]
765
761
impl < T : AsSocket > AsSocket for Async < T > {
766
762
fn as_socket ( & self ) -> BorrowedSocket < ' _ > {
767
763
self . get_ref ( ) . as_socket ( )
768
764
}
769
765
}
770
766
771
- #[ cfg( all ( not ( async_io_no_io_safety ) , windows) ) ]
767
+ #[ cfg( windows) ]
772
768
impl < T : AsRawSocket + From < OwnedSocket > > TryFrom < OwnedSocket > for Async < T > {
773
769
type Error = io:: Error ;
774
770
@@ -777,7 +773,7 @@ impl<T: AsRawSocket + From<OwnedSocket>> TryFrom<OwnedSocket> for Async<T> {
777
773
}
778
774
}
779
775
780
- #[ cfg( all ( not ( async_io_no_io_safety ) , windows) ) ]
776
+ #[ cfg( windows) ]
781
777
impl < T : Into < OwnedSocket > > TryFrom < Async < T > > for OwnedSocket {
782
778
type Error = io:: Error ;
783
779
0 commit comments