Home
last modified time | relevance | path

Searched refs:sleep (Results 1 – 25 of 59) sorted by relevance

123

/webrtc/turn/src/allocation/channel_bind/
H A Dchannel_bind_test.rs47 tokio::time::sleep(Duration::from_millis(30)).await; in test_channel_bind_start()
60 tokio::time::sleep(Duration::from_millis(20)).await; in test_channel_bind_reset()
67 tokio::time::sleep(Duration::from_millis(20)).await; in test_channel_bind_reset()
/webrtc/turn/src/client/periodic_timer/
H A Dperiodic_timer_test.rs26 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/mdns/examples/
H A Dmdns_server_query.rs34 tokio::time::sleep(tokio::time::Duration::from_secs(20)).await; in main()
44 tokio::time::sleep(tokio::time::Duration::from_secs(20)).await; in main()
/webrtc/turn/src/allocation/allocation_manager/
H A Dallocation_manager_test.rs275 tokio::time::sleep(lifetime + Duration::from_millis(100)).await; in test_allocation_timeout()
324 tokio::time::sleep(Duration::from_millis(150)).await; in test_manager_close()
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()
545 tokio::time::sleep(Duration::from_millis(100)).await; in test_get_allocations_info_bytes_count()
548 tokio::time::sleep(Duration::from_millis(1000)).await; in test_get_allocations_info_bytes_count()
596 tokio::time::sleep(Duration::from_millis(100)).await; in test_alloc_close_notify()
599 tokio::time::sleep(Duration::from_millis(1000)).await; in test_alloc_close_notify()
604 tokio::time::sleep(Duration::from_millis(1000)).await; in test_alloc_close_notify()
/webrtc/turn/src/allocation/
H A Dallocation_manager.rs171 let sleep = tokio::time::sleep(Duration::from_secs(30)); in create_reservation() localVariable
172 tokio::pin!(sleep); in create_reservation()
174 _ = &mut sleep => { in create_reservation()
H A Dpermission.rs39 let timer = tokio::time::sleep(lifetime); in start()
H A Dchannel_bind.rs43 let timer = tokio::time::sleep(lifetime); in start()
/webrtc/util/src/conn/
H A Dconn_udp_listener_test.rs83 tokio::time::sleep(Duration::from_millis(100)).await; in test_listener_close_unaccepted()
136 let timer = tokio::time::sleep(Duration::from_millis(10)); in test_listener_accept_filter()
177 tokio::time::sleep(Duration::from_millis(100)).await; in test_listener_concurrent()
212 tokio::time::sleep(Duration::from_millis(100)).await; in test_listener_concurrent()
H A Dconn_bridge.rs124 tokio::time::sleep(TICK_WAIT).await; in push()
208 tokio::time::sleep(TICK_WAIT).await; in process()
/webrtc/sctp/src/timer/
H A Dtimer_test.rs8 use tokio::time::{sleep, Duration};
52 sleep(ACK_INTERVAL + Duration::from_millis(50)).await; in test_ack_timer_start_and_stop()
241 sleep(Duration::from_millis(650)).await; in test_rtx_timer_callback_interval()
269 sleep(Duration::from_millis((interval * 3) / 2)).await; in test_rtx_timer_last_start_wins()
294 sleep(Duration::from_millis((interval * 3) / 2)).await; in test_rtx_timer_stop_right_after_start()
323 sleep(Duration::from_millis((interval * 3) / 2)).await; in test_rtx_timer_start_stop_then_start()
508 sleep(Duration::from_millis(100)).await; in test_rtx_timer_closed_timer_wont_start()
H A Dack_timer.rs44 let timer = tokio::time::sleep(interval); in start()
/webrtc/turn/examples/
H A Dturn_client_udp.rs179 tokio::time::sleep(Duration::from_millis(500)).await; in do_ping_test()
193 tokio::time::sleep(Duration::from_secs(1)).await; in do_ping_test()
/webrtc/sctp/src/association/
H A Dassociation_test.rs71 let timer = tokio::time::sleep(Duration::from_millis(10)); in create_new_association_pair()
177 tokio::time::sleep(Duration::from_millis(10)).await; in flush_buffers()
352 tokio::time::sleep(Duration::from_millis(10)).await; in test_assoc_reliable_ordered_reordered()
662 tokio::time::sleep(Duration::from_millis(10)).await; in test_assoc_reliable_retransmission()
669 tokio::time::sleep(Duration::from_millis(10)).await; in test_assoc_reliable_retransmission()
1086 tokio::time::sleep(Duration::from_millis(10)).await; in test_assoc_unreliable_rexmit_unordered_fragment()
1362 tokio::time::sleep(Duration::from_millis(10)).await; in test_assoc_congestion_control_fast_retransmission()
1647 tokio::time::sleep(Duration::from_millis(4)).await; in test_assoc_congestion_control_slow_reader()
2091 tokio::time::sleep(Duration::from_millis(10)).await; in test_assoc_abort()
2272 let timer1 = tokio::time::sleep(Duration::from_secs(1)); in create_assocs()
[all …]
/webrtc/ice/src/udp_mux/
H A Dudp_mux_test.rs10 use tokio::time::{sleep, timeout};
180 sleep(Duration::from_millis(1)).await; in test_mux_connection()
268 sleep(Duration::from_millis(1)).await; in test_mux_connection()
/webrtc/data/src/data_channel/
H A Ddata_channel_test.rs16 tokio::time::sleep(Duration::from_millis(10)).await; in bridge_process_at_least_one()
74 let timer = tokio::time::sleep(Duration::from_millis(10)); in create_new_association_pair()
138 let timer = tokio::time::sleep(Duration::from_millis(10)); in close_association_pair()
221 tokio::time::sleep(Duration::from_millis(100)).await; in pr_ordered_unordered_test()
226 tokio::time::sleep(Duration::from_millis(100)).await; in pr_ordered_unordered_test()
363 tokio::time::sleep(Duration::from_millis(100)).await; in test_data_channel_channel_type_reliable_unordered()
504 tokio::time::sleep(Duration::from_millis(10)).await; in test_data_channel_buffered_amount()
/webrtc/interceptor/src/nack/generator/
H A Dgenerator_test.rs48 tokio::time::sleep(INTERVAL * 2).await; // wait for at least 2 nack packets in test_generator_interceptor()
/webrtc/turn/src/client/
H A Dperiodic_timer.rs61 let timer = tokio::time::sleep(interval); in start()
/webrtc/interceptor/src/twcc/sender/
H A Dsender_test.rs52 let timeout = tokio::time::sleep(Duration::from_millis(10)); in test_twcc_sender_interceptor()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_test.rs175 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()
276 tokio::time::sleep(Duration::from_secs(1)).await; in test_get_stats()
/webrtc/examples/examples/data-channels-flow-control/
H A Ddata-channels-flow-control.rs129 tokio::time::sleep(Duration::from_secs(1)).await; in create_responder()
144 tokio::time::sleep(Duration::from_secs(1)).await; in create_responder()
/webrtc/util/src/buffer/
H A Dbuffer_test.rs5 use tokio::time::{sleep, Duration};
148 sleep(Duration::from_micros(1)).await; in test_buffer_async()
155 sleep(Duration::from_micros(1)).await; in test_buffer_async()
/webrtc/sctp/examples/
H A Dpong.rs91 tokio::time::sleep(Duration::from_secs(1)).await; in main()
/webrtc/ice/src/agent/
H A Dagent_vnet_test.rs494 tokio::time::sleep(Duration::from_secs(1)).await; in test_connectivity_simple_vnet_full_cone_nats_on_both_ends()
556 tokio::time::sleep(Duration::from_secs(1)).await; in test_connectivity_vnet_full_cone_nats_on_both_ends()
618 tokio::time::sleep(Duration::from_secs(1)).await; in test_connectivity_vnet_symmetric_nats_on_both_ends()
671 tokio::time::sleep(Duration::from_secs(1)).await; in test_connectivity_vnet_1to1_nat_with_host_candidate_vs_symmetric_nats()
724 tokio::time::sleep(Duration::from_secs(1)).await; in test_connectivity_vnet_1to1_nat_with_srflx_candidate_vs_symmetric_nats()
982 tokio::time::sleep(Duration::from_millis(20)).await; in test_write_use_valid_pair()
/webrtc/dtls/src/
H A Dhandshaker.rs307 let retransmit_timer = tokio::time::sleep(self.cfg.retransmit_interval); in wait()
369 let retransmit_timer = tokio::time::sleep(self.cfg.retransmit_interval); in finish()
/webrtc/webrtc/src/ice_transport/
H A Dice_transport_test.rs28 tokio::time::sleep(Duration::from_secs(1)).await; in test_ice_transport_on_selected_candidate_pair_change()

123