| /external/rust/crates/futures-executor/src/ |
| D | unpark_mutex.rs | 65 match self.status.compare_exchange(WAITING, POLLING, in notify()
86 match self.status.compare_exchange(POLLING, REPOLL, in notify()
120 match self.status.compare_exchange(POLLING, WAITING, SeqCst, SeqCst) { in wait()
|
| /external/rust/crates/tokio/src/park/ |
| D | thread.rs | 85 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
94 match self.state.compare_exchange(EMPTY, PARKED, SeqCst, SeqCst) { in park()
116 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
132 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park_timeout()
144 match self.state.compare_exchange(EMPTY, PARKED, SeqCst, SeqCst) { in park_timeout()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | park.rs | 127 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
149 .compare_exchange(EMPTY, PARKED_CONDVAR, SeqCst, SeqCst) in park_condvar()
172 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park_condvar()
186 .compare_exchange(EMPTY, PARKED_DRIVER, SeqCst, SeqCst) in park_driver()
|
| D | queue.rs | 200 .compare_exchange( in push_overflow()
283 .compare_exchange(head, next, AcqRel, Acquire); in pop()
383 .compare_exchange(prev_packed, next_packed, AcqRel, Acquire); in steal_into2()
429 .compare_exchange(prev_packed, next_packed, AcqRel, Acquire); in steal_into2()
|
| /external/rust/crates/crossbeam-epoch/src/sync/ |
| D | queue.rs | 79 .compare_exchange(onto, next, Release, Relaxed, guard); in push_internal()
85 .compare_exchange(Shared::null(), new, Release, Relaxed, guard) in push_internal()
91 .compare_exchange(onto, new, Release, Relaxed, guard); in push_internal()
125 .compare_exchange(head, next, Release, Relaxed, guard) in pop_internal()
132 .compare_exchange(tail, next, Release, Relaxed, guard); in pop_internal()
158 .compare_exchange(head, next, Release, Relaxed, guard) in pop_if_internal()
165 .compare_exchange(tail, next, Release, Relaxed, guard); in pop_if_internal()
|
| /external/rust/crates/crossbeam-utils/tests/ |
| D | atomic_cell.rs | 183 assert_eq!(a.compare_exchange(Foo(0), Foo(5)), Ok(Foo(100))); in modular_u8()
185 assert_eq!(a.compare_exchange(Foo(10), Foo(15)), Ok(Foo(100))); in modular_u8()
207 assert_eq!(a.compare_exchange(Foo(0), Foo(5)), Ok(Foo(100))); in modular_usize()
209 assert_eq!(a.compare_exchange(Foo(10), Foo(15)), Ok(Foo(100))); in modular_usize()
226 assert!(cell.compare_exchange(prev, next).is_ok()); in garbage_padding()
|
| /external/rust/crates/once_cell/src/ |
| D | race.rs | 41 self.inner.compare_exchange(0, value.get(), Ordering::AcqRel, Ordering::Acquire); in set()
82 self.inner.compare_exchange(0, val, Ordering::AcqRel, Ordering::Acquire); in get_or_try_init()
214 let exchange = self.inner.compare_exchange( in set()
260 let exchange = self.inner.compare_exchange( in get_or_try_init()
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 319 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
335 match self.state.compare_exchange(EMPTY, PARKED, SeqCst, SeqCst) { in park()
374 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
|
| /external/rust/crates/rayon-core/src/ |
| D | latch.rs | 93 .compare_exchange(UNSET, SLEEPY, Ordering::SeqCst, Ordering::Relaxed) in get_sleepy()
103 .compare_exchange(SLEEPY, SLEEPING, Ordering::SeqCst, Ordering::Relaxed) in fall_asleep()
115 .compare_exchange(SLEEPING, UNSET, Ordering::SeqCst, Ordering::Relaxed); in wake_up()
|
| /external/rust/crates/tokio/src/loom/std/ |
| D | atomic_u64.rs | 48 pub(crate) fn compare_exchange( in compare_exchange() method
72 self.compare_exchange(current, new, success, failure) in compare_exchange_weak()
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 327 let res = self.state.compare_exchange(curr, new, SeqCst, SeqCst); in notify_one()
467 let res = state.compare_exchange(curr, set_state(curr, NOTIFIED), SeqCst, SeqCst); in notify_locked()
542 let res = notify.state.compare_exchange( in poll()
574 let res = notify.state.compare_exchange( in poll()
591 let res = notify.state.compare_exchange( in poll()
|
| D | batch_semaphore.rs | 225 match self.permits.compare_exchange(curr, next, AcqRel, Acquire) { in try_acquire()
343 match self.permits.compare_exchange(curr, next, AcqRel, Acquire) { in poll_acquire()
424 match self.state.compare_exchange(curr, next, AcqRel, Acquire) { in assign_permits()
|
| /external/rust/crates/crossbeam-epoch/src/ |
| D | epoch.rs | 118 pub(crate) fn compare_exchange( in compare_exchange() method
127 .compare_exchange(current.data, new.data, success, failure) in compare_exchange()
|
| /external/rust/crates/futures-core/src/task/__internal/ |
| D | atomic_waker.rs | 264 .compare_exchange(WAITING, REGISTERING, Acquire, Acquire) in register()
282 let res = self.state.compare_exchange( in register()
|
| /external/rust/crates/tokio/src/sync/task/ |
| D | atomic_waker.rs | 176 .compare_exchange(WAITING, REGISTERING, Acquire, Acquire) in do_register()
193 .compare_exchange(REGISTERING, WAITING, AcqRel, Acquire); in do_register()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | tick.rs | 49 .compare_exchange(delivery_time, now + self.duration) in try_recv()
75 .compare_exchange(delivery_time, delivery_time.max(now) + self.duration) in recv()
|
| /external/rust/crates/crossbeam-utils/benches/ |
| D | atomic_cell.rs | 35 let _ = a.compare_exchange(i, i.wrapping_add(1)); in compare_exchange_u8()
109 let _ = a.compare_exchange(i, i.wrapping_add(1)); in compare_exchange_usize()
|
| /external/rust/crates/crossbeam-epoch/tests/ |
| D | loom.rs | 87 .compare_exchange(head, n, Release, Relaxed, &guard) in treiber_stack()
109 .compare_exchange(head, next, Relaxed, Relaxed, &guard) in treiber_stack()
|
| /external/rust/crates/grpcio/src/task/ |
| D | executor.rs | 190 .compare_exchange(init_state, POLLING, Ordering::AcqRel, Ordering::Acquire) in poll()
212 match task.state.compare_exchange( in poll()
|
| /external/rust/crates/parking_lot/src/ |
| D | raw_mutex.rs | 104 .compare_exchange(LOCKED_BIT, 0, Ordering::Release, Ordering::Relaxed) in unlock()
125 .compare_exchange(LOCKED_BIT, 0, Ordering::Release, Ordering::Relaxed) in unlock_fair()
|
| /external/rust/crates/crossbeam-epoch/ |
| D | CHANGELOG.md | 7 - Add `Atomic::compare_exchange` and `Atomic::compare_exchange_weak`. (#628)
8 …::compare_and_set` and `Atomic::compare_and_set_weak`. Use `Atomic::compare_exchange` or `Atomic::…
|
| /external/rust/crates/crossbeam-utils/ |
| D | CHANGELOG.md | 7 - Deprecate `AtomicCell::compare_and_swap`. Use `AtomicCell::compare_exchange` instead. (#619)
49 - Fix a bug in `AtomicCell::compare_exchange()` and `AtomicCell::compare_and_swap()`.
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | block.rs | 268 .compare_exchange(ptr::null_mut(), block.as_ptr(), success, failure) in try_push()
313 .compare_exchange(ptr::null_mut(), new_block.as_ptr(), AcqRel, Acquire) in grow()
|
| /external/llvm-project/libcxxabi/src/ |
| D | cxa_guard_impl.h | 136 …bool compare_exchange(IntType *expected, IntType desired, MemoryOrder ord_success, MemoryOrder ord… in compare_exchange() function
442 if (init_byte.compare_exchange(&last_val, PENDING_BIT, std::_AO_Acq_Rel, in acquire_init_byte()
465 if (!init_byte.compare_exchange(&last_val, PENDING_BIT | WAITING_BIT, in acquire_init_byte()
|
| /external/rust/crates/spin/src/ |
| D | rw_lock.rs | 266 if compare_exchange( in try_write_internal()
440 if compare_exchange( in try_upgrade_internal()
708 fn compare_exchange( in compare_exchange() function
717 atomic.compare_exchange(current, new, success, failure) in compare_exchange()
|