37         let ncbs = Arc::new(AtomicU32::new(0));  in test_ack_timer_start_and_stop()
38         let obs = Arc::new(Mutex::new(TestAckTimerObserver { ncbs: ncbs.clone() }));  in test_ack_timer_start_and_stop()
40         let mut rt = AckTimer::new(Arc::downgrade(&obs), ACK_INTERVAL);  in test_ack_timer_start_and_stop()
86         let m = RtoManager::new();  in test_rto_manager_initial_values()
97         let mut m = RtoManager::new();  in test_rto_manager_rto_calculation_small_rtt()
113         let mut m = RtoManager::new();  in test_rto_manager_rto_calculation_large_rtt()
150         let mut m = RtoManager::new();  in test_rto_manager_reset()
184                 ncbs: Arc::new(AtomicU32::new(0)),  in default()
226         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_callback_interval()
227         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_callback_interval()
232         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_callback_interval()
253         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_last_start_wins()
254         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_last_start_wins()
259         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_last_start_wins()
281         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_stop_right_after_start()
282         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_stop_right_after_start()
287         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_stop_right_after_start()
306         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_start_stop_then_start()
307         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_start_stop_then_start()
312         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_start_stop_then_start()
335         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_start_and_stop_in_atight_loop()
336         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_start_and_stop_in_atight_loop()
341         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_start_and_stop_in_atight_loop()
361         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_should_stop_after_rtx_failure()
362         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_should_stop_after_rtx_failure()
370         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_should_stop_after_rtx_failure()
411         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
412         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
421         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, 0);  in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
463         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_stop_timer_that_is_not_running_is_noop()
469         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_stop_timer_that_is_not_running_is_noop()
489         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_closed_timer_wont_start()
490         let obs = Arc::new(Mutex::new(TestTimerObserver {  in test_rtx_timer_closed_timer_wont_start()
495         let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS);  in test_rtx_timer_closed_timer_wont_start()