| /webrtc/webrtc/src/api/setting_engine/ |
| H A D | mod.rs | 62 pub(crate) timeout: Timeout, field
114 self.timeout.ice_disconnected_timeout = disconnected_timeout; in set_ice_timeouts()
115 self.timeout.ice_failed_timeout = failed_timeout; in set_ice_timeouts()
116 self.timeout.ice_keepalive_interval = keep_alive_interval; in set_ice_timeouts()
121 self.timeout.ice_host_acceptance_min_wait = t; in set_host_acceptance_min_wait()
126 self.timeout.ice_srflx_acceptance_min_wait = t; in set_srflx_acceptance_min_wait()
131 self.timeout.ice_prflx_acceptance_min_wait = t; in set_prflx_acceptance_min_wait()
136 self.timeout.ice_relay_acceptance_min_wait = t; in set_relay_acceptance_min_wait()
|
| H A D | setting_engine_test.rs | 12 assert_eq!(s.timeout.ice_disconnected_timeout, None); in test_set_connection_timeout()
13 assert_eq!(s.timeout.ice_failed_timeout, None); in test_set_connection_timeout()
14 assert_eq!(s.timeout.ice_keepalive_interval, None); in test_set_connection_timeout()
22 s.timeout.ice_disconnected_timeout, in test_set_connection_timeout()
25 assert_eq!(s.timeout.ice_failed_timeout, Some(Duration::from_secs(2))); in test_set_connection_timeout()
27 s.timeout.ice_keepalive_interval, in test_set_connection_timeout()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_test.rs | 52 let timeout = tokio::time::sleep(Duration::from_millis(10)); in test_twcc_sender_interceptor() localVariable
53 tokio::pin!(timeout); in test_twcc_sender_interceptor()
64 _ = timeout.as_mut()=>{ in test_twcc_sender_interceptor()
|
| /webrtc/mdns/src/conn/ |
| H A D | conn_test.rs | 4 use tokio::time::timeout;
33 timeout(Duration::from_millis(100), a.send(())) in test_query_respect_timeout()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_test.rs | 10 use tokio::time::{sleep, timeout};
73 timeout( in test_udp_mux()
82 timeout( in test_udp_mux()
96 timeout( in test_udp_mux()
135 let timeout = all_results.iter().find_map(|r| r.as_ref().err()); in test_udp_mux() localVariable
137 timeout.is_none(), in test_udp_mux()
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_test.rs | 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/webrtc/src/ice_transport/ |
| H A D | ice_gatherer.rs | 112 disconnected_timeout: self.setting_engine.timeout.ice_disconnected_timeout, in create_agent()
113 failed_timeout: self.setting_engine.timeout.ice_failed_timeout, in create_agent()
114 keepalive_interval: self.setting_engine.timeout.ice_keepalive_interval, in create_agent()
116 host_acceptance_min_wait: self.setting_engine.timeout.ice_host_acceptance_min_wait, in create_agent()
117 srflx_acceptance_min_wait: self.setting_engine.timeout.ice_srflx_acceptance_min_wait, in create_agent()
118 prflx_acceptance_min_wait: self.setting_engine.timeout.ice_prflx_acceptance_min_wait, in create_agent()
119 relay_acceptance_min_wait: self.setting_engine.timeout.ice_relay_acceptance_min_wait, in create_agent()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_test.rs | 175 let timeout = tokio::time::sleep(Duration::from_secs(10)); in close_pair() localVariable
176 tokio::pin!(timeout); in close_pair()
179 _ = timeout.as_mut() =>{ in close_pair()
213 let timeout = tokio::time::sleep(Duration::from_millis(20)); in send_video_until_done() localVariable
214 tokio::pin!(timeout); in send_video_until_done()
224 _ = timeout.as_mut() =>{ in send_video_until_done()
|
| /webrtc/examples/examples/data-channels/ |
| H A D | data-channels.rs | 134 let timeout = tokio::time::sleep(Duration::from_secs(5)); in main() localVariable
135 tokio::pin!(timeout); in main()
138 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | dtls_transport_test.rs | 82 let timeout = tokio::time::sleep(Duration::from_secs(1)); in test_invalid_fingerprint_causes_failed() localVariable
83 tokio::pin!(timeout); in test_invalid_fingerprint_causes_failed()
105 _ = timeout.as_mut() =>{ in test_invalid_fingerprint_causes_failed()
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 145 let timeout = tokio::time::sleep(Duration::from_millis(400)); in test_agent_stop() localVariable
146 tokio::pin!(timeout); in test_agent_stop()
162 _ = timeout.as_mut() => panic!("timed out"), in test_agent_stop()
|
| /webrtc/examples/examples/data-channels-create/ |
| H A D | data-channels-create.rs | 127 let timeout = tokio::time::sleep(Duration::from_secs(5)); in main() localVariable
128 tokio::pin!(timeout); in main()
131 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/examples/examples/data-channels-detach-create/ |
| H A D | data-channels-detach-create.rs | 227 let timeout = tokio::time::sleep(Duration::from_secs(5)); in write_loop() localVariable
228 tokio::pin!(timeout); in write_loop()
231 _ = timeout.as_mut() =>{ in write_loop()
|
| /webrtc/examples/examples/data-channels-detach/ |
| H A D | data-channels-detach.rs | 235 let timeout = tokio::time::sleep(Duration::from_secs(5)); in write_loop() localVariable
236 tokio::pin!(timeout); in write_loop()
239 _ = timeout.as_mut() =>{ in write_loop()
|
| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener_test.rs | 135 let mut timeout = false; in test_listener_accept_filter() localVariable
143 timeout = true; in test_listener_accept_filter()
148 assert_eq!(!timeout, expected, "{name}: unexpected result"); in test_listener_accept_filter()
|
| /webrtc/examples/examples/simulcast/ |
| H A D | simulcast.rs | 174 let timeout = tokio::time::sleep(Duration::from_secs(3)); in main() localVariable
175 tokio::pin!(timeout); in main()
178 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/examples/examples/data-channels-close/ |
| H A D | data-channels-close.rs | 162 let timeout = tokio::time::sleep(Duration::from_secs(5)); in main() localVariable
163 tokio::pin!(timeout); in main()
169 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | rtp_receiver_test.rs | 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()
|
| /webrtc/examples/examples/reflect/ |
| H A D | reflect.rs | 209 let timeout = tokio::time::sleep(Duration::from_secs(3)); in main() localVariable
210 tokio::pin!(timeout); in main()
213 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | rtp-forwarder.rs | 191 let timeout = tokio::time::sleep(Duration::from_secs(3)); in main() localVariable
192 tokio::pin!(timeout); in main()
195 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/examples/examples/ortc/ |
| H A D | ortc.rs | 264 let timeout = tokio::time::sleep(Duration::from_secs(5)); in handle_on_open() localVariable
265 tokio::pin!(timeout); in handle_on_open()
268 _ = timeout.as_mut() =>{ in handle_on_open()
|
| /webrtc/examples/examples/broadcast/ |
| H A D | broadcast.rs | 136 let timeout = tokio::time::sleep(Duration::from_secs(3)); in main() localVariable
137 tokio::pin!(timeout); in main()
140 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/examples/examples/swap-tracks/ |
| H A D | swap-tracks.rs | 277 let timeout = tokio::time::sleep(Duration::from_secs(5)); in main() localVariable
278 tokio::pin!(timeout); in main()
281 _ = timeout.as_mut() => { in main()
|
| /webrtc/examples/examples/save-to-disk-h264/ |
| H A D | save-to-disk-h264.rs | 214 let timeout = tokio::time::sleep(Duration::from_secs(3)); in main() localVariable
215 tokio::pin!(timeout); in main()
218 _ = timeout.as_mut() =>{ in main()
|
| /webrtc/examples/examples/save-to-disk-vpx/ |
| H A D | save-to-disk-vpx.rs | 239 let timeout = tokio::time::sleep(Duration::from_secs(3)); in main() localVariable
240 tokio::pin!(timeout); in main()
243 _ = timeout.as_mut() =>{ in main()
|