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

Consistency: rename last_tcp_retransmits to prev_tcp_retransmits (since all the others use prev_ for previous).

Browse Source
This commit is contained in:
Herbert Wolverson 2024-07-02 15:09:36 -05:00
parent 1fac078389
commit 91d26d315c
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/rust/lqosd/src/throughput_tracker/throughput_entry.rs
View File

@ -19,7 +19,7 @@ pub(crate) struct ThroughputEntry {
pub(crate) last_fresh_rtt_data_cycle: u64, pub(crate) last_fresh_rtt_data_cycle: u64,
pub(crate) last_seen: u64, // Last seen in kernel time since boot pub(crate) last_seen: u64, // Last seen in kernel time since boot
pub(crate) tcp_retransmits: DownUpOrder<u64>, pub(crate) tcp_retransmits: DownUpOrder<u64>,
pub(crate) last_tcp_retransmits: DownUpOrder<u64>, pub(crate) prev_tcp_retransmits: DownUpOrder<u64>,
} }
impl ThroughputEntry { impl ThroughputEntry {

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

@ -148,7 +148,7 @@ impl ThroughputTracker {
last_fresh_rtt_data_cycle: 0, last_fresh_rtt_data_cycle: 0,
last_seen: 0, last_seen: 0,
tcp_retransmits: DownUpOrder::zeroed(), tcp_retransmits: DownUpOrder::zeroed(),
last_tcp_retransmits: DownUpOrder::zeroed(), prev_tcp_retransmits: DownUpOrder::zeroed(),
}; };
for c in counts { for c in counts {
entry.bytes.checked_add_direct(c.download_bytes, c.upload_bytes); entry.bytes.checked_add_direct(c.download_bytes, c.upload_bytes);
@ -293,10 +293,10 @@ impl ThroughputTracker {
// Apply the new ones // Apply the new ones
for (local_ip, retries) in tcp_retries { for (local_ip, retries) in tcp_retries {
if let Some(mut tracker) = self.raw_data.get_mut(&local_ip) { if let Some(mut tracker) = self.raw_data.get_mut(&local_ip) {
tracker.tcp_retransmits.down = retries.down.saturating_sub(tracker.last_tcp_retransmits.down); tracker.tcp_retransmits.down = retries.down.saturating_sub(tracker.prev_tcp_retransmits.down);
tracker.tcp_retransmits.up = retries.up.saturating_sub(tracker.last_tcp_retransmits.up); tracker.tcp_retransmits.up = retries.up.saturating_sub(tracker.prev_tcp_retransmits.up);
tracker.last_tcp_retransmits.down = retries.down; tracker.prev_tcp_retransmits.down = retries.down;
tracker.last_tcp_retransmits.up = retries.up; tracker.prev_tcp_retransmits.up = retries.up;
} }
} }