From 96aef2d3883f305a89191c43bc4e6b18e04b103f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sampo=20Kivist=C3=B6?= Date: Tue, 7 Oct 2025 23:33:46 +0300 Subject: [PATCH] Changed RR and SR ticker behavior to Skip to avoid overdue reports and catchup bursts --- interceptor/src/report/receiver/mod.rs | 2 ++ interceptor/src/report/sender/mod.rs | 2 ++ 2 files changed, 4 insertions(+) diff --git a/interceptor/src/report/receiver/mod.rs b/interceptor/src/report/receiver/mod.rs index 5a5e21579..19fc8e558 100644 --- a/interceptor/src/report/receiver/mod.rs +++ b/interceptor/src/report/receiver/mod.rs @@ -86,6 +86,8 @@ impl ReceiverReport { internal: Arc, ) -> Result<()> { let mut ticker = tokio::time::interval(internal.interval); + ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip); + let mut close_rx = { let mut close_rx = internal.close_rx.lock().await; if let Some(close) = close_rx.take() { diff --git a/interceptor/src/report/sender/mod.rs b/interceptor/src/report/sender/mod.rs index f46c54933..81a832132 100644 --- a/interceptor/src/report/sender/mod.rs +++ b/interceptor/src/report/sender/mod.rs @@ -47,6 +47,8 @@ impl SenderReport { internal: Arc, ) -> Result<()> { let mut ticker = tokio::time::interval(internal.interval); + ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip); + let mut close_rx = { let mut close_rx = internal.close_rx.lock().await; if let Some(close) = close_rx.take() {