Skip to content

Commit 4f1bbd7

Browse files
committed
Change reconnecting interval to use MissedTickBehavior::Delay to not exhaust a lot of retries prematurely as with the default one - MissedTickBehavior::Burst
1 parent 640d330 commit 4f1bbd7

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

livekit/src/rtc_engine/mod.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ use std::{borrow::Cow, fmt::Debug, sync::Arc, time::Duration};
1717
use libwebrtc::prelude::*;
1818
use livekit_api::signal_client::{SignalError, SignalOptions};
1919
use livekit_protocol as proto;
20-
use livekit_runtime::{interval, Interval, JoinHandle};
20+
use livekit_runtime::{interval, Interval, JoinHandle, MissedTickBehavior};
2121
use parking_lot::{RwLock, RwLockReadGuard};
2222
use thiserror::Error;
2323
use tokio::sync::{
@@ -360,6 +360,8 @@ impl EngineInner {
360360
session.wait_pc_connection().await?;
361361

362362
let (engine_tx, engine_rx) = mpsc::unbounded_channel();
363+
let mut interval = interval(RECONNECT_INTERVAL);
364+
interval.set_missed_tick_behavior(MissedTickBehavior::Delay);
363365
let inner = Arc::new(Self {
364366
lk_runtime,
365367
engine_tx,
@@ -374,7 +376,7 @@ impl EngineInner {
374376
}),
375377
options,
376378
reconnecting_lock: AsyncRwLock::default(),
377-
reconnecting_interval: AsyncMutex::new(interval(RECONNECT_INTERVAL)),
379+
reconnecting_interval: AsyncMutex::new(interval),
378380
});
379381

380382
// Start initial tasks

0 commit comments

Comments
 (0)