Skip to content

Commit 13cc7f8

Browse files
committed
Clippy fixes.
1 parent 9d86fb9 commit 13cc7f8

File tree

9 files changed

+20
-28
lines changed

9 files changed

+20
-28
lines changed

examples/utils.rs

+1-5
Original file line numberDiff line numberDiff line change
@@ -84,11 +84,7 @@ pub fn parse_options(options: &Options, free: Vec<&str>) -> Matches {
8484
free.join(" ")
8585
);
8686
print!("{}", options.usage(&brief));
87-
process::exit(if matches.free.len() != free.len() {
88-
1
89-
} else {
90-
0
91-
})
87+
process::exit((matches.free.len() != free.len()) as _);
9288
}
9389
matches
9490
}

src/iface/fragmentation.rs

+4-7
Original file line numberDiff line numberDiff line change
@@ -364,7 +364,7 @@ impl<'a, K: Eq + Ord + Clone + Copy> PacketAssemblerSet<'a, K> {
364364
/// - Returns [`Error::PacketAssemblerSetKeyNotFound`] when the key was not found in the set.
365365
pub(crate) fn get_packet_assembler_mut(&mut self, key: &K) -> Result<&mut PacketAssembler<'a>> {
366366
if let Some(i) = self.index_buffer.get(key) {
367-
Ok(&mut self.packet_buffer[*i as usize])
367+
Ok(&mut self.packet_buffer[*i])
368368
} else {
369369
Err(Error::PacketAssemblerSetKeyNotFound)
370370
}
@@ -379,7 +379,7 @@ impl<'a, K: Eq + Ord + Clone + Copy> PacketAssemblerSet<'a, K> {
379379
/// - Returns [`Error::PacketAssemblerIncomplete`] when the fragments assembler was empty or not fully assembled.
380380
pub(crate) fn get_assembled_packet(&mut self, key: &K) -> Result<&[u8]> {
381381
if let Some(i) = self.index_buffer.get(key) {
382-
let p = self.packet_buffer[*i as usize].assemble()?;
382+
let p = self.packet_buffer[*i].assemble()?;
383383
self.index_buffer.remove(key);
384384
Ok(p)
385385
} else {
@@ -392,10 +392,7 @@ impl<'a, K: Eq + Ord + Clone + Copy> PacketAssemblerSet<'a, K> {
392392
loop {
393393
let mut key = None;
394394
for (k, i) in self.index_buffer.iter() {
395-
if matches!(
396-
self.packet_buffer[*i as usize].assembler,
397-
AssemblerState::NotInit
398-
) {
395+
if matches!(self.packet_buffer[*i].assembler, AssemblerState::NotInit) {
399396
key = Some(*k);
400397
break;
401398
}
@@ -416,7 +413,7 @@ impl<'a, K: Eq + Ord + Clone + Copy> PacketAssemblerSet<'a, K> {
416413
F: Fn(&mut PacketAssembler<'_>) -> Result<bool>,
417414
{
418415
for (_, i) in &mut self.index_buffer.iter() {
419-
let frag = &mut self.packet_buffer[*i as usize];
416+
let frag = &mut self.packet_buffer[*i];
420417
if f(frag)? {
421418
frag.mark_discarded();
422419
}

src/iface/interface/ipv4.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -507,7 +507,7 @@ impl<'a> InterfaceInner<'a> {
507507
}
508508

509509
tx_buffer[repr.buffer_len()..][..payload_len].copy_from_slice(
510-
&buffer[*frag_offset as usize + repr.buffer_len() as usize..][..payload_len],
510+
&buffer[*frag_offset as usize + repr.buffer_len()..][..payload_len],
511511
);
512512

513513
// Update the frag offset for the next fragment.

src/socket/tcp.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ impl Default for RttEstimator {
129129
impl RttEstimator {
130130
fn retransmission_timeout(&self) -> Duration {
131131
let margin = RTTE_MIN_MARGIN.max(self.deviation * 4);
132-
let ms = (self.rtt + margin).max(RTTE_MIN_RTO).min(RTTE_MAX_RTO);
132+
let ms = (self.rtt + margin).clamp(RTTE_MIN_RTO, RTTE_MAX_RTO);
133133
Duration::from_millis(ms as u64)
134134
}
135135

@@ -1442,7 +1442,7 @@ impl<'a> Socket<'a> {
14421442

14431443
if segment_in_window {
14441444
// We've checked that segment_start >= window_start above.
1445-
payload_offset = (segment_start - window_start) as usize;
1445+
payload_offset = segment_start - window_start;
14461446
self.local_rx_last_seq = Some(repr.seq_number);
14471447
} else {
14481448
// If we're in the TIME-WAIT state, restart the TIME-WAIT timeout, since

src/wire/icmpv6.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -555,7 +555,7 @@ impl<'a> Repr<'a> {
555555
{
556556
let ip_packet = Ipv6Packet::new_checked(packet.payload())?;
557557

558-
let payload = &packet.payload()[ip_packet.header_len() as usize..];
558+
let payload = &packet.payload()[ip_packet.header_len()..];
559559
if payload.len() < 8 {
560560
return Err(Error);
561561
}

src/wire/igmp.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ impl<T: AsRef<[u8]>> Packet<T> {
7272
/// Returns `Err(Error)` if the buffer is too short.
7373
pub fn check_len(&self) -> Result<()> {
7474
let len = self.buffer.as_ref().len();
75-
if len < field::GROUP_ADDRESS.end as usize {
75+
if len < field::GROUP_ADDRESS.end {
7676
Err(Error)
7777
} else {
7878
Ok(())

src/wire/ipv6hopbyhop.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -296,14 +296,14 @@ mod test {
296296
#[test]
297297
fn test_header_len_overflow() {
298298
let mut bytes = vec![];
299-
bytes.extend(&REPR_PACKET_PAD4);
299+
bytes.extend(REPR_PACKET_PAD4);
300300
let len = bytes.len() as u8;
301301
Header::new_unchecked(&mut bytes).set_header_len(len + 1);
302302

303303
assert_eq!(Header::new_checked(&bytes).unwrap_err(), Error);
304304

305305
let mut bytes = vec![];
306-
bytes.extend(&REPR_PACKET_PAD12);
306+
bytes.extend(REPR_PACKET_PAD12);
307307
let len = bytes.len() as u8;
308308
Header::new_unchecked(&mut bytes).set_header_len(len + 1);
309309

src/wire/ipv6routing.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ impl<T: AsRef<[u8]>> Header<T> {
169169
return Err(Error);
170170
}
171171

172-
if len < field::DATA(self.header_len()).end as usize {
172+
if len < field::DATA(self.header_len()).end {
173173
return Err(Error);
174174
}
175175

src/wire/sixlowpan.rs

+7-8
Original file line numberDiff line numberDiff line change
@@ -1215,10 +1215,9 @@ pub mod iphc {
12151215
let mut len = 0;
12161216
len += 2; // The minimal header length
12171217

1218-
len += if self.next_header == NextHeader::Compressed {
1219-
0 // The next header is compressed (we don't need to inline what the next header is)
1220-
} else {
1221-
1 // The next header field is inlined
1218+
len += match self.next_header {
1219+
NextHeader::Compressed => 0, // The next header is compressed (we don't need to inline what the next header is)
1220+
NextHeader::Uncompressed(_) => 1, // The next header field is inlined
12221221
};
12231222

12241223
// Hop Limit size
@@ -1604,10 +1603,10 @@ pub mod nhc {
16041603
/// Return the size of the Next Header field.
16051604
fn next_header_size(&self) -> usize {
16061605
// If nh is set, then the Next Header is compressed using LOWPAN_NHC
1607-
if self.nh_field() == 1 {
1608-
0
1609-
} else {
1610-
1
1606+
match self.nh_field() {
1607+
0 => 1,
1608+
1 => 0,
1609+
_ => unreachable!(),
16111610
}
16121611
}
16131612
}

0 commit comments

Comments
 (0)