Lines Matching refs:Ordering

10 use std::sync::atomic::{AtomicU32, Ordering};
31             self.ncbs.fetch_add(1, Ordering::SeqCst);  in on_ack_timeout()
55             ncbs.load(Ordering::SeqCst),  in test_ack_timer_start_and_stop()
58             ncbs.load(Ordering::SeqCst)  in test_ack_timer_start_and_stop()
195             self.ncbs.fetch_add(1, Ordering::SeqCst);  in on_retransmission_timeout()
245         assert_eq!(ncbs.load(Ordering::SeqCst), 4, "should be called 4 times");  in test_rtx_timer_callback_interval()
273         assert_eq!(ncbs.load(Ordering::SeqCst), 1, "must be called once");  in test_rtx_timer_last_start_wins()
298         assert_eq!(ncbs.load(Ordering::SeqCst), 0, "no callback should be made");  in test_rtx_timer_stop_right_after_start()
327         assert_eq!(ncbs.load(Ordering::SeqCst), 1, "must be called once");  in test_rtx_timer_start_stop_then_start()
351         assert_eq!(ncbs.load(Ordering::SeqCst), 0, "no callback should be made");  in test_rtx_timer_start_and_stop_in_atight_loop()
388         assert_eq!(ncbs.load(Ordering::SeqCst), 5, "should be called 5 times");  in test_rtx_timer_should_stop_after_rtx_failure()
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()
509         assert_eq!(ncbs.load(Ordering::SeqCst), 0, "RTO should not occur");  in test_rtx_timer_closed_timer_wont_start()