@@ -121,7 +121,7 @@ impl_debug!(
121
121
impl Type {
122
122
/// Our custom flag to set `WSA_FLAG_NO_HANDLE_INHERIT` on socket creation.
123
123
/// Trying to mimic `Type::cloexec` on windows.
124
- const NO_INHERIT : c_int = 1 << ( ( size_of :: < c_int > ( ) * 8 ) - 1 ) ; // Last bit.
124
+ const NO_INHERIT : c_int = 1 << ( c_int :: BITS as usize - 1 ) ; // Last bit.
125
125
126
126
/// Set `WSA_FLAG_NO_HANDLE_INHERIT` on the socket.
127
127
#[ cfg( feature = "all" ) ]
@@ -166,9 +166,9 @@ pub struct MaybeUninitSlice<'a> {
166
166
_lifetime : PhantomData < & ' a mut [ MaybeUninit < u8 > ] > ,
167
167
}
168
168
169
- unsafe impl < ' a > Send for MaybeUninitSlice < ' a > { }
169
+ unsafe impl Send for MaybeUninitSlice < ' _ > { }
170
170
171
- unsafe impl < ' a > Sync for MaybeUninitSlice < ' a > { }
171
+ unsafe impl Sync for MaybeUninitSlice < ' _ > { }
172
172
173
173
impl < ' a > MaybeUninitSlice < ' a > {
174
174
pub fn new ( buf : & ' a mut [ MaybeUninit < u8 > ] ) -> MaybeUninitSlice < ' a > {
@@ -251,7 +251,7 @@ pub(crate) fn socket(family: c_int, mut ty: c_int, protocol: c_int) -> io::Resul
251
251
252
252
// Check if we set our custom flag.
253
253
let flags = if ty & Type :: NO_INHERIT != 0 {
254
- ty = ty & !Type :: NO_INHERIT ;
254
+ ty &= !Type :: NO_INHERIT ;
255
255
WSA_FLAG_NO_HANDLE_INHERIT
256
256
} else {
257
257
0
@@ -284,7 +284,7 @@ pub(crate) fn poll_connect(socket: &crate::Socket, timeout: Duration) -> io::Res
284
284
285
285
let mut fd_array = WSAPOLLFD {
286
286
fd : socket. as_raw ( ) ,
287
- events : ( POLLRDNORM | POLLWRNORM ) as i16 ,
287
+ events : ( POLLRDNORM | POLLWRNORM ) ,
288
288
revents : 0 ,
289
289
} ;
290
290
@@ -305,8 +305,8 @@ pub(crate) fn poll_connect(socket: &crate::Socket, timeout: Duration) -> io::Res
305
305
Ok ( 0 ) => return Err ( io:: ErrorKind :: TimedOut . into ( ) ) ,
306
306
Ok ( _) => {
307
307
// Error or hang up indicates an error (or failure to connect).
308
- if ( fd_array. revents & POLLERR as i16 ) != 0
309
- || ( fd_array. revents & POLLHUP as i16 ) != 0
308
+ if ( fd_array. revents & POLLERR ) != 0
309
+ || ( fd_array. revents & POLLHUP ) != 0
310
310
{
311
311
match socket. take_error ( ) {
312
312
Ok ( Some ( err) ) => return Err ( err) ,
@@ -422,7 +422,7 @@ pub(crate) fn shutdown(socket: Socket, how: Shutdown) -> io::Result<()> {
422
422
Shutdown :: Write => SD_SEND ,
423
423
Shutdown :: Read => SD_RECEIVE ,
424
424
Shutdown :: Both => SD_BOTH ,
425
- } as i32 ;
425
+ } ;
426
426
syscall ! ( shutdown( socket, how) , PartialEq :: eq, SOCKET_ERROR ) . map ( |_| ( ) )
427
427
}
428
428
@@ -439,7 +439,7 @@ pub(crate) fn recv(socket: Socket, buf: &mut [MaybeUninit<u8>], flags: c_int) ->
439
439
) ;
440
440
match res {
441
441
Ok ( n) => Ok ( n as usize ) ,
442
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN as i32 ) => Ok ( 0 ) ,
442
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => Ok ( 0 ) ,
443
443
Err ( err) => Err ( err) ,
444
444
}
445
445
}
@@ -466,8 +466,8 @@ pub(crate) fn recv_vectored(
466
466
) ;
467
467
match res {
468
468
Ok ( _) => Ok ( ( nread as usize , RecvFlags ( 0 ) ) ) ,
469
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN as i32 ) => Ok ( ( 0 , RecvFlags ( 0 ) ) ) ,
470
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAEMSGSIZE as i32 ) => {
469
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => Ok ( ( 0 , RecvFlags ( 0 ) ) ) ,
470
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAEMSGSIZE ) => {
471
471
Ok ( ( nread as usize , RecvFlags ( MSG_TRUNC ) ) )
472
472
}
473
473
Err ( err) => Err ( err) ,
@@ -496,7 +496,7 @@ pub(crate) fn recv_from(
496
496
) ;
497
497
match res {
498
498
Ok ( n) => Ok ( n as usize ) ,
499
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN as i32 ) => Ok ( 0 ) ,
499
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => Ok ( 0 ) ,
500
500
Err ( err) => Err ( err) ,
501
501
}
502
502
} )
@@ -523,7 +523,7 @@ pub(crate) fn peek_sender(socket: Socket) -> io::Result<SockAddr> {
523
523
match res {
524
524
Ok ( _n) => Ok ( ( ) ) ,
525
525
Err ( e) => match e. raw_os_error ( ) {
526
- Some ( code) if code == ( WSAESHUTDOWN as i32 ) || code == ( WSAEMSGSIZE as i32 ) => {
526
+ Some ( code) if code == WSAESHUTDOWN || code == WSAEMSGSIZE => {
527
527
Ok ( ( ) )
528
528
}
529
529
_ => Err ( e) ,
@@ -562,10 +562,10 @@ pub(crate) fn recv_from_vectored(
562
562
) ;
563
563
match res {
564
564
Ok ( _) => Ok ( ( nread as usize , RecvFlags ( 0 ) ) ) ,
565
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN as i32 ) => {
565
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => {
566
566
Ok ( ( nread as usize , RecvFlags ( 0 ) ) )
567
567
}
568
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAEMSGSIZE as i32 ) => {
568
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAEMSGSIZE ) => {
569
569
Ok ( ( nread as usize , RecvFlags ( MSG_TRUNC ) ) )
570
570
}
571
571
Err ( err) => Err ( err) ,
@@ -699,7 +699,7 @@ fn from_ms(duration: u32) -> Option<Duration> {
699
699
} else {
700
700
let secs = duration / 1000 ;
701
701
let nsec = ( duration % 1000 ) * 1000000 ;
702
- Some ( Duration :: new ( secs as u64 , nsec as u32 ) )
702
+ Some ( Duration :: new ( secs as u64 , nsec) )
703
703
}
704
704
}
705
705
@@ -760,7 +760,7 @@ pub(crate) unsafe fn getsockopt<T>(socket: Socket, level: c_int, optname: i32) -
760
760
syscall ! (
761
761
getsockopt(
762
762
socket,
763
- level as i32 ,
763
+ level,
764
764
optname,
765
765
optval. as_mut_ptr( ) . cast( ) ,
766
766
& mut optlen,
@@ -786,7 +786,7 @@ pub(crate) unsafe fn setsockopt<T>(
786
786
syscall ! (
787
787
setsockopt(
788
788
socket,
789
- level as i32 ,
789
+ level,
790
790
optname,
791
791
( & optval as * const T ) . cast( ) ,
792
792
mem:: size_of:: <T >( ) as c_int,
@@ -1034,14 +1034,14 @@ impl FromRawSocket for crate::Socket {
1034
1034
fn in_addr_convertion ( ) {
1035
1035
let ip = Ipv4Addr :: new ( 127 , 0 , 0 , 1 ) ;
1036
1036
let raw = to_in_addr ( & ip) ;
1037
- assert_eq ! ( unsafe { raw. S_un . S_addr } , 127 << 0 | 1 << 24 ) ;
1037
+ assert_eq ! ( unsafe { raw. S_un . S_addr } , 127 | 1 << 24 ) ;
1038
1038
assert_eq ! ( from_in_addr( raw) , ip) ;
1039
1039
1040
1040
let ip = Ipv4Addr :: new ( 127 , 34 , 4 , 12 ) ;
1041
1041
let raw = to_in_addr ( & ip) ;
1042
1042
assert_eq ! (
1043
1043
unsafe { raw. S_un . S_addr } ,
1044
- 127 << 0 | 34 << 8 | 4 << 16 | 12 << 24
1044
+ 127 | 34 << 8 | 4 << 16 | 12 << 24
1045
1045
) ;
1046
1046
assert_eq ! ( from_in_addr( raw) , ip) ;
1047
1047
}
0 commit comments