Skip to content

Commit e892d91

Browse files
committed
don't reset dropped_packets in the interval with no exchanged data
1 parent 75d2ad7 commit e892d91

2 files changed

Lines changed: 4 additions & 3 deletions

File tree

src/networking/parse_packets.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -432,7 +432,7 @@ fn maybe_send_tick_run_live(
432432
first_packet_ticks.and_then(|i| i.checked_add(Duration::from_millis(1000)));
433433
let _ = tx.send_blocking(BackendTrafficMessage::TickRun(
434434
cap_id,
435-
info_traffic_msg.take_but_leave_timestamp(),
435+
info_traffic_msg.take_but_leave_something(),
436436
new_hosts_to_send.lock().unwrap().drain(..).collect(),
437437
false,
438438
));
@@ -460,7 +460,7 @@ fn maybe_send_tick_run_offline(
460460
next_packet_timestamp.secs() - info_traffic_msg.last_packet_timestamp.secs();
461461
let _ = tx.send_blocking(BackendTrafficMessage::TickRun(
462462
cap_id,
463-
info_traffic_msg.take_but_leave_timestamp(),
463+
info_traffic_msg.take_but_leave_something(),
464464
new_hosts_to_send.lock().unwrap().drain(..).collect(),
465465
false,
466466
));

src/networking/types/info_traffic.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,9 +158,10 @@ impl InfoTrafficMessage {
158158
}
159159
}
160160

161-
pub fn take_but_leave_timestamp(&mut self) -> Self {
161+
pub fn take_but_leave_something(&mut self) -> Self {
162162
let info_traffic = Self {
163163
last_packet_timestamp: self.last_packet_timestamp,
164+
dropped_packets: self.dropped_packets,
164165
..Self::default()
165166
};
166167
std::mem::replace(self, info_traffic)

0 commit comments

Comments
 (0)