@@ -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 } ;
@@ -691,14 +687,14 @@ impl<T: AsRawFd> AsRawFd for Async<T> {
691
687
}
692
688
}
693
689
694
- #[ cfg( all ( not ( async_io_no_io_safety ) , unix) ) ]
690
+ #[ cfg( unix) ]
695
691
impl < T : AsFd > AsFd for Async < T > {
696
692
fn as_fd ( & self ) -> BorrowedFd < ' _ > {
697
693
self . get_ref ( ) . as_fd ( )
698
694
}
699
695
}
700
696
701
- #[ cfg( all ( not ( async_io_no_io_safety ) , unix) ) ]
697
+ #[ cfg( unix) ]
702
698
impl < T : AsRawFd + From < OwnedFd > > TryFrom < OwnedFd > for Async < T > {
703
699
type Error = io:: Error ;
704
700
@@ -707,7 +703,7 @@ impl<T: AsRawFd + From<OwnedFd>> TryFrom<OwnedFd> for Async<T> {
707
703
}
708
704
}
709
705
710
- #[ cfg( all ( not ( async_io_no_io_safety ) , unix) ) ]
706
+ #[ cfg( unix) ]
711
707
impl < T : Into < OwnedFd > > TryFrom < Async < T > > for OwnedFd {
712
708
type Error = io:: Error ;
713
709
@@ -767,14 +763,14 @@ impl<T: AsRawSocket> AsRawSocket for Async<T> {
767
763
}
768
764
}
769
765
770
- #[ cfg( all ( not ( async_io_no_io_safety ) , windows) ) ]
766
+ #[ cfg( windows) ]
771
767
impl < T : AsSocket > AsSocket for Async < T > {
772
768
fn as_socket ( & self ) -> BorrowedSocket < ' _ > {
773
769
self . get_ref ( ) . as_socket ( )
774
770
}
775
771
}
776
772
777
- #[ cfg( all ( not ( async_io_no_io_safety ) , windows) ) ]
773
+ #[ cfg( windows) ]
778
774
impl < T : AsRawSocket + From < OwnedSocket > > TryFrom < OwnedSocket > for Async < T > {
779
775
type Error = io:: Error ;
780
776
@@ -783,7 +779,7 @@ impl<T: AsRawSocket + From<OwnedSocket>> TryFrom<OwnedSocket> for Async<T> {
783
779
}
784
780
}
785
781
786
- #[ cfg( all ( not ( async_io_no_io_safety ) , windows) ) ]
782
+ #[ cfg( windows) ]
787
783
impl < T : Into < OwnedSocket > > TryFrom < Async < T > > for OwnedSocket {
788
784
type Error = io:: Error ;
789
785
0 commit comments