IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2025-02-25 18:55:32 -06:00
Code Issues Packages Projects Releases Wiki Activity

ISSUE #229 - Use checked add with 0 default when adding packet counters.

Browse Source
This commit is contained in:
Herbert Wolverson
2023-02-01 20:00:32 +00:00
parent e2508a6e57
commit cb3fa889fb
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/rust/lqosd/src/throughput_tracker/tracking_data.rs
View File

@@ -124,22 +124,22 @@ impl ThroughputTracker {
.iter()
.map(|(_k, v)| {
(
v.bytes.0 - v.prev_bytes.0,
v.bytes.1 - v.prev_bytes.1,
v.packets.0 - v.prev_packets.0,
v.packets.1 - v.prev_packets.1,
v.bytes.0.saturating_sub(v.prev_bytes.0),
v.bytes.1.saturating_sub(v.prev_bytes.1),
v.packets.0.saturating_sub(v.prev_packets.0),
v.packets.1.saturating_sub(v.prev_packets.1),
v.tc_handle.as_u32() > 0,
)
})
.for_each(
|(bytes_down, bytes_up, packets_down, packets_up, shaped)| {
self.bytes_per_second.0 += bytes_down;
self.bytes_per_second.1 += bytes_up;
self.packets_per_second.0 += packets_down;
self.packets_per_second.1 += packets_up;
self.bytes_per_second.0 = self.bytes_per_second.0.checked_add(bytes_down).unwrap_or(0);
self.bytes_per_second.1 = self.bytes_per_second.1.checked_add(bytes_up).unwrap_or(0);
self.packets_per_second.0 = self.packets_per_second.0.checked_add(packets_down).unwrap_or(0);
self.packets_per_second.1 = self.packets_per_second.1.checked_add(packets_up).unwrap_or(0);
if shaped {
self.shaped_bytes_per_second.0 += bytes_down;
self.shaped_bytes_per_second.1 += bytes_up;
self.shaped_bytes_per_second.0 = self.shaped_bytes_per_second.0.checked_add(bytes_down).unwrap_or(0);
self.shaped_bytes_per_second.1 = self.shaped_bytes_per_second.1.checked_add(bytes_up).unwrap_or(0);
}
},
);