| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | counters.rs | 4 use std::sync::atomic::Ordering::Relaxed;
27 let notifies_local = NUM_NOTIFY_LOCAL.load(Relaxed); in drop()
28 let notifies_remote = NUM_NOTIFY_REMOTE.load(Relaxed); in drop()
29 let unparks_local = NUM_UNPARKS_LOCAL.load(Relaxed); in drop()
30 let unparks_remote = NUM_UNPARKS_REMOTE.load(Relaxed); in drop()
31 let maintenance = NUM_MAINTENANCE.load(Relaxed); in drop()
32 let lifo_scheds = NUM_LIFO_SCHEDULES.load(Relaxed); in drop()
33 let lifo_capped = NUM_LIFO_CAPPED.load(Relaxed); in drop()
34 let num_steals = NUM_STEALS.load(Relaxed); in drop()
35 let num_overflow = NUM_OVERFLOW.load(Relaxed); in drop()
[all …]
|
| /external/rust/android-crates-io/crates/rustix/src/backend/linux_raw/param/ |
| D | init.rs | 26 unsafe { PAGE_SIZE.load(Ordering::Relaxed) } in page_size()
32 unsafe { CLOCK_TICKS_PER_SECOND.load(Ordering::Relaxed) as u64 } in clock_ticks_per_second()
40 HWCAP.load(Ordering::Relaxed), in linux_hwcap()
41 HWCAP2.load(Ordering::Relaxed), in linux_hwcap()
49 let execfn = unsafe { EXECFN.load(Ordering::Relaxed) }; in linux_execfn()
59 unsafe { SECURE.load(Ordering::Relaxed) } in linux_secure()
67 PHDR.load(Ordering::Relaxed).cast(), in exe_phdrs()
68 PHENT.load(Ordering::Relaxed), in exe_phdrs()
69 PHNUM.load(Ordering::Relaxed), in exe_phdrs()
78 unsafe { SYSINFO_EHDR.load(Ordering::Relaxed) } in sysinfo_ehdr()
[all …]
|
| D | auxv.rs | 21 use core::sync::atomic::Ordering::Relaxed;
37 let mut page_size = PAGE_SIZE.load(Relaxed); in page_size()
41 page_size = PAGE_SIZE.load(Relaxed); in page_size()
50 let mut ticks = CLOCK_TICKS_PER_SECOND.load(Relaxed); in clock_ticks_per_second()
54 ticks = CLOCK_TICKS_PER_SECOND.load(Relaxed); in clock_ticks_per_second()
63 let mut hwcap = HWCAP.load(Relaxed); in linux_hwcap()
64 let mut hwcap2 = HWCAP2.load(Relaxed); in linux_hwcap()
68 hwcap = HWCAP.load(Relaxed); in linux_hwcap()
69 hwcap2 = HWCAP2.load(Relaxed); in linux_hwcap()
78 let mut execfn = EXECFN.load(Relaxed); in linux_execfn()
[all …]
|
| /external/rust/android-crates-io/crates/dashmap/src/ |
| D | lock.rs | 28 .compare_exchange(0, ONE_WRITER, Ordering::Acquire, Ordering::Relaxed) in try_lock_exclusive()
36 .compare_exchange_weak(0, ONE_WRITER, Ordering::Acquire, Ordering::Relaxed) in lock_exclusive()
47 .compare_exchange(ONE_WRITER, 0, Ordering::Release, Ordering::Relaxed) in unlock_exclusive()
94 let mut state = self.state.load(Ordering::Relaxed); in lock_exclusive_slow()
102 Ordering::Relaxed, in lock_exclusive_slow()
111 state = self.state.load(Ordering::Relaxed); in lock_exclusive_slow()
118 Ordering::Relaxed, in lock_exclusive_slow()
119 Ordering::Relaxed, in lock_exclusive_slow()
130 let state = self.state.load(Ordering::Relaxed); in lock_exclusive_slow()
148 let state = self.state.load(Ordering::Relaxed); in unlock_exclusive_slow()
[all …]
|
| /external/rust/android-crates-io/crates/parking_lot/src/ |
| D | raw_mutex.rs | 69 .compare_exchange_weak(0, LOCKED_BIT, Ordering::Acquire, Ordering::Relaxed) in lock()
79 let mut state = self.state.load(Ordering::Relaxed); in try_lock()
88 Ordering::Relaxed, in try_lock()
104 .compare_exchange(LOCKED_BIT, 0, Ordering::Release, Ordering::Relaxed) in unlock()
114 let state = self.state.load(Ordering::Relaxed); in is_locked()
125 .compare_exchange(LOCKED_BIT, 0, Ordering::Release, Ordering::Relaxed) in unlock_fair()
135 if self.state.load(Ordering::Relaxed) & PARKED_BIT != 0 { in bump()
149 .compare_exchange_weak(0, LOCKED_BIT, Ordering::Acquire, Ordering::Relaxed) in try_lock_until()
166 .compare_exchange_weak(0, LOCKED_BIT, Ordering::Acquire, Ordering::Relaxed) in try_lock_for()
185 let mut state = self.state.load(Ordering::Relaxed); in mark_parked_if_locked()
[all …]
|
| D | raw_rwlock.rs | 70 .compare_exchange_weak(0, WRITER_BIT, Ordering::Acquire, Ordering::Relaxed) in lock_exclusive()
83 .compare_exchange(0, WRITER_BIT, Ordering::Acquire, Ordering::Relaxed) in try_lock_exclusive()
98 .compare_exchange(WRITER_BIT, 0, Ordering::Release, Ordering::Relaxed) in unlock_exclusive()
143 let state = self.state.load(Ordering::Relaxed); in is_locked()
149 let state = self.state.load(Ordering::Relaxed); in is_locked_exclusive()
166 .compare_exchange(WRITER_BIT, 0, Ordering::Release, Ordering::Relaxed) in unlock_exclusive_fair()
176 if self.state.load(Ordering::Relaxed) & (READERS_MASK | WRITER_BIT) in bump_shared()
185 if self.state.load(Ordering::Relaxed) & PARKED_BIT != 0 { in bump_exclusive()
239 .compare_exchange_weak(0, WRITER_BIT, Ordering::Acquire, Ordering::Relaxed) in try_lock_exclusive_for()
256 .compare_exchange_weak(0, WRITER_BIT, Ordering::Acquire, Ordering::Relaxed) in try_lock_exclusive_until()
[all …]
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | counters.rs | 4 use std::sync::atomic::Ordering::Relaxed;
14 let notifies_local = NUM_NOTIFY_LOCAL.load(Relaxed); in drop()
15 let unparks_local = NUM_UNPARKS_LOCAL.load(Relaxed); in drop()
16 let maintenance = NUM_MAINTENANCE.load(Relaxed); in drop()
17 let lifo_scheds = NUM_LIFO_SCHEDULES.load(Relaxed); in drop()
18 let lifo_capped = NUM_LIFO_CAPPED.load(Relaxed); in drop()
30 NUM_NOTIFY_LOCAL.fetch_add(1, Relaxed); in inc_num_inc_notify_local()
34 NUM_UNPARKS_LOCAL.fetch_add(1, Relaxed); in inc_num_unparks_local()
38 NUM_MAINTENANCE.fetch_add(1, Relaxed); in inc_num_maintenance()
42 NUM_LIFO_SCHEDULES.fetch_add(1, Relaxed); in inc_lifo_schedules()
[all …]
|
| /external/rust/android-crates-io/crates/portable-atomic/src/tests/ |
| D | helper.rs | 281 assert_eq!(a.load(Ordering::Relaxed), 10);
283 assert_eq!(a.load(Ordering::Relaxed), 10);
295 let mut old = a.load(Ordering::Relaxed);
303 assert_eq!(a.load(Ordering::Relaxed), 8);
313 assert_eq!(a.load(Ordering::Relaxed), 10);
316 assert_eq!(a.load(Ordering::Relaxed), $int_type::MAX.wrapping_add(1));
326 assert_eq!(a.load(Ordering::Relaxed), 10);
329 assert_eq!(a.load(Ordering::Relaxed), $int_type::MAX.wrapping_add(1));
339 assert_eq!(a.load(Ordering::Relaxed), 10);
342 assert_eq!(a.load(Ordering::Relaxed), $int_type::MIN.wrapping_sub(1));
[all …]
|
| /external/rust/android-crates-io/crates/tracing/tests/ |
| D | filters_are_reevaluated_for_different_call_sites.rs | 32 charlie_count2.fetch_add(1, Ordering::Relaxed); in filters_are_reevaluated_for_different_call_sites()
36 dave_count2.fetch_add(1, Ordering::Relaxed); in filters_are_reevaluated_for_different_call_sites()
58 assert_eq!(charlie_count.load(Ordering::Relaxed), 1); in filters_are_reevaluated_for_different_call_sites()
59 assert_eq!(dave_count.load(Ordering::Relaxed), 1); in filters_are_reevaluated_for_different_call_sites()
65 assert_eq!(charlie_count.load(Ordering::Relaxed), 1); in filters_are_reevaluated_for_different_call_sites()
66 assert_eq!(dave_count.load(Ordering::Relaxed), 1); in filters_are_reevaluated_for_different_call_sites()
72 assert_eq!(charlie_count.load(Ordering::Relaxed), 2); in filters_are_reevaluated_for_different_call_sites()
73 assert_eq!(dave_count.load(Ordering::Relaxed), 1); in filters_are_reevaluated_for_different_call_sites()
78 assert_eq!(charlie_count.load(Ordering::Relaxed), 2); in filters_are_reevaluated_for_different_call_sites()
79 assert_eq!(dave_count.load(Ordering::Relaxed), 2); in filters_are_reevaluated_for_different_call_sites()
|
| D | filters_are_not_reevaluated_for_the_same_span.rs | 30 alice_count2.fetch_add(1, Ordering::Relaxed); in filters_are_not_reevaluated_for_the_same_span()
34 bob_count2.fetch_add(1, Ordering::Relaxed); in filters_are_not_reevaluated_for_the_same_span()
55 assert_eq!(alice_count.load(Ordering::Relaxed), 1); in filters_are_not_reevaluated_for_the_same_span()
56 assert_eq!(bob_count.load(Ordering::Relaxed), 1); in filters_are_not_reevaluated_for_the_same_span()
62 assert_eq!(alice_count.load(Ordering::Relaxed), 1); in filters_are_not_reevaluated_for_the_same_span()
63 assert_eq!(bob_count.load(Ordering::Relaxed), 1); in filters_are_not_reevaluated_for_the_same_span()
66 assert_eq!(alice_count.load(Ordering::Relaxed), 1); in filters_are_not_reevaluated_for_the_same_span()
67 assert_eq!(bob_count.load(Ordering::Relaxed), 1); in filters_are_not_reevaluated_for_the_same_span()
|
| D | filter_caching_is_lexically_scoped.rs | 35 count2.fetch_add(1, Ordering::Relaxed); in filter_caching_is_lexically_scoped()
48 assert_eq!(count.load(Ordering::Relaxed), 1); in filter_caching_is_lexically_scoped()
52 assert_eq!(count.load(Ordering::Relaxed), 1); in filter_caching_is_lexically_scoped()
55 assert_eq!(count.load(Ordering::Relaxed), 2); in filter_caching_is_lexically_scoped()
58 assert_eq!(count.load(Ordering::Relaxed), 2); in filter_caching_is_lexically_scoped()
61 assert_eq!(count.load(Ordering::Relaxed), 2); in filter_caching_is_lexically_scoped()
64 assert_eq!(count.load(Ordering::Relaxed), 2); in filter_caching_is_lexically_scoped()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/metrics/ |
| D | runtime.rs | 7 use std::sync::atomic::Ordering::Relaxed;
254 .load(Relaxed)
269 .load(Relaxed)
312 .load(Relaxed)
366 .load(Relaxed)
410 .load(Relaxed)
456 .load(Relaxed)
502 .load(Relaxed)
543 .load(Relaxed)
588 .load(Relaxed);
[all …]
|
| D | batch.rs | 3 use std::sync::atomic::Ordering::Relaxed;
81 worker.mean_poll_time.store(mean_poll_time, Relaxed); in submit()
82 worker.park_count.store(self.park_count, Relaxed); in submit()
85 .store(self.park_unpark_count, Relaxed); in submit()
86 worker.noop_count.store(self.noop_count, Relaxed); in submit()
87 worker.steal_count.store(self.steal_count, Relaxed); in submit()
90 .store(self.steal_operations, Relaxed); in submit()
91 worker.poll_count.store(self.poll_count, Relaxed); in submit()
95 .store(self.busy_duration_total, Relaxed); in submit()
99 .store(self.local_schedule_count, Relaxed); in submit()
[all …]
|
| /external/rust/android-crates-io/crates/crossbeam-epoch/src/ |
| D | collector.rs | 195 let before = collector.global.epoch.load(Ordering::Relaxed); in pin_holds_advance()
197 let after = collector.global.epoch.load(Ordering::Relaxed); in pin_holds_advance()
225 DESTROYS.fetch_add(1, Ordering::Relaxed); in incremental()
234 let curr = DESTROYS.load(Ordering::Relaxed); in incremental()
241 assert!(DESTROYS.load(Ordering::Relaxed) == COUNT); in incremental()
262 DESTROYS.fetch_add(1, Ordering::Relaxed); in buffering()
270 assert!(DESTROYS.load(Ordering::Relaxed) < COUNT); in buffering()
274 while DESTROYS.load(Ordering::Relaxed) < COUNT { in buffering()
278 assert_eq!(DESTROYS.load(Ordering::Relaxed), COUNT); in buffering()
293 DROPS.fetch_add(1, Ordering::Relaxed); in count_drops()
[all …]
|
| /external/rust/android-crates-io/crates/portable-atomic/src/imp/atomic128/ |
| D | intrinsics.rs | 47 sync::atomic::Ordering::{AcqRel, Acquire, Relaxed, Release, SeqCst},
55 Ordering::Release | Ordering::Relaxed => Ordering::Relaxed, in strongest_failure_ordering()
78 Relaxed => intrinsics::atomic_load_relaxed(src), in atomic_load()
98 Relaxed => intrinsics::atomic_store_relaxed(dst, val), in atomic_store()
163 (Relaxed, Relaxed) => intrinsics::atomic_cxchg_relaxed_relaxed(dst, old, new), in atomic_compare_exchange()
164 (Relaxed, Acquire) => intrinsics::atomic_cxchg_relaxed_acquire(dst, old, new), in atomic_compare_exchange()
165 (Relaxed, SeqCst) => intrinsics::atomic_cxchg_relaxed_seqcst(dst, old, new), in atomic_compare_exchange()
166 (Acquire, Relaxed) => intrinsics::atomic_cxchg_acquire_relaxed(dst, old, new), in atomic_compare_exchange()
169 (Release, Relaxed) => intrinsics::atomic_cxchg_release_relaxed(dst, old, new), in atomic_compare_exchange()
172 (AcqRel, Relaxed) => intrinsics::atomic_cxchg_acqrel_relaxed(dst, old, new), in atomic_compare_exchange()
[all …]
|
| /external/rust/android-crates-io/crates/rayon/tests/ |
| D | sort-panic-safe.rs | 8 use std::sync::atomic::Ordering::Relaxed;
38 VERSIONS.fetch_add(2, Relaxed); in partial_cmp()
51 DROP_COUNTS[self.id].fetch_add(1, Relaxed); in drop()
52 VERSIONS.fetch_sub(self.version.get(), Relaxed); in drop()
64 count.fetch_add(1, Relaxed);
68 let mut panic_countdown = count.load(Relaxed);
78 VERSIONS.store(0, Relaxed);
80 DROP_COUNTS[i].store(0, Relaxed);
88 if panic_countdown.fetch_sub(1, Relaxed) == 1 {
100 let count = c.load(Relaxed);
[all …]
|
| /external/rust/android-crates-io/crates/itertools/src/ |
| D | next_array.rs | 196 DROPPED.fetch_add(1, Ordering::Relaxed); in tracked_drop()
202 assert_eq!(DROPPED.load(Ordering::Relaxed), 0); in tracked_drop()
204 assert_eq!(DROPPED.load(Ordering::Relaxed), 0); in tracked_drop()
211 assert_eq!(DROPPED.load(Ordering::Relaxed), 0); in tracked_drop()
213 assert_eq!(DROPPED.swap(0, Ordering::Relaxed), 1); in tracked_drop()
221 assert_eq!(DROPPED.swap(0, Ordering::Relaxed), 2); in tracked_drop()
223 assert_eq!(DROPPED.load(Ordering::Relaxed), 0); in tracked_drop()
237 assert_eq!(DROPPED.load(Ordering::Relaxed), 1); in tracked_drop()
241 assert_eq!(DROPPED.swap(0, Ordering::Relaxed), 3); in tracked_drop()
255 assert_eq!(DROPPED.load(Ordering::Relaxed), 1); in tracked_drop()
[all …]
|
| /external/rust/android-crates-io/crates/rustix/src/backend/linux_raw/ |
| D | vdso_wrappers.rs | 28 use core::sync::atomic::Ordering::Relaxed;
62 let callee = match transmute(CLOCK_GETTIME.load(Relaxed)) { in clock_gettime()
101 let callee = match transmute(CLOCK_GETTIME.load(Relaxed)) { in clock_gettime_dynamic()
128 let callee = match transmute(GETCPU.load(Relaxed)) { in sched_getcpu()
140 use super::{transmute, ArgReg, Relaxed, RetReg, SyscallNumber, A0, A1, A2, A3, A4, A5, R0};
145 let callee = match transmute(super::SYSCALL.load(Relaxed)) { in syscall0()
157 let callee = match transmute(super::SYSCALL.load(Relaxed)) { in syscall1()
169 let callee = match transmute(super::SYSCALL.load(Relaxed)) { in syscall1_noreturn()
182 let callee = match transmute(super::SYSCALL.load(Relaxed)) { in syscall2()
196 let callee = match transmute(super::SYSCALL.load(Relaxed)) { in syscall3()
[all …]
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | rt_threaded_alt.rs | 15 use std::sync::atomic::Ordering::Relaxed;
55 let num = cnt.fetch_add(1, Relaxed) + 1; in many_oneshot_futures()
254 self.0.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
264 a.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
267 b.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
278 let a = num_inc.load(Relaxed); in drop_threadpool_drops_futures()
282 let b = num_dec.load(Relaxed); in drop_threadpool_drops_futures()
286 let c = num_drop.load(Relaxed); in drop_threadpool_drops_futures()
303 after_inner.clone().fetch_add(1, Ordering::Relaxed); in start_stop_callbacks_called()
306 before_inner.clone().fetch_add(1, Ordering::Relaxed); in start_stop_callbacks_called()
[all …]
|
| D | rt_threaded.rs | 14 use std::sync::atomic::Ordering::Relaxed;
54 let num = cnt.fetch_add(1, Relaxed) + 1; in many_oneshot_futures()
254 self.0.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
264 a.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
267 b.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
278 let a = num_inc.load(Relaxed); in drop_threadpool_drops_futures()
282 let b = num_dec.load(Relaxed); in drop_threadpool_drops_futures()
286 let c = num_drop.load(Relaxed); in drop_threadpool_drops_futures()
303 after_inner.clone().fetch_add(1, Ordering::Relaxed); in start_stop_callbacks_called()
306 before_inner.clone().fetch_add(1, Ordering::Relaxed); in start_stop_callbacks_called()
[all …]
|
| /external/rust/android-crates-io/crates/portable-atomic/src/imp/ |
| D | riscv.rs | 115 Ordering::Relaxed => op!(""),
236 Ordering::Relaxed => atomic_load!("", ""),
266 Ordering::Relaxed => atomic_store!("", ""),
644 assert_eq!(a.load(Ordering::Relaxed), x.wrapping_add(y));
647 assert_eq!(a.load(Ordering::Relaxed), y.wrapping_add(x));
655 assert_eq!(a.load(Ordering::Relaxed), x.wrapping_sub(y));
658 assert_eq!(a.load(Ordering::Relaxed), y.wrapping_sub(x));
666 assert_eq!(a.load(Ordering::Relaxed), x & y);
669 assert_eq!(a.load(Ordering::Relaxed), y & x);
677 assert_eq!(a.load(Ordering::Relaxed), x | y);
[all …]
|
| /external/crosvm/cros_async/src/sync/ |
| D | mu.rs | 214 .compare_exchange_weak(0, LOCKED, Ordering::Acquire, Ordering::Relaxed) in lock()
228 Ordering::Relaxed, in lock()
242 .compare_exchange_weak(0, READ_LOCK, Ordering::Acquire, Ordering::Relaxed) in read_lock()
253 Ordering::Relaxed, in read_lock()
274 let oldstate = self.state.load(Ordering::Relaxed); in lock_slow()
284 Ordering::Relaxed, in lock_slow()
302 Ordering::Relaxed, in lock_slow()
342 Ordering::Relaxed, in lock_slow()
444 let oldstate = self.state.load(Ordering::Relaxed); in unlock_slow()
457 Ordering::Relaxed, in unlock_slow()
[all …]
|
| /external/rust/android-crates-io/crates/parking_lot_core/src/ |
| D | word_lock.rs | 92 .compare_exchange_weak(0, LOCKED_BIT, Ordering::Acquire, Ordering::Relaxed) in lock()
113 let mut state = self.state.load(Ordering::Relaxed); in lock_slow()
121 Ordering::Relaxed, in lock_slow()
131 state = self.state.load(Ordering::Relaxed); in lock_slow()
158 Ordering::Relaxed, in lock_slow()
172 self.state.load(Ordering::Relaxed) in lock_slow()
179 let mut state = self.state.load(Ordering::Relaxed); in unlock_slow()
193 Ordering::Relaxed, in unlock_slow()
234 Ordering::Relaxed, in unlock_slow()
253 Ordering::Relaxed, in unlock_slow()
|
| /external/rust/android-crates-io/crates/hashbrown/src/external_trait_impls/rayon/ |
| D | map.rs | 482 counter.fetch_add(1, Ordering::Relaxed); in new()
490 self.counter.fetch_sub(1, Ordering::Relaxed); in drop()
525 assert_eq!(key.load(Ordering::Relaxed), 0); in test_into_iter_drops()
526 assert_eq!(value.load(Ordering::Relaxed), 0); in test_into_iter_drops()
534 assert_eq!(key.load(Ordering::Relaxed), 100); in test_into_iter_drops()
535 assert_eq!(value.load(Ordering::Relaxed), 100); in test_into_iter_drops()
543 assert_eq!(key.load(Ordering::Relaxed), 100); in test_into_iter_drops()
544 assert_eq!(value.load(Ordering::Relaxed), 100); in test_into_iter_drops()
550 assert_eq!(key.load(Ordering::Relaxed), 100); in test_into_iter_drops()
551 assert_eq!(value.load(Ordering::Relaxed), 100); in test_into_iter_drops()
[all …]
|
| /external/rust/android-crates-io/extra_versions/crates/hashbrown/src/external_trait_impls/rayon/ |
| D | map.rs | 492 counter.fetch_add(1, Ordering::Relaxed); in new()
500 self.counter.fetch_sub(1, Ordering::Relaxed); in drop()
535 assert_eq!(key.load(Ordering::Relaxed), 0); in test_into_iter_drops()
536 assert_eq!(value.load(Ordering::Relaxed), 0); in test_into_iter_drops()
544 assert_eq!(key.load(Ordering::Relaxed), 100); in test_into_iter_drops()
545 assert_eq!(value.load(Ordering::Relaxed), 100); in test_into_iter_drops()
553 assert_eq!(key.load(Ordering::Relaxed), 100); in test_into_iter_drops()
554 assert_eq!(value.load(Ordering::Relaxed), 100); in test_into_iter_drops()
560 assert_eq!(key.load(Ordering::Relaxed), 100); in test_into_iter_drops()
561 assert_eq!(value.load(Ordering::Relaxed), 100); in test_into_iter_drops()
[all …]
|