Lines Matching refs:AMT
203 const AMT: u32 = if cfg!(miri) { 100 } else { 10000 }; in stress_shared_unbounded() constant
209 assert_eq!(result.len(), (AMT * NTHREADS) as usize); in stress_shared_unbounded()
219 for _ in 0..AMT { in stress_shared_unbounded()
232 const AMT: u32 = if cfg!(miri) { 100 } else { 10000 }; in stress_shared_bounded_hard() constant
238 assert_eq!(result.len(), (AMT * NTHREADS) as usize); in stress_shared_bounded_hard()
248 for _ in 0..AMT { in stress_shared_bounded_hard()
262 const AMT: usize = if cfg!(miri) { 100 } else { 10_000 }; in stress_receiver_multi_task_bounded_hard() constant
314 for i in 0..AMT { in stress_receiver_multi_task_bounded_hard()
323 assert_eq!(AMT, n.load(Ordering::Relaxed)); in stress_receiver_multi_task_bounded_hard()
404 const AMT: u32 = if cfg!(miri) { 100 } else { 1000 }; in stress_poll_ready() constant
413 threads.push(thread::spawn(move || block_on(stress_poll_ready_sender(sender, AMT)))); in stress_poll_ready()
418 assert_eq!(result.len() as u32, AMT * NTHREADS); in stress_poll_ready()