| /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()
27 pub(crate) use loom::sync::*;
30 pub(crate) use loom::sync::atomic::*;
32 // TODO: implement a loom version
50 pub use loom::lazy_static::AccessError;
51 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/sync/tests/ |
| 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_notify.rs | 3 use loom::future::block_on;
4 use loom::sync::Arc;
5 use loom::thread;
9 loom::model(|| { in notify_one()
26 loom::model(|| { in notify_waiters()
47 loom::model(|| { in notify_waiters_and_one()
76 loom::model(|| { in notify_multi()
110 loom::model(|| { in notify_drop()
|
| 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()
|
| D | loom_atomic_waker.rs | 4 use loom::future::block_on;
5 use loom::sync::atomic::AtomicUsize;
6 use loom::thread;
20 loom::model(|| { in basic_notification()
67 loom::model(move || { in test_panicky_waker()
|
| D | loom_rwlock.rs | 3 use loom::future::block_on;
4 use loom::thread;
9 let b = loom::model::Builder::new(); in concurrent_write()
40 let b = loom::model::Builder::new(); in concurrent_read_write()
87 loom::model(|| { in downgrade()
|
| /external/rust/crates/crossbeam-epoch/src/ |
| D | lib.rs | 67 extern crate loom_crate as loom;
75 pub(crate) use loom::cell::UnsafeCell;
80 pub(crate) use loom::sync::atomic::{fence, AtomicUsize};
82 // FIXME: loom does not support compiler_fence at the moment.
83 // https://github.com/tokio-rs/loom/issues/117
89 pub(crate) use loom::sync::Arc;
91 pub(crate) use loom::thread_local;
103 // loom's UnsafeCell has a slightly different API than the standard library UnsafeCell.
104 // Since we want the rest of the code to be agnostic to whether it's running under loom or
105 // not, we write this small wrapper that provides the loom-supported API for the standard
[all …]
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_pool.rs | 1 /// Full runtime loom tests. These are heavy tests and take significant time to
13 use loom::sync::atomic::{AtomicBool, AtomicUsize};
14 use loom::sync::Arc;
23 use loom::sync::atomic::AtomicBool;
79 loom::model(|| { in racy_shutdown()
101 loom::model(|| { in pool_multi_spawn()
133 loom::model(move || { in only_blocking_inner()
167 loom::model(move || { in blocking_and_regular_inner()
214 loom::model(|| { in join_output()
228 loom::model(|| { in poll_drop_handle_then_drop()
[all …]
|
| D | loom_yield.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()
|
| D | loom_blocking.rs | 7 loom::model(|| { in blocking_shutdown()
29 loom::model(|| { in spawn_mandatory_blocking_should_always_run()
50 loom::model(|| { in spawn_mandatory_blocking_should_run_even_when_shutting_down_from_other_thread()
56 loom::thread::spawn(move || { in spawn_mandatory_blocking_should_run_even_when_shutting_down_from_other_thread()
79 loom::model(|| { in spawn_blocking_when_paused()
|
| /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"]
53 # Enable the use of loom for concurrency testing.
58 loom-crate = { package = "loom", version = "0.5", optional = true }
|
| D | Cargo.toml | 60 loom = [
61 "loom-crate",
62 "crossbeam-utils/loom",
70 [target."cfg(crossbeam_loom)".dependencies.loom-crate]
73 package = "loom"
|
| /external/rust/crates/tokio/src/macros/ |
| D | loom.rs | 3 #[cfg(loom)]
4 const LOOM: bool = true; constant
5 #[cfg(not(loom))]
6 const LOOM: bool = false; constant
8 if LOOM {
|
| D | cfg.rs | 42 #[cfg(not(loom))]
162 $( #[cfg(loom)] $item )*
168 $( #[cfg(not(loom))] $item )*
185 // For now, metrics is only disabled in loom tests.
187 #[cfg(all(tokio_unstable, not(loom)))]
197 #[cfg(not(all(tokio_unstable, not(loom))))]
205 $( #[cfg(not(all(feature = "net", feature = "rt", all(tokio_unstable, not(loom)))))]$item )*
254 #[cfg(not(loom))]
264 #[cfg(not(loom))]
272 #[cfg(not(all(unix, not(loom), feature = "process")))]
[all …]
|
| D | thread_local.rs | 1 #[cfg(all(loom, test))]
4 loom::thread_local! {
10 ($($tts:tt)+) => { loom::thread_local!{ $($tts)+ } }
14 #[cfg(not(all(loom, test)))]
22 #[cfg(not(all(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/loom/std/ |
| D | mod.rs | 1 #![cfg_attr(any(not(feature = "full"), loom), allow(unused_imports, dead_code))]
60 pub(crate) use crate::loom::std::parking_lot::{
69 pub(crate) use crate::loom::std::mutex::Mutex;
72 pub(crate) use crate::loom::std::atomic_u16::AtomicU16;
73 pub(crate) use crate::loom::std::atomic_u32::AtomicU32;
74 pub(crate) use crate::loom::std::atomic_u64::{AtomicU64, StaticAtomicU64};
75 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()
|
| /external/rust/crates/crossbeam-utils/src/ |
| D | lib.rs | 47 pub(crate) use loom::sync::atomic::spin_loop_hint;
48 pub(crate) use loom::sync::atomic::{
53 // FIXME: loom does not support compiler_fence at the moment.
54 // https://github.com/tokio-rs/loom/issues/117
58 pub(crate) use loom::sync::atomic::fence as compiler_fence;
60 pub(crate) use loom::sync::{Arc, Condvar, Mutex};
|
| /external/rust/crates/bytes/.github/workflows/ |
| D | ci.yml | 134 # Loom
135 loom:
136 name: loom
142 - name: Loom tests
143 run: RUSTFLAGS="--cfg loom -Dwarnings" cargo test --lib
155 - loom
|
| /external/rust/crates/tokio/src/util/ |
| D | rc_cell.rs | 1 use crate::loom::cell::UnsafeCell;
12 #[cfg(not(all(loom, test)))]
19 // The UnsafeCell in loom does not have a const `new` fn.
20 #[cfg(all(loom, test))]
|