Searched refs:rt (Results 1 – 4 of 4) sorted by relevance
43 let ok = rt.start(); in test_ack_timer_start_and_stop()48 rt.stop(); in test_ack_timer_start_and_stop()67 rt.stop(); in test_ack_timer_start_and_stop()242 rt.stop().await; in test_rtx_timer_callback_interval()270 rt.stop().await; in test_rtx_timer_last_start_wins()292 rt.stop().await; in test_rtx_timer_stop_right_after_start()295 rt.stop().await; in test_rtx_timer_stop_right_after_start()317 rt.stop().await; in test_rtx_timer_start_stop_then_start()324 rt.stop().await; in test_rtx_timer_start_stop_then_start()453 rt.stop().await; in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()[all …]
16 let rt = PeriodicTimer::new(timer_id, Duration::from_millis(50)); in test_periodic_timer() localVariable20 assert!(!rt.is_running().await, "should not be running yet"); in test_periodic_timer()22 let ok = rt.start(dummy1).await; in test_periodic_timer()24 assert!(rt.is_running().await, "should be running"); in test_periodic_timer()28 let ok = rt.start(dummy2).await; in test_periodic_timer()32 rt.stop().await; in test_periodic_timer()34 assert!(!rt.is_running().await, "should not be running"); in test_periodic_timer()
101 for rt in &self.receipt_time { in marshal_to()102 buf.put_u32(*rt); in marshal_to()
161 let rt = 987654321u32.wrapping_add( in test_receiver_interceptor_after_rtp_and_rtcp_packets() localVariable171 rtp_time: rt, in test_receiver_interceptor_after_rtp_and_rtcp_packets()452 let rt = 987654321u32.wrapping_add( in test_receiver_interceptor_packet_loss() localVariable462 rtp_time: rt, in test_receiver_interceptor_packet_loss()