| /external/rust/crates/sharded-slab/src/tests/ |
| D | mod.rs | 11 #[cfg_attr(loom, ignore)]
19 #[cfg_attr(loom, ignore)]
37 #[cfg(loom)]
45 #[cfg(loom)]
47 run_builder(name, loom::model::Builder::new(), f) in run_model()
50 #[cfg(loom)]
53 builder: loom::model::Builder, in run_builder()
68 #[cfg(not(loom))]
70 #[cfg(loom)]
72 #[cfg(loom)]
[all …]
|
| /external/rust/crates/tokio/src/loom/ |
| D | mocked.rs | 1 pub(crate) use loom::*;
5 pub(crate) use loom::sync::MutexGuard;
8 pub(crate) struct Mutex<T>(loom::sync::Mutex<T>);
14 Mutex(loom::sync::Mutex::new(t)) in new()
28 pub(crate) use loom::sync::*;
31 pub(crate) use loom::sync::atomic::*;
33 // TODO: implement a loom version
51 pub use loom::lazy_static::AccessError;
52 pub use loom::thread::*;
|
| D | mod.rs | 1 //! This module abstracts over `loom` and `std::sync` depending on whether we
6 #[cfg(not(all(test, loom)))]
8 #[cfg(not(all(test, loom)))]
11 #[cfg(all(test, loom))]
13 #[cfg(all(test, loom))]
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_multi_thread_alt.rs | 5 /// Full runtime loom tests. These are heavy tests and take significant time to
17 use loom::sync::atomic::{AtomicBool, AtomicUsize};
18 use loom::sync::Arc;
27 use loom::sync::atomic::AtomicBool;
83 loom::model(|| { in racy_shutdown()
105 loom::model(|| { in pool_multi_spawn()
137 loom::model(move || { in only_blocking_inner()
171 loom::model(move || { in blocking_and_regular_inner()
219 loom::model(|| { in join_output()
233 loom::model(|| { in poll_drop_handle_then_drop()
[all …]
|
| D | loom_multi_thread.rs | 5 /// Full runtime loom tests. These are heavy tests and take significant time to
17 use loom::sync::atomic::{AtomicBool, AtomicUsize};
18 use loom::sync::Arc;
27 use loom::sync::atomic::AtomicBool;
83 loom::model(|| { in racy_shutdown()
105 loom::model(|| { in pool_multi_spawn()
137 loom::model(move || { in only_blocking_inner()
171 loom::model(move || { in blocking_and_regular_inner()
218 loom::model(|| { in join_output()
232 loom::model(|| { in poll_drop_handle_then_drop()
[all …]
|
| /external/rust/crates/oneshot-uniffi/tests/helpers/ |
| D | mod.rs | 5 #[cfg(not(loom))]
7 #[cfg(not(loom))]
9 #[cfg(loom)]
10 use loom::sync::{
15 #[cfg(loom)]
19 #[cfg(loom)] in maybe_loom_model()
20 loom::model(test); in maybe_loom_model()
21 #[cfg(not(loom))] in maybe_loom_model()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_notify.rs | 3 use loom::future::block_on;
4 use loom::sync::Arc;
5 use loom::thread;
14 loom::model(|| { in notify_one()
31 loom::model(|| { in notify_waiters()
52 loom::model(|| { in notify_waiters_and_one()
81 loom::model(|| { in notify_multi()
115 loom::model(|| { in notify_drop()
180 loom::model(|| notify_waiters_poll_consistency_variant([false, false])); in notify_waiters_poll_consistency()
181 loom::model(|| notify_waiters_poll_consistency_variant([true, false])); in notify_waiters_poll_consistency()
[all …]
|
| D | loom_mpsc.rs | 4 use loom::future::block_on;
5 use loom::sync::Arc;
6 use loom::thread;
11 loom::model(|| { in closing_tx()
29 loom::model(|| { in closing_unbounded_tx()
47 loom::model(|| { in closing_bounded_rx()
61 loom::model(|| { in closing_and_sending()
88 loom::model(|| { in closing_unbounded_rx()
102 loom::model(|| { in dropping_tx()
120 loom::model(|| { in dropping_unbounded_tx()
[all …]
|
| D | loom_semaphore_batch.rs | 4 use loom::future::block_on;
5 use loom::sync::atomic::AtomicUsize;
6 use loom::thread;
33 loom::model(|| { in basic_usage()
53 loom::model(|| { in release()
74 loom::model(|| { in basic_closing()
99 loom::model(|| { in concurrent_close()
138 loom::model(|| { in concurrent_cancel()
162 let mut b = loom::model::Builder::new(); in batch()
202 loom::model(|| { in release_during_acquire()
|
| D | loom_oneshot.rs | 4 use loom::future::block_on;
5 use loom::thread;
10 loom::model(|| { in smoke()
24 loom::model(|| { in changing_rx_task()
61 loom::model(|| { in try_recv_close()
75 loom::model(|| { in recv_closed()
116 loom::model(|| { in changing_tx_task()
|
| D | loom_broadcast.rs | 4 use loom::future::block_on;
5 use loom::sync::Arc;
6 use loom::thread;
11 loom::model(|| { in broadcast_send()
52 loom::model(|| { in broadcast_two()
97 loom::model(|| { in broadcast_wrap()
146 loom::model(|| { in drop_rx()
184 loom::model(move || { in drop_multiple_rx_with_overflow()
|
| /external/rust/crates/crossbeam-epoch/src/ |
| D | lib.rs | 67 extern crate loom_crate as loom;
73 pub(crate) use loom::cell::UnsafeCell;
77 pub(crate) use loom::sync::atomic::{fence, AtomicPtr, AtomicUsize, Ordering};
79 // FIXME: loom does not support compiler_fence at the moment.
80 // https://github.com/tokio-rs/loom/issues/117
86 pub(crate) use loom::sync::Arc;
88 pub(crate) use loom::thread_local;
99 // loom's UnsafeCell has a slightly different API than the standard library UnsafeCell.
100 // Since we want the rest of the code to be agnostic to whether it's running under loom or
101 // not, we write this small wrapper that provides the loom-supported API for the standard
[all …]
|
| /external/rust/crates/tokio/src/runtime/time/tests/ |
| D | mod.rs | 5 #[cfg(not(loom))]
8 use crate::loom::sync::atomic::{AtomicBool, Ordering};
9 use crate::loom::sync::Arc;
10 use crate::loom::thread;
15 #[cfg(loom)] in block_on()
16 return loom::future::block_on(f); in block_on()
18 #[cfg(not(loom))] in block_on()
28 #[cfg(loom)] in model()
29 loom::model(f); in model()
31 #[cfg(not(loom))] in model()
[all …]
|
| /external/rust/crates/crossbeam-epoch/ |
| D | Cargo.toml.orig | 39 # Enable the use of loom for concurrency testing.
43 loom = ["loom-crate", "crossbeam-utils/loom"]
48 # Enable the use of loom for concurrency testing.
53 loom-crate = { package = "loom", version = "0.7.1", optional = true }
|
| D | Cargo.toml | 44 loom = [
45 "loom-crate",
46 "crossbeam-utils/loom",
54 [target."cfg(crossbeam_loom)".dependencies.loom-crate]
57 package = "loom"
|
| /external/rust/crates/tokio/src/runtime/tests/loom_multi_thread/ |
| D | yield_now.rs | 8 let mut loom = loom::model::Builder::default(); in yield_calls_park_before_scheduling_again() localVariable
9 loom.max_permutations = Some(1); in yield_calls_park_before_scheduling_again()
10 loom.check(|| { in yield_calls_park_before_scheduling_again()
15 let tid = loom::thread::current().id(); in yield_calls_park_before_scheduling_again()
20 if tid == loom::thread::current().id() { in yield_calls_park_before_scheduling_again()
|
| /external/rust/crates/tokio/src/runtime/tests/loom_multi_thread_alt/ |
| D | yield_now.rs | 8 let mut loom = loom::model::Builder::default(); in yield_calls_park_before_scheduling_again() localVariable
9 loom.max_permutations = Some(1); in yield_calls_park_before_scheduling_again()
10 loom.check(|| { in yield_calls_park_before_scheduling_again()
15 let tid = loom::thread::current().id(); in yield_calls_park_before_scheduling_again()
20 if tid == loom::thread::current().id() { in yield_calls_park_before_scheduling_again()
|
| /external/rust/crates/tokio/src/runtime/tests/loom_current_thread/ |
| D | yield_now.rs | 8 let mut loom = loom::model::Builder::default(); in yield_calls_park_before_scheduling_again() localVariable
9 loom.max_permutations = Some(1); in yield_calls_park_before_scheduling_again()
10 loom.check(|| { in yield_calls_park_before_scheduling_again()
15 let tid = loom::thread::current().id(); in yield_calls_park_before_scheduling_again()
20 if tid == loom::thread::current().id() { in yield_calls_park_before_scheduling_again()
|
| /external/rust/crates/oneshot-uniffi/tests/ |
| D | loom.rs | 1 #![cfg(loom)]
5 use loom::hint;
6 use loom::thread;
20 loom::model(|| { in try_recv()
39 loom::model(|| { in send_recv_different_threads()
55 loom::model(|| { in recv_drop_sender_different_threads()
71 loom::model(|| { in async_recv()
76 assert_eq!(loom::future::block_on(receiver), Ok(987)); in async_recv()
84 loom::model(|| { in send_then_poll()
104 loom::model(|| { in poll_then_send()
[all …]
|
| D | sync.rs | 11 #[cfg(loom)]
12 pub use loom::thread::spawn;
13 #[cfg(not(loom))]
16 #[cfg(loom)]
18 loom::thread::yield_now() in sleep()
59 // FIXME: This test does not work with loom. There is something that happens after the in send_before_recv()
62 #[cfg(not(loom))] in send_before_recv()
248 // This test doesn't give meaningful results when run with oneshot_test_delay and loom
249 #[cfg(all(feature = "std", not(all(oneshot_test_delay, loom))))]
256 #[cfg(not(loom))] in recv_deadline_time_should_elapse()
[all …]
|
| /external/rust/crates/sharded-slab/src/ |
| D | sync.rs | 3 #[cfg(all(loom, any(test, feature = "loom")))]
6 pub use loom::sync::atomic::*;
9 pub(crate) use loom::{
15 use loom::alloc;
19 /// This is a version of `loom::alloc::Track` that adds a missing
63 #[cfg(not(all(loom, any(feature = "loom", test))))]
|
| /external/rust/crates/tokio-util/src/sync/tests/ |
| D | loom_cancellation_token.rs | 3 use loom::{future::block_on, thread};
8 loom::model(|| { in cancel_token()
29 loom::model(|| { in cancel_token_owned()
50 loom::model(|| { in cancel_with_child()
80 loom::model(|| { in drop_token_no_child()
105 loom::model(|| { in drop_token_with_children()
130 loom::model(|| { in drop_and_cancel_token()
155 loom::model(|| { in cancel_parent_and_child()
|
| /external/rust/crates/tokio/src/macros/ |
| D | cfg.rs | 66 #[cfg(not(loom))]
186 $( #[cfg(loom)] $item )*
192 $( #[cfg(not(loom))] $item )*
209 // For now, metrics is only disabled in loom tests.
211 #[cfg(all(tokio_unstable, not(loom)))]
221 #[cfg(not(all(tokio_unstable, not(loom))))]
229 $( #[cfg(not(all(feature = "net", feature = "rt", all(tokio_unstable, not(loom)))))]$item )*
278 #[cfg(not(loom))]
288 #[cfg(not(loom))]
296 #[cfg(not(all(unix, not(loom), feature = "process")))]
[all …]
|
| /external/rust/crates/tokio/src/loom/std/ |
| D | mod.rs | 1 #![cfg_attr(any(not(feature = "full"), loom), allow(unused_imports, dead_code))]
61 pub(crate) use crate::loom::std::parking_lot::{
70 pub(crate) use crate::loom::std::mutex::Mutex;
73 pub(crate) use crate::loom::std::atomic_u16::AtomicU16;
74 pub(crate) use crate::loom::std::atomic_u32::AtomicU32;
75 pub(crate) use crate::loom::std::atomic_u64::{AtomicU64, StaticAtomicU64};
76 pub(crate) use crate::loom::std::atomic_usize::AtomicUsize;
|
| /external/rust/crates/crossbeam-epoch/tests/ |
| D | loom.rs | 4 use loom_crate as loom;
8 use loom::sync::atomic::Ordering::{self, Acquire, Relaxed, Release};
9 use loom::sync::Arc;
10 use loom::thread::spawn;
16 loom::model(|| { in it_works()
23 let jh = loom::thread::spawn(move || { in it_works()
136 loom::model(|| { in treiber_stack()
|