| /external/rust/crates/tokio/src/loom/std/ |
| D | mod.rs | 1 #![cfg_attr(any(not(feature = "full"), loom), allow(unused_imports, dead_code))]
58 pub(crate) use crate::loom::std::parking_lot::{
67 pub(crate) use crate::loom::std::mutex::Mutex;
70 pub(crate) use crate::loom::std::atomic_ptr::AtomicPtr;
71 pub(crate) use crate::loom::std::atomic_u16::AtomicU16;
72 pub(crate) use crate::loom::std::atomic_u32::AtomicU32;
73 pub(crate) use crate::loom::std::atomic_u64::AtomicU64;
74 pub(crate) use crate::loom::std::atomic_u8::AtomicU8;
75 pub(crate) use crate::loom::std::atomic_usize::AtomicUsize;
|
| /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()
|
| 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_multi()
81 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_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()
|
| 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()
|
| 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()
87 loom::model(|| { in changing_tx_task()
|
| D | loom_watch.rs | 3 use loom::future::block_on;
4 use loom::thread;
8 loom::model(|| { in smoke()
|
| /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::*;
|
| D | mod.rs | 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_pool.rs | 13 use loom::sync::atomic::{AtomicBool, AtomicUsize};
14 use loom::sync::{Arc, Mutex};
28 loom::model(|| { in racy_shutdown()
50 loom::model(|| { in pool_multi_spawn()
82 loom::model(move || { in only_blocking_inner()
116 loom::model(move || { in blocking_and_regular_inner()
163 loom::model(|| { in pool_shutdown()
180 loom::model(|| { in join_output()
194 loom::model(|| { in poll_drop_handle_then_drop()
211 loom::model(|| { in complete_block_on_under_load()
[all …]
|
| D | loom_basic_scheduler.rs | 1 use crate::loom::sync::atomic::AtomicUsize;
2 use crate::loom::sync::Arc;
3 use crate::loom::thread;
36 loom::model(|| { in block_on_num_polls()
|
| D | loom_queue.rs | 4 use loom::thread;
8 loom::model(|| { in basic()
62 loom::model(|| { in steal_overflow()
130 loom::model(|| { in multi_stealer()
166 loom::model(|| { in chained_steal()
|
| /external/rust/crates/crossbeam-epoch/src/ |
| D | lib.rs | 69 extern crate loom_crate as loom;
77 pub(crate) use loom::cell::UnsafeCell;
82 pub(crate) use loom::sync::atomic::AtomicUsize;
93 loom::sync::atomic::fence(Ordering::Acquire) in fence()
103 pub(crate) use loom::sync::Arc;
105 pub(crate) use loom::lazy_static;
106 pub(crate) use loom::thread_local;
|
| /external/rust/crates/tokio/src/time/driver/tests/ |
| D | mod.rs | 3 #[cfg(not(loom))]
6 use crate::loom::sync::Arc;
7 use crate::loom::thread;
9 loom::sync::atomic::{AtomicBool, Ordering},
26 #[cfg(loom)] in block_on()
27 return loom::future::block_on(f); in block_on()
29 #[cfg(not(loom))] in block_on()
34 #[cfg(loom)] in model()
35 loom::model(f); in model()
37 #[cfg(not(loom))] in model()
[all …]
|
| /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-epoch/ |
| D | Cargo.toml.orig | 35 # Enable the use of loom for concurrency testing.
39 loom = ["loom-crate", "crossbeam-utils/loom"]
46 # Enable the use of loom for concurrency testing.
51 loom-crate = { package = "loom", version = "0.4", optional = true }
|
| D | Cargo.toml | 52 loom = ["loom-crate", "crossbeam-utils/loom"] qkey
55 [target."cfg(crossbeam_loom)".dependencies.loom-crate]
58 package = "loom"
|
| /external/rust/crates/tokio/src/macros/ |
| D | cfg.rs | 42 #[cfg(not(loom))]
145 $( #[cfg(loom)] $item )*
151 $( #[cfg(not(loom))] $item )*
191 #[cfg(not(loom))]
200 #[cfg(not(loom))]
208 #[cfg(not(all(unix, not(loom), feature = "process")))]
219 #[cfg(not(loom))]
229 #[cfg(not(loom))]
238 … #[cfg(any(loom, not(unix), not(any(feature = "signal", all(unix, feature = "process")))))]
|
| D | thread_local.rs | 1 #[cfg(all(loom, test))]
3 ($($tts:tt)+) => { loom::thread_local!{ $($tts)+ } }
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | mod.rs | 91 #[cfg(all(target_pointer_width = "64", not(loom)))]
94 #[cfg(all(not(target_pointer_width = "64"), not(loom)))]
97 #[cfg(loom)]
|
| /external/rust/crates/crossbeam-utils/src/ |
| D | lib.rs | 48 pub(crate) use loom::sync::atomic::spin_loop_hint;
49 pub(crate) use loom::sync::atomic::{
58 pub(crate) use loom::sync::atomic::fence as compiler_fence;
60 pub(crate) use loom::sync::{Arc, Condvar, Mutex};
|
| /external/rust/crates/bytes/src/ |
| D | loom.rs | 1 #[cfg(not(all(test, loom)))]
23 #[cfg(all(test, loom))]
26 pub(crate) use loom::sync::atomic::{fence, AtomicPtr, AtomicUsize, Ordering};
|
| /external/rust/crates/tokio/src/sync/ |
| D | watch.rs | 58 use crate::loom::sync::atomic::AtomicUsize;
59 use crate::loom::sync::atomic::Ordering::{Relaxed, SeqCst};
60 use crate::loom::sync::{Arc, RwLock, RwLockReadGuard};
439 #[cfg(all(test, loom))]
442 use loom::thread;
447 loom::model(|| { in watch_spurious_wakeup()
481 loom::model(|| { in watch_borrow()
|