Lines Matching refs:obs
38 let obs = Arc::new(Mutex::new(TestAckTimerObserver { ncbs: ncbs.clone() })); in test_ack_timer_start_and_stop() localVariable
40 let mut rt = AckTimer::new(Arc::downgrade(&obs), ACK_INTERVAL); in test_ack_timer_start_and_stop()
227 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_callback_interval() localVariable
232 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS); in test_rtx_timer_callback_interval()
254 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_last_start_wins() localVariable
259 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS); in test_rtx_timer_last_start_wins()
282 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_stop_right_after_start() localVariable
287 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS); in test_rtx_timer_stop_right_after_start()
307 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_start_stop_then_start() localVariable
312 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS); in test_rtx_timer_start_stop_then_start()
336 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_start_and_stop_in_atight_loop() localVariable
341 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS); in test_rtx_timer_start_and_stop_in_atight_loop()
362 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_should_stop_after_rtx_failure() localVariable
370 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS); in test_rtx_timer_should_stop_after_rtx_failure()
412 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_should_not_stop_if_max_retrans_is_zero() localVariable
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() localVariable
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()
490 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_closed_timer_wont_start() localVariable
495 let rt = RtxTimer::new(Arc::downgrade(&obs), timer_id, PATH_MAX_RETRANS); in test_rtx_timer_closed_timer_wont_start()