24         ncbs: Arc<AtomicU32>,  field
31             self.ncbs.fetch_add(1, Ordering::SeqCst);  in on_ack_timeout()
37         let ncbs = Arc::new(AtomicU32::new(0));  in test_ack_timer_start_and_stop()  localVariable
38         let obs = Arc::new(Mutex::new(TestAckTimerObserver { ncbs: ncbs.clone() }));  in test_ack_timer_start_and_stop()
55             ncbs.load(Ordering::SeqCst),  in test_ack_timer_start_and_stop()
58             ncbs.load(Ordering::SeqCst)  in test_ack_timer_start_and_stop()
175         ncbs: Arc<AtomicU32>,  field
184                 ncbs: Arc::new(AtomicU32::new(0)),  in default()
195             self.ncbs.fetch_add(1, Ordering::SeqCst);  in on_retransmission_timeout()
226         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_callback_interval()  localVariable
228             ncbs: ncbs.clone(),  in test_rtx_timer_callback_interval()
245         assert_eq!(ncbs.load(Ordering::SeqCst), 4, "should be called 4 times");  in test_rtx_timer_callback_interval()
253         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_last_start_wins()  localVariable
255             ncbs: ncbs.clone(),  in test_rtx_timer_last_start_wins()
273         assert_eq!(ncbs.load(Ordering::SeqCst), 1, "must be called once");  in test_rtx_timer_last_start_wins()
281         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_stop_right_after_start()  localVariable
283             ncbs: ncbs.clone(),  in test_rtx_timer_stop_right_after_start()
298         assert_eq!(ncbs.load(Ordering::SeqCst), 0, "no callback should be made");  in test_rtx_timer_stop_right_after_start()
306         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_start_stop_then_start()  localVariable
308             ncbs: ncbs.clone(),  in test_rtx_timer_start_stop_then_start()
327         assert_eq!(ncbs.load(Ordering::SeqCst), 1, "must be called once");  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()  localVariable
337             ncbs: ncbs.clone(),  in test_rtx_timer_start_and_stop_in_atight_loop()
351         assert_eq!(ncbs.load(Ordering::SeqCst), 0, "no callback should be made");  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()  localVariable
363             ncbs: ncbs.clone(),  in test_rtx_timer_should_stop_after_rtx_failure()
388         assert_eq!(ncbs.load(Ordering::SeqCst), 5, "should be called 5 times");  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()  localVariable
413             ncbs: ncbs.clone(),  in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
439         assert_eq!(ncbs.load(Ordering::SeqCst), 6, "should be called 6 times");  in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
489         let ncbs = Arc::new(AtomicU32::new(0));  in test_rtx_timer_closed_timer_wont_start()  localVariable
491             ncbs: ncbs.clone(),  in test_rtx_timer_closed_timer_wont_start()
509         assert_eq!(ncbs.load(Ordering::SeqCst), 0, "RTO should not occur");  in test_rtx_timer_closed_timer_wont_start()