Skip to content

Commit e425507

Browse files
committed
Fix clippy lints
Signed-off-by: Alex Saveau <[email protected]>
1 parent 2605aa7 commit e425507

12 files changed

+95
-107
lines changed

src/sys/aio.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ impl AioCb {
163163
0 => Ok(()),
164164
num if num > 0 => Err(Errno::from_i32(num)),
165165
-1 => Err(Errno::last()),
166-
num => panic!("unknown aio_error return value {:?}", num),
166+
num => panic!("unknown aio_error return value {num:?}"),
167167
}
168168
}
169169

src/sys/mman.rs

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ use crate::Result;
88
#[cfg(feature = "fs")]
99
use crate::{fcntl::OFlag, sys::stat::Mode};
1010
use libc::{self, c_int, c_void, off_t, size_t};
11-
use std::{os::unix::io::RawFd, num::NonZeroUsize};
11+
use std::{num::NonZeroUsize, os::unix::io::RawFd};
1212

1313
libc_bitflags! {
1414
/// Desired memory protection of a memory mapping.
@@ -424,12 +424,11 @@ pub unsafe fn mmap(
424424
fd: RawFd,
425425
offset: off_t,
426426
) -> Result<*mut c_void> {
427-
let ptr = addr.map_or(
428-
std::ptr::null_mut(),
429-
|a| usize::from(a) as *mut c_void
430-
);
431-
432-
let ret = libc::mmap(ptr, length.into(), prot.bits(), flags.bits(), fd, offset);
427+
let ptr =
428+
addr.map_or(std::ptr::null_mut(), |a| usize::from(a) as *mut c_void);
429+
430+
let ret =
431+
libc::mmap(ptr, length.into(), prot.bits(), flags.bits(), fd, offset);
433432

434433
if ret == libc::MAP_FAILED {
435434
Err(Errno::last())

src/sys/socket/addr.rs

Lines changed: 37 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -42,19 +42,15 @@ pub(crate) const fn ipv4addr_to_libc(addr: net::Ipv4Addr) -> libc::in_addr {
4242
static_assertions::assert_eq_size!(net::Ipv4Addr, libc::in_addr);
4343
// Safe because both types have the same memory layout, and no fancy Drop
4444
// impls.
45-
unsafe {
46-
mem::transmute(addr)
47-
}
45+
unsafe { mem::transmute(addr) }
4846
}
4947

5048
/// Convert a std::net::Ipv6Addr into the libc form.
5149
#[cfg(feature = "net")]
5250
pub(crate) const fn ipv6addr_to_libc(addr: &net::Ipv6Addr) -> libc::in6_addr {
5351
static_assertions::assert_eq_size!(net::Ipv6Addr, libc::in6_addr);
5452
// Safe because both are Newtype wrappers around the same libc type
55-
unsafe {
56-
mem::transmute(*addr)
57-
}
53+
unsafe { mem::transmute(*addr) }
5854
}
5955

6056
/// These constants specify the protocol family to be used
@@ -79,7 +75,11 @@ pub enum AddressFamily {
7975
#[cfg_attr(docsrs, doc(cfg(all())))]
8076
Netlink = libc::AF_NETLINK,
8177
/// Kernel interface for interacting with the routing table
82-
#[cfg(not(any(target_os = "redox", target_os = "linux", target_os = "android")))]
78+
#[cfg(not(any(
79+
target_os = "redox",
80+
target_os = "linux",
81+
target_os = "android"
82+
)))]
8383
Route = libc::PF_ROUTE,
8484
/// Low level packet interface (see [`packet(7)`](https://man7.org/linux/man-pages/man7/packet.7.html))
8585
#[cfg(any(
@@ -422,7 +422,11 @@ impl AddressFamily {
422422
libc::AF_NETLINK => Some(AddressFamily::Netlink),
423423
#[cfg(any(target_os = "macos", target_os = "macos"))]
424424
libc::AF_SYSTEM => Some(AddressFamily::System),
425-
#[cfg(not(any(target_os = "redox", target_os = "linux", target_os = "android")))]
425+
#[cfg(not(any(
426+
target_os = "redox",
427+
target_os = "linux",
428+
target_os = "android"
429+
)))]
426430
libc::PF_ROUTE => Some(AddressFamily::Route),
427431
#[cfg(any(target_os = "android", target_os = "linux"))]
428432
libc::AF_PACKET => Some(AddressFamily::Packet),
@@ -592,10 +596,11 @@ impl UnixAddr {
592596
pub fn new_unnamed() -> UnixAddr {
593597
let ret = libc::sockaddr_un {
594598
sun_family: AddressFamily::Unix as sa_family_t,
595-
.. unsafe { mem::zeroed() }
599+
..unsafe { mem::zeroed() }
596600
};
597601

598-
let sun_len: u8 = offset_of!(libc::sockaddr_un, sun_path).try_into().unwrap();
602+
let sun_len: u8 =
603+
offset_of!(libc::sockaddr_un, sun_path).try_into().unwrap();
599604

600605
unsafe { UnixAddr::from_raw_parts(ret, sun_len) }
601606
}
@@ -1268,7 +1273,9 @@ impl SockaddrLike for SockaddrStorage {
12681273
if i32::from(ss.ss_family) == libc::AF_UNIX {
12691274
// Safe because we UnixAddr is strictly smaller than
12701275
// SockaddrStorage, and we just initialized the structure.
1271-
(*(&mut ss as *mut libc::sockaddr_storage as *mut UnixAddr)).sun_len = len as u8;
1276+
(*(&mut ss as *mut libc::sockaddr_storage
1277+
as *mut UnixAddr))
1278+
.sun_len = len as u8;
12721279
}
12731280
Some(Self { ss })
12741281
}
@@ -1343,7 +1350,7 @@ impl SockaddrLike for SockaddrStorage {
13431350
// The UnixAddr type knows its own length
13441351
Some(ua) => ua.len(),
13451352
// For all else, we're just a boring SockaddrStorage
1346-
None => mem::size_of_val(self) as libc::socklen_t
1353+
None => mem::size_of_val(self) as libc::socklen_t,
13471354
}
13481355
}
13491356
}
@@ -1403,12 +1410,13 @@ impl SockaddrStorage {
14031410
}
14041411
}
14051412
// Sanity checks
1406-
if self.family() != Some(AddressFamily::Unix) ||
1407-
len < offset_of!(libc::sockaddr_un, sun_path) ||
1408-
len > mem::size_of::<libc::sockaddr_un>() {
1413+
if self.family() != Some(AddressFamily::Unix)
1414+
|| len < offset_of!(libc::sockaddr_un, sun_path)
1415+
|| len > mem::size_of::<libc::sockaddr_un>()
1416+
{
14091417
None
14101418
} else {
1411-
Some(unsafe{&self.su})
1419+
Some(unsafe { &self.su })
14121420
}
14131421
}
14141422

@@ -1432,12 +1440,13 @@ impl SockaddrStorage {
14321440
}
14331441
}
14341442
// Sanity checks
1435-
if self.family() != Some(AddressFamily::Unix) ||
1436-
len < offset_of!(libc::sockaddr_un, sun_path) ||
1437-
len > mem::size_of::<libc::sockaddr_un>() {
1443+
if self.family() != Some(AddressFamily::Unix)
1444+
|| len < offset_of!(libc::sockaddr_un, sun_path)
1445+
|| len > mem::size_of::<libc::sockaddr_un>()
1446+
{
14381447
None
14391448
} else {
1440-
Some(unsafe{&mut self.su})
1449+
Some(unsafe { &mut self.su })
14411450
}
14421451
}
14431452

@@ -2486,7 +2495,7 @@ mod tests {
24862495
fn display() {
24872496
let s = "127.0.0.1:8080";
24882497
let addr = SockaddrIn::from_str(s).unwrap();
2489-
assert_eq!(s, format!("{}", addr));
2498+
assert_eq!(s, format!("{addr}"));
24902499
}
24912500

24922501
#[test]
@@ -2506,7 +2515,7 @@ mod tests {
25062515
fn display() {
25072516
let s = "[1234:5678:90ab:cdef::1111:2222]:8080";
25082517
let addr = SockaddrIn6::from_str(s).unwrap();
2509-
assert_eq!(s, format!("{}", addr));
2518+
assert_eq!(s, format!("{addr}"));
25102519
}
25112520

25122521
#[test]
@@ -2525,9 +2534,8 @@ mod tests {
25252534
fn from_sockaddr_un_named() {
25262535
let ua = UnixAddr::new("/var/run/mysock").unwrap();
25272536
let ptr = ua.as_ptr() as *const libc::sockaddr;
2528-
let ss = unsafe {
2529-
SockaddrStorage::from_raw(ptr, Some(ua.len()))
2530-
}.unwrap();
2537+
let ss = unsafe { SockaddrStorage::from_raw(ptr, Some(ua.len())) }
2538+
.unwrap();
25312539
assert_eq!(ss.len(), ua.len());
25322540
}
25332541

@@ -2537,9 +2545,8 @@ mod tests {
25372545
let name = String::from("nix\0abstract\0test");
25382546
let ua = UnixAddr::new_abstract(name.as_bytes()).unwrap();
25392547
let ptr = ua.as_ptr() as *const libc::sockaddr;
2540-
let ss = unsafe {
2541-
SockaddrStorage::from_raw(ptr, Some(ua.len()))
2542-
}.unwrap();
2548+
let ss = unsafe { SockaddrStorage::from_raw(ptr, Some(ua.len())) }
2549+
.unwrap();
25432550
assert_eq!(ss.len(), ua.len());
25442551
}
25452552

@@ -2548,9 +2555,8 @@ mod tests {
25482555
fn from_sockaddr_un_abstract_unnamed() {
25492556
let ua = UnixAddr::new_unnamed();
25502557
let ptr = ua.as_ptr() as *const libc::sockaddr;
2551-
let ss = unsafe {
2552-
SockaddrStorage::from_raw(ptr, Some(ua.len()))
2553-
}.unwrap();
2558+
let ss = unsafe { SockaddrStorage::from_raw(ptr, Some(ua.len())) }
2559+
.unwrap();
25542560
assert_eq!(ss.len(), ua.len());
25552561
}
25562562
}

src/sys/socket/mod.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ use libc::{
1212
self, c_int, c_void, iovec, size_t, socklen_t, CMSG_DATA, CMSG_FIRSTHDR,
1313
CMSG_LEN, CMSG_NXTHDR,
1414
};
15-
use std::convert::TryFrom;
1615
use std::io::{IoSlice, IoSliceMut};
1716
#[cfg(feature = "net")]
1817
use std::net;

src/sys/socket/sockopt.rs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,7 @@ use crate::Result;
66
use cfg_if::cfg_if;
77
use libc::{self, c_int, c_void, socklen_t};
88
use std::ffi::{OsStr, OsString};
9-
use std::{
10-
convert::TryFrom,
11-
mem::{self, MaybeUninit}
12-
};
9+
use std::mem::{self, MaybeUninit};
1310
#[cfg(target_family = "unix")]
1411
use std::os::unix::ffi::OsStrExt;
1512
use std::os::unix::io::RawFd;
@@ -107,7 +104,7 @@ macro_rules! getsockopt_impl {
107104

108105
match <$ty>::try_from(getter.assume_init()) {
109106
Err(_) => Err(Errno::EINVAL),
110-
Ok(r) => Ok(r)
107+
Ok(r) => Ok(r),
111108
}
112109
}
113110
}

src/sys/time.rs

Lines changed: 15 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -261,8 +261,7 @@ impl TimeValLike for TimeSpec {
261261
fn seconds(seconds: i64) -> TimeSpec {
262262
assert!(
263263
(TS_MIN_SECONDS..=TS_MAX_SECONDS).contains(&seconds),
264-
"TimeSpec out of bounds; seconds={}",
265-
seconds
264+
"TimeSpec out of bounds; seconds={seconds}",
266265
);
267266
let mut ts = zero_init_timespec();
268267
ts.tv_sec = seconds as time_t;
@@ -428,20 +427,20 @@ impl fmt::Display for TimeSpec {
428427

429428
let sec = abs.tv_sec();
430429

431-
write!(f, "{}", sign)?;
430+
write!(f, "{sign}")?;
432431

433432
if abs.tv_nsec() == 0 {
434-
if abs.tv_sec() == 1 {
435-
write!(f, "{} second", sec)?;
433+
if sec == 1 {
434+
write!(f, "1 second")?;
436435
} else {
437-
write!(f, "{} seconds", sec)?;
436+
write!(f, "{sec} seconds")?;
438437
}
439438
} else if abs.tv_nsec() % 1_000_000 == 0 {
440-
write!(f, "{}.{:03} seconds", sec, abs.tv_nsec() / 1_000_000)?;
439+
write!(f, "{sec}.{:03} seconds", abs.tv_nsec() / 1_000_000)?;
441440
} else if abs.tv_nsec() % 1_000 == 0 {
442-
write!(f, "{}.{:06} seconds", sec, abs.tv_nsec() / 1_000)?;
441+
write!(f, "{sec}.{:06} seconds", abs.tv_nsec() / 1_000)?;
443442
} else {
444-
write!(f, "{}.{:09} seconds", sec, abs.tv_nsec())?;
443+
write!(f, "{sec}.{:09} seconds", abs.tv_nsec())?;
445444
}
446445

447446
Ok(())
@@ -497,8 +496,7 @@ impl TimeValLike for TimeVal {
497496
fn seconds(seconds: i64) -> TimeVal {
498497
assert!(
499498
(TV_MIN_SECONDS..=TV_MAX_SECONDS).contains(&seconds),
500-
"TimeVal out of bounds; seconds={}",
501-
seconds
499+
"TimeVal out of bounds; seconds={seconds}"
502500
);
503501
#[cfg_attr(target_env = "musl", allow(deprecated))]
504502
// https://github.com/rust-lang/libc/issues/1848
@@ -662,18 +660,18 @@ impl fmt::Display for TimeVal {
662660

663661
let sec = abs.tv_sec();
664662

665-
write!(f, "{}", sign)?;
663+
write!(f, "{sign}")?;
666664

667665
if abs.tv_usec() == 0 {
668-
if abs.tv_sec() == 1 {
669-
write!(f, "{} second", sec)?;
666+
if sec == 1 {
667+
write!(f, "1 second")?;
670668
} else {
671-
write!(f, "{} seconds", sec)?;
669+
write!(f, "{sec} seconds")?;
672670
}
673671
} else if abs.tv_usec() % 1000 == 0 {
674-
write!(f, "{}.{:03} seconds", sec, abs.tv_usec() / 1000)?;
672+
write!(f, "{sec}.{:03} seconds", abs.tv_usec() / 1000)?;
675673
} else {
676-
write!(f, "{}.{:06} seconds", sec, abs.tv_usec())?;
674+
write!(f, "{sec}.{:06} seconds", abs.tv_usec())?;
677675
}
678676

679677
Ok(())

test/sys/test_aio.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -610,7 +610,7 @@ fn test_aio_suspend() {
610610
let r = aio_suspend(&cbbuf[..], Some(timeout));
611611
match r {
612612
Err(Errno::EINTR) => continue,
613-
Err(e) => panic!("aio_suspend returned {:?}", e),
613+
Err(e) => panic!("aio_suspend returned {e:?}"),
614614
Ok(_) => (),
615615
};
616616
}

test/sys/test_signal.rs

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -54,9 +54,8 @@ fn test_sigprocmask() {
5454
// test don't make sense.
5555
assert!(
5656
!old_signal_set.contains(SIGNAL),
57-
"the {:?} signal is already blocked, please change to a \
58-
different one",
59-
SIGNAL
57+
"the {SIGNAL:?} signal is already blocked, please change to a \
58+
different one"
6059
);
6160

6261
// Now block the signal.
@@ -71,8 +70,7 @@ fn test_sigprocmask() {
7170
.expect("expect to be able to retrieve old signals");
7271
assert!(
7372
old_signal_set.contains(SIGNAL),
74-
"expected the {:?} to be blocked",
75-
SIGNAL
73+
"expected the {SIGNAL:?} to be blocked"
7674
);
7775

7876
// Reset the signal.

test/sys/test_socket.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -626,7 +626,7 @@ mod recvfrom {
626626
println!("IPv6 not available, skipping test.");
627627
return;
628628
}
629-
Err(e) => panic!("bind: {}", e),
629+
Err(e) => panic!("bind: {e}"),
630630
Ok(()) => (),
631631
}
632632
let ssock = socket(
@@ -1272,7 +1272,7 @@ fn test_scm_credentials() {
12721272
ControlMessageOwned::ScmCredentials(cred) => cred,
12731273
#[cfg(any(target_os = "freebsd", target_os = "dragonfly"))]
12741274
ControlMessageOwned::ScmCreds(cred) => cred,
1275-
other => panic!("unexpected cmsg {:?}", other),
1275+
other => panic!("unexpected cmsg {other:?}"),
12761276
};
12771277
assert!(received_cred.is_none());
12781278
assert_eq!(cred.pid(), getpid().as_raw());
@@ -1550,7 +1550,7 @@ fn loopback_address(
15501550
Err(e) => {
15511551
let stdioerr = io::stderr();
15521552
let mut handle = stdioerr.lock();
1553-
writeln!(handle, "getifaddrs: {:?}", e).unwrap();
1553+
writeln!(handle, "getifaddrs: {e:?}").unwrap();
15541554
return None;
15551555
}
15561556
};
@@ -2347,7 +2347,7 @@ mod linux_errqueue {
23472347
}
23482348
*ext_err
23492349
} else {
2350-
panic!("Unexpected control message {:?}", cmsg);
2350+
panic!("Unexpected control message {cmsg:?}");
23512351
}
23522352
},
23532353
)
@@ -2398,7 +2398,7 @@ mod linux_errqueue {
23982398
}
23992399
*ext_err
24002400
} else {
2401-
panic!("Unexpected control message {:?}", cmsg);
2401+
panic!("Unexpected control message {cmsg:?}");
24022402
}
24032403
},
24042404
)
@@ -2432,7 +2432,7 @@ mod linux_errqueue {
24322432
MsgFlags::empty(),
24332433
) {
24342434
assert_eq!(e, Errno::EADDRNOTAVAIL);
2435-
println!("{:?} not available, skipping test.", af);
2435+
println!("{af:?} not available, skipping test.");
24362436
return;
24372437
}
24382438

0 commit comments

Comments
 (0)