Skip to content

Commit 14ff7f4

Browse files
authored
Changed RR and SR ticker behavior to Skip to avoid overdue reports and catchup bursts (#745)
1 parent 92d43af commit 14ff7f4

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

interceptor/src/report/receiver/mod.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,8 @@ impl ReceiverReport {
8686
internal: Arc<ReceiverReportInternal>,
8787
) -> Result<()> {
8888
let mut ticker = tokio::time::interval(internal.interval);
89+
ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
90+
8991
let mut close_rx = {
9092
let mut close_rx = internal.close_rx.lock().await;
9193
if let Some(close) = close_rx.take() {

interceptor/src/report/sender/mod.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,8 @@ impl SenderReport {
4747
internal: Arc<SenderReportInternal>,
4848
) -> Result<()> {
4949
let mut ticker = tokio::time::interval(internal.interval);
50+
ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
51+
5052
let mut close_rx = {
5153
let mut close_rx = internal.close_rx.lock().await;
5254
if let Some(close) = close_rx.take() {

0 commit comments

Comments
 (0)