| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 21 interval: Option<Duration>, field
27 pub fn with_interval(mut self, interval: Duration) -> ReportBuilder { in with_interval()
28 self.interval = Some(interval); in with_interval()
42 interval: if let Some(interval) = &self.interval { in build_rr()
43 *interval in build_rr()
61 interval: if let Some(interval) = &self.interval { in build_sr()
62 *interval in build_sr()
|
| /webrtc/sctp/src/timer/ |
| H A D | ack_timer.rs | 18 pub(crate) interval: Duration, field
24 pub(crate) fn new(timeout_observer: Weak<Mutex<T>>, interval: Duration) -> Self { in new()
27 interval, in new()
40 let interval = self.interval; in start() localVariable
44 let timer = tokio::time::sleep(interval); in start()
|
| H A D | timer_test.rs | 261 let interval = 30; in test_rtx_timer_last_start_wins() localVariable
262 let ok = rt.start(interval).await; in test_rtx_timer_last_start_wins()
289 let interval = 30; in test_rtx_timer_stop_right_after_start() localVariable
290 let ok = rt.start(interval).await; in test_rtx_timer_stop_right_after_start()
314 let interval = 30; in test_rtx_timer_start_stop_then_start() localVariable
315 let ok = rt.start(interval).await; in test_rtx_timer_start_stop_then_start()
319 let ok = rt.start(interval).await; in test_rtx_timer_start_stop_then_start()
380 let interval = 10; in test_rtx_timer_should_stop_after_rtx_failure() localVariable
381 let ok = rt.start(interval).await; in test_rtx_timer_should_stop_after_rtx_failure()
431 let interval = 10; in test_rtx_timer_should_not_stop_if_max_retrans_is_zero() localVariable
[all …]
|
| H A D | rtx_timer.rs | 158 let interval = calculate_next_timeout(rto, n_rtos); in start() localVariable
159 let timer = tokio::time::sleep(Duration::from_millis(interval)); in start()
|
| /webrtc/turn/src/client/ |
| H A D | periodic_timer.rs | 28 interval: Duration, field
34 pub fn new(id: TimerIdRefresh, interval: Duration) -> Self { in new()
37 interval, in new()
56 let interval = self.interval; in start() localVariable
61 let timer = tokio::time::sleep(interval); in start()
|
| H A D | transaction.rs | 109 pub interval: u16, field
120 pub interval: Arc<AtomicU16>, field
133 interval: Arc::new(AtomicU16::new(0)), in default()
156 interval: Arc::new(AtomicU16::new(config.interval)), in new()
171 let (n_rtx, interval, key) = (self.n_rtx.clone(), self.interval.clone(), self.key.clone()); in start_rtx_timer()
177 interval.load(Ordering::SeqCst) as u64, in start_rtx_timer()
185 let mut val = interval.load(Ordering::SeqCst); in start_rtx_timer()
190 interval.store(val, Ordering::SeqCst); in start_rtx_timer()
|
| H A D | mod.rs | 112 interval: self.rto_in_ms, in perform_transaction()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 29 interval: Option<Duration>, field
48 pub fn with_interval(mut self, interval: Duration) -> GeneratorBuilder { in with_interval()
49 self.interval = Some(interval); in with_interval()
69 interval: if let Some(interval) = self.interval { in build()
70 interval in build()
88 interval: Duration, field
117 let mut ticker = tokio::time::interval(internal.interval); in run()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 20 interval: Option<Duration>, field
25 pub fn with_interval(mut self, interval: Duration) -> ReceiverBuilder { in with_interval()
26 self.interval = Some(interval); in with_interval()
37 interval: if let Some(interval) = &self.interval { in build()
38 *interval in build()
63 interval: Duration, field
116 let mut ticker = tokio::time::interval(internal.interval); in run()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 16 pub(crate) interval: Duration, field
48 let mut ticker = tokio::time::interval(internal.interval); in run()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 16 pub(crate) interval: Duration, field
86 let mut ticker = tokio::time::interval(internal.interval); in run()
|
| /webrtc/stun/src/ |
| H A D | client.rs | 50 let mut interval = time::interval(rate); in start() localVariable
55 _ = interval.tick() => { in start()
|
| /webrtc/examples/examples/play-from-disk-h264/ |
| H A D | play-from-disk-h264.rs | 185 let mut ticker = tokio::time::interval(Duration::from_millis(33)); in main()
262 let mut ticker = tokio::time::interval(OGG_PAGE_DURATION); in main()
|
| /webrtc/examples/examples/play-from-disk-vpx/ |
| H A D | play-from-disk-vpx.rs | 200 let mut ticker = tokio::time::interval(sleep_time); in main()
273 let mut ticker = tokio::time::interval(OGG_PAGE_DURATION); in main()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_internal.rs | 262 let mut interval = DEFAULT_CHECK_INTERVAL; in connectivity_checks() localVariable
265 if x != ZERO_DURATION && (interval == ZERO_DURATION || interval > x) { in connectivity_checks()
266 interval = x; in connectivity_checks()
284 let t = tokio::time::sleep(interval); in connectivity_checks()
|
| /webrtc/sdp/src/description/ |
| H A D | description_test.rs | 98 interval: 604800, in test_marshal()
|
| H A D | session.rs | 146 pub interval: i64, field
153 let mut fields = vec![format!("{}", self.interval), format!("{}", self.duration)]; in fmt()
1120 let interval = parse_time_units(fields[0])?; in unmarshal_repeat_times() localVariable
1128 interval, in unmarshal_repeat_times()
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 407 let mut int = tokio::time::interval(Duration::from_secs(1)); in main()
|
| /webrtc/examples/examples/play-from-disk-renegotiation/ |
| H A D | play-from-disk-renegotiation.rs | 391 let mut ticker = tokio::time::interval(sleep_time); in write_video_to_track()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 175 let mut cleanup_ticker = tokio::time::interval(Duration::from_secs(10)); in run_stats_reducer()
|