Home
last modified time | relevance | path

Searched refs:Duration (Results 1 – 25 of 122) sorted by relevance

12345

/webrtc/ice/src/agent/
H A Dagent_config.rs11 use std::time::Duration;
14 pub(crate) const DEFAULT_CHECK_INTERVAL: Duration = Duration::from_millis(200);
17 pub(crate) const DEFAULT_KEEPALIVE_INTERVAL: Duration = Duration::from_secs(2);
20 pub(crate) const DEFAULT_DISCONNECTED_TIMEOUT: Duration = Duration::from_secs(5);
23 pub(crate) const DEFAULT_FAILED_TIMEOUT: Duration = Duration::from_secs(25);
26 pub(crate) const DEFAULT_HOST_ACCEPTANCE_MIN_WAIT: Duration = Duration::from_secs(0);
29 pub(crate) const DEFAULT_SRFLX_ACCEPTANCE_MIN_WAIT: Duration = Duration::from_millis(500);
32 pub(crate) const DEFAULT_PRFLX_ACCEPTANCE_MIN_WAIT: Duration = Duration::from_millis(1000);
35 pub(crate) const DEFAULT_RELAY_ACCEPTANCE_MIN_WAIT: Duration = Duration::from_millis(2000);
44 pub(crate) const MAX_BINDING_REQUEST_TIMEOUT: Duration = Duration::from_millis(4000);
[all …]
H A Dagent_internal.rs67 pub(crate) host_acceptance_min_wait: Duration,
68 pub(crate) srflx_acceptance_min_wait: Duration,
69 pub(crate) prflx_acceptance_min_wait: Duration,
70 pub(crate) relay_acceptance_min_wait: Duration,
73 pub(crate) disconnected_timeout: Duration,
76 pub(crate) failed_timeout: Duration,
79 pub(crate) keepalive_interval: Duration,
81 pub(crate) check_interval: Duration,
139 failed_timeout: Duration::from_secs(0), in new()
146 check_interval: Duration::from_secs(0), in new()
[all …]
/webrtc/webrtc/src/api/setting_engine/
H A Dmod.rs16 use tokio::time::Duration;
26 pub ice_disconnected_timeout: Option<Duration>,
27 pub ice_failed_timeout: Option<Duration>,
28 pub ice_keepalive_interval: Option<Duration>,
29 pub ice_host_acceptance_min_wait: Option<Duration>,
30 pub ice_srflx_acceptance_min_wait: Option<Duration>,
31 pub ice_prflx_acceptance_min_wait: Option<Duration>,
32 pub ice_relay_acceptance_min_wait: Option<Duration>,
110 disconnected_timeout: Option<Duration>, in set_ice_timeouts() argument
111 failed_timeout: Option<Duration>, in set_ice_timeouts() argument
[all …]
H A Dsetting_engine_test.rs17 Some(Duration::from_secs(1)), in test_set_connection_timeout()
18 Some(Duration::from_secs(2)), in test_set_connection_timeout()
19 Some(Duration::from_secs(3)), in test_set_connection_timeout()
23 Some(Duration::from_secs(1)) in test_set_connection_timeout()
25 assert_eq!(s.timeout.ice_failed_timeout, Some(Duration::from_secs(2))); in test_set_connection_timeout()
28 Some(Duration::from_secs(3)) in test_set_connection_timeout()
/webrtc/turn/src/allocation/channel_bind/
H A Dchannel_bind_test.rs10 async fn create_channel_bind(lifetime: Duration) -> Result<Allocation> { in create_channel_bind()
33 let a = create_channel_bind(Duration::from_millis(20)).await?; in test_channel_bind()
46 let a = create_channel_bind(Duration::from_millis(20)).await?; in test_channel_bind_start()
47 tokio::time::sleep(Duration::from_millis(30)).await; in test_channel_bind_start()
58 let a = create_channel_bind(Duration::from_millis(30)).await?; in test_channel_bind_reset()
60 tokio::time::sleep(Duration::from_millis(20)).await; in test_channel_bind_reset()
64 c.refresh(Duration::from_millis(30)).await; in test_channel_bind_reset()
67 tokio::time::sleep(Duration::from_millis(20)).await; in test_channel_bind_reset()
/webrtc/turn/src/proto/
H A Dlifetime.rs5 use std::time::Duration;
13 pub const DEFAULT_LIFETIME: Duration = Duration::from_secs(10 * 60);
25 pub struct Lifetime(pub Duration);
54 self.0 = Duration::from_secs(seconds as u64); in get_from()
/webrtc/turn/src/allocation/
H A Dpermission.rs5 use tokio::time::{Duration, Instant};
7 pub(crate) const PERMISSION_TIMEOUT: Duration = Duration::from_secs(5 * 60);
15 reset_tx: Option<mpsc::Sender<Duration>>,
30 pub(crate) async fn start(&mut self, lifetime: Duration) { in start() argument
72 pub(crate) async fn refresh(&self, lifetime: Duration) { in refresh() argument
H A Dchannel_bind.rs9 use tokio::time::{Duration, Instant};
18 reset_tx: Option<mpsc::Sender<Duration>>,
34 pub(crate) async fn start(&mut self, lifetime: Duration) { in start() argument
78 pub(crate) async fn refresh(&self, lifetime: Duration) { in refresh() argument
/webrtc/sctp/src/timer/
H A Dack_timer.rs4 use tokio::time::Duration;
6 pub(crate) const ACK_INTERVAL: Duration = Duration::from_millis(200);
18 pub(crate) interval: Duration,
24 pub(crate) fn new(timeout_observer: Weak<Mutex<T>>, interval: Duration) -> Self { in new()
/webrtc/media/src/io/sample_builder/
H A Dsample_builder_test.rs20 max_late_timestamp: Duration,
85 max_late_timestamp: Duration::from_secs(0), in test_sample_builder()
103 max_late_timestamp: Duration::from_secs(0), in test_sample_builder()
152 duration: Duration::from_secs(1), in test_sample_builder()
240 duration: Duration::from_secs(2), in test_sample_builder()
815 duration: Duration::from_secs(2), in test_sample_builder()
1084 duration: Duration::from_secs(1), in test_sample_builder()
1261 duration: Duration::from_secs(1), in test_sample_builder_max_late()
1297 duration: Duration::from_secs(1), in test_sample_builder_max_late()
1317 duration: Duration::from_secs(1), in test_sample_builder_max_late()
[all …]
/webrtc/interceptor/src/report/
H A Dmod.rs3 use std::time::{Duration, SystemTime};
21 interval: Option<Duration>,
27 pub fn with_interval(mut self, interval: Duration) -> ReportBuilder { in with_interval()
45 Duration::from_secs(1) in build_rr()
64 Duration::from_secs(1) in build_sr()
/webrtc/interceptor/src/nack/generator/
H A Dgenerator_test.rs10 const INTERVAL: Duration = Duration::from_millis(10); in test_generator_interceptor()
41 let r = timeout_or_fail(Duration::from_millis(10), stream.read_rtp()) in test_generator_interceptor()
53 let r = timeout_or_fail(Duration::from_millis(10), stream.written_rtcp()) in test_generator_interceptor()
/webrtc/interceptor/src/nack/responder/
H A Dresponder_test.rs5 use tokio::time::Duration;
38 let p = timeout_or_fail(Duration::from_millis(10), stream.written_rtp()) in test_responder_interceptor()
59 if let Ok(r) = tokio::time::timeout(Duration::from_millis(50), stream.written_rtp()).await { in test_responder_interceptor()
70 let result = tokio::time::timeout(Duration::from_millis(10), stream.written_rtp()).await; in test_responder_interceptor()
/webrtc/mdns/src/
H A Dconfig.rs1 use std::time::Duration;
8 pub query_interval: Duration,
/webrtc/turn/src/client/periodic_timer/
H A Dperiodic_timer_test.rs16 let rt = PeriodicTimer::new(timer_id, Duration::from_millis(50)); in test_periodic_timer()
26 tokio::time::sleep(Duration::from_millis(100)).await; in test_periodic_timer()
31 tokio::time::sleep(Duration::from_millis(120)).await; in test_periodic_timer()
/webrtc/stun/src/
H A Dclient.rs16 use tokio::time::{self, Duration, Instant};
18 const DEFAULT_TIMEOUT_RATE: Duration = Duration::from_millis(5);
19 const DEFAULT_RTO: Duration = Duration::from_millis(300);
29 rate: Duration, in start() argument
43 rate: Duration, in start() argument
87 rto: Duration,
109 rto: Duration,
110 rto_rate: Duration,
148 pub fn with_rto(mut self, rto: Duration) -> Self { in with_rto()
154 pub fn with_timeout_rate(mut self, d: Duration) -> Self { in with_timeout_rate()
[all …]
/webrtc/media/src/
H A Dlib.rs12 use std::time::{Duration, SystemTime};
29 pub duration: Duration,
76 duration: Duration::from_secs(0), in default()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_test.rs12 use tokio::time::Duration;
45 Some(Duration::from_secs(1)), in create_vnet_pair()
46 Some(Duration::from_secs(1)), in create_vnet_pair()
47 Some(Duration::from_millis(200)), in create_vnet_pair()
70 Some(Duration::from_secs(1)), in create_vnet_pair()
71 Some(Duration::from_secs(1)), in create_vnet_pair()
72 Some(Duration::from_millis(200)), in create_vnet_pair()
175 let timeout = tokio::time::sleep(Duration::from_secs(10)); in close_pair()
213 let timeout = tokio::time::sleep(Duration::from_millis(20)); in send_video_until_done()
234 duration: Duration::from_secs(1), in send_video_until_done()
[all …]
/webrtc/interceptor/src/mock/
H A Dmock_time.rs1 use std::time::{Duration, SystemTime};
32 pub fn advance(&mut self, d: Duration) { in advance() argument
/webrtc/turn/src/allocation/allocation_manager/
H A Dallocation_manager_test.rs248 let lifetime = Duration::from_millis(100); in test_allocation_timeout()
307 Duration::from_millis(100), in test_manager_close()
318 Duration::from_millis(200), in test_manager_close()
324 tokio::time::sleep(Duration::from_millis(150)).await; in test_manager_close()
417 channel_bind_timeout: Duration::from_secs(0), in create_server()
478 tokio::time::sleep(Duration::from_millis(100)).await; in test_get_allocations_info()
526 tokio::time::sleep(Duration::from_millis(100)).await; in test_get_allocations_info_bytes_count()
529 tokio::time::sleep(Duration::from_millis(1000)).await; in test_get_allocations_info_bytes_count()
548 tokio::time::sleep(Duration::from_millis(1000)).await; in test_get_allocations_info_bytes_count()
599 tokio::time::sleep(Duration::from_millis(1000)).await; in test_alloc_close_notify()
[all …]
/webrtc/turn/src/client/
H A Dperiodic_timer.rs5 use tokio::time::Duration;
28 interval: Duration,
34 pub fn new(id: TimerIdRefresh, interval: Duration) -> Self { in new()
/webrtc/turn/src/auth/
H A Dmod.rs7 use std::time::{Duration, SystemTime, UNIX_EPOCH};
19 duration: Duration, in generate_long_term_credentials() argument
58 let t = Duration::from_secs(username.parse::<u64>()?); in auth_handle()
/webrtc/webrtc/src/rtp_transceiver/rtp_receiver/
H A Drtp_receiver_test.rs15 use tokio::time::Duration;
143 duration: Duration::from_secs(1), in test_set_rtp_parameters()
184 let result = tokio::time::timeout(Duration::from_secs(1), track.read_rtp()).await; in test_rtp_receiver_set_read_deadline()
190 let result = tokio::time::timeout(Duration::from_secs(1), track.read_rtp()).await; in test_rtp_receiver_set_read_deadline()
193 let result = tokio::time::timeout(Duration::from_secs(1), receiver.read_rtcp()).await; in test_rtp_receiver_set_read_deadline()
214 duration: Duration::from_secs(1), in test_rtp_receiver_set_read_deadline()
/webrtc/turn/src/server/
H A Dconfig.rs10 use tokio::time::Duration;
40 pub channel_bind_timeout: Duration,
/webrtc/dtls/src/handshake/handshake_message_server_hello/
H A Dhandshake_message_server_hello_test.rs4 use std::time::{Duration, SystemTime};
15 SystemTime::UNIX_EPOCH.checked_add(Duration::new(560149025u64, 0)) in test_handshake_message_server_hello()

12345