@@ -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,9 +305,7 @@ 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
310
- {
308
+ if ( fd_array. revents & POLLERR ) != 0 || ( fd_array. revents & POLLHUP ) != 0 {
311
309
match socket. take_error ( ) {
312
310
Ok ( Some ( err) ) => return Err ( err) ,
313
311
Ok ( None ) => {
@@ -422,7 +420,7 @@ pub(crate) fn shutdown(socket: Socket, how: Shutdown) -> io::Result<()> {
422
420
Shutdown :: Write => SD_SEND ,
423
421
Shutdown :: Read => SD_RECEIVE ,
424
422
Shutdown :: Both => SD_BOTH ,
425
- } as i32 ;
423
+ } ;
426
424
syscall ! ( shutdown( socket, how) , PartialEq :: eq, SOCKET_ERROR ) . map ( |_| ( ) )
427
425
}
428
426
@@ -439,7 +437,7 @@ pub(crate) fn recv(socket: Socket, buf: &mut [MaybeUninit<u8>], flags: c_int) ->
439
437
) ;
440
438
match res {
441
439
Ok ( n) => Ok ( n as usize ) ,
442
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN as i32 ) => Ok ( 0 ) ,
440
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => Ok ( 0 ) ,
443
441
Err ( err) => Err ( err) ,
444
442
}
445
443
}
@@ -466,8 +464,8 @@ pub(crate) fn recv_vectored(
466
464
) ;
467
465
match res {
468
466
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 ) => {
467
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => Ok ( ( 0 , RecvFlags ( 0 ) ) ) ,
468
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAEMSGSIZE ) => {
471
469
Ok ( ( nread as usize , RecvFlags ( MSG_TRUNC ) ) )
472
470
}
473
471
Err ( err) => Err ( err) ,
@@ -496,7 +494,7 @@ pub(crate) fn recv_from(
496
494
) ;
497
495
match res {
498
496
Ok ( n) => Ok ( n as usize ) ,
499
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN as i32 ) => Ok ( 0 ) ,
497
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => Ok ( 0 ) ,
500
498
Err ( err) => Err ( err) ,
501
499
}
502
500
} )
@@ -523,9 +521,7 @@ pub(crate) fn peek_sender(socket: Socket) -> io::Result<SockAddr> {
523
521
match res {
524
522
Ok ( _n) => Ok ( ( ) ) ,
525
523
Err ( e) => match e. raw_os_error ( ) {
526
- Some ( code) if code == ( WSAESHUTDOWN as i32 ) || code == ( WSAEMSGSIZE as i32 ) => {
527
- Ok ( ( ) )
528
- }
524
+ Some ( code) if code == WSAESHUTDOWN || code == WSAEMSGSIZE => Ok ( ( ) ) ,
529
525
_ => Err ( e) ,
530
526
} ,
531
527
}
@@ -562,10 +558,10 @@ pub(crate) fn recv_from_vectored(
562
558
) ;
563
559
match res {
564
560
Ok ( _) => Ok ( ( nread as usize , RecvFlags ( 0 ) ) ) ,
565
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN as i32 ) => {
561
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAESHUTDOWN ) => {
566
562
Ok ( ( nread as usize , RecvFlags ( 0 ) ) )
567
563
}
568
- Err ( ref err) if err. raw_os_error ( ) == Some ( WSAEMSGSIZE as i32 ) => {
564
+ Err ( ref err) if err. raw_os_error ( ) == Some ( WSAEMSGSIZE ) => {
569
565
Ok ( ( nread as usize , RecvFlags ( MSG_TRUNC ) ) )
570
566
}
571
567
Err ( err) => Err ( err) ,
@@ -699,7 +695,7 @@ fn from_ms(duration: u32) -> Option<Duration> {
699
695
} else {
700
696
let secs = duration / 1000 ;
701
697
let nsec = ( duration % 1000 ) * 1000000 ;
702
- Some ( Duration :: new ( secs as u64 , nsec as u32 ) )
698
+ Some ( Duration :: new ( secs as u64 , nsec) )
703
699
}
704
700
}
705
701
@@ -760,7 +756,7 @@ pub(crate) unsafe fn getsockopt<T>(socket: Socket, level: c_int, optname: i32) -
760
756
syscall ! (
761
757
getsockopt(
762
758
socket,
763
- level as i32 ,
759
+ level,
764
760
optname,
765
761
optval. as_mut_ptr( ) . cast( ) ,
766
762
& mut optlen,
@@ -786,7 +782,7 @@ pub(crate) unsafe fn setsockopt<T>(
786
782
syscall ! (
787
783
setsockopt(
788
784
socket,
789
- level as i32 ,
785
+ level,
790
786
optname,
791
787
( & optval as * const T ) . cast( ) ,
792
788
mem:: size_of:: <T >( ) as c_int,
@@ -1034,14 +1030,14 @@ impl FromRawSocket for crate::Socket {
1034
1030
fn in_addr_convertion ( ) {
1035
1031
let ip = Ipv4Addr :: new ( 127 , 0 , 0 , 1 ) ;
1036
1032
let raw = to_in_addr ( & ip) ;
1037
- assert_eq ! ( unsafe { raw. S_un . S_addr } , 127 << 0 | 1 << 24 ) ;
1033
+ assert_eq ! ( unsafe { raw. S_un . S_addr } , 127 | 1 << 24 ) ;
1038
1034
assert_eq ! ( from_in_addr( raw) , ip) ;
1039
1035
1040
1036
let ip = Ipv4Addr :: new ( 127 , 34 , 4 , 12 ) ;
1041
1037
let raw = to_in_addr ( & ip) ;
1042
1038
assert_eq ! (
1043
1039
unsafe { raw. S_un . S_addr } ,
1044
- 127 << 0 | 34 << 8 | 4 << 16 | 12 << 24
1040
+ 127 | 34 << 8 | 4 << 16 | 12 << 24
1045
1041
) ;
1046
1042
assert_eq ! ( from_in_addr( raw) , ip) ;
1047
1043
}
0 commit comments