| /external/tensorflow/tensorflow/core/platform/ |
| D | blocking_counter.h | 49 unsigned int v = state_.fetch_or(1, std::memory_order_acq_rel); in Wait()
59 unsigned int v = state_.fetch_or(1, std::memory_order_acq_rel); in WaitFor()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | block.rs | 160 self.ready_slots.fetch_or(TX_CLOSED, Release); in tx_close()
197 self.ready_slots.fetch_or(RELEASED, Release); in tx_release()
203 self.ready_slots.fetch_or(mask, Release); in set_ready()
|
| /external/rust/crates/async-task/src/ |
| D | header.rs | 48 let state = self.state.fetch_or(NOTIFYING, Ordering::AcqRel); in take()
78 let mut state = self.state.fetch_or(0, Ordering::Acquire); in register()
|
| /external/rust/crates/crossbeam-utils/src/atomic/ |
| D | atomic_cell.rs | 361 pub fn fetch_or(&self, val: $t) -> $t {
364 a.fetch_or(val as usize, Ordering::AcqRel) as $t
474 pub fn fetch_or(&self, val: $t) -> $t {
476 a.fetch_or(val, Ordering::AcqRel)
571 pub fn fetch_or(&self, val: bool) -> bool { in fetch_or() method
573 a.fetch_or(val, Ordering::AcqRel) in fetch_or()
|
| /external/rust/crates/tokio/src/sync/ |
| D | oneshot.rs | 858 let val = cell.fetch_or(VALUE_SENT, AcqRel); in set_complete()
867 let val = cell.fetch_or(RX_TASK_SET, AcqRel); in set_rx_task()
883 let val = cell.fetch_or(CLOSED, Acquire); in set_closed()
888 let val = cell.fetch_or(TX_TASK_SET, AcqRel); in set_tx_task()
|
| /external/perfetto/src/tracing/ |
| D | track_event_category_registry.cc | 50 state_storage_[category_index].fetch_or( in EnableCategoryForInstance()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | list.rs | 105 && slot.state.fetch_or(DESTROY, Ordering::AcqRel) & READ == 0 in destroy()
290 slot.state.fetch_or(WRITE, Ordering::Release); in write()
400 } else if slot.state.fetch_or(READ, Ordering::AcqRel) & DESTROY != 0 { in read()
533 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect()
|
| /external/rust/crates/tokio/src/loom/std/ |
| D | atomic_u64.rs | 41 pub(crate) fn fetch_or(&self, val: u64, _: Ordering) -> u64 { in fetch_or() method
|
| /external/crosvm/devices/src/virtio/ |
| D | interrupt.rs | 61 .fetch_or(interrupt_status_mask as usize, Ordering::SeqCst) in signal()
|
| /external/rust/crates/futures-core/src/task/__internal/ |
| D | atomic_waker.rs | 375 match self.state.fetch_or(WAKING, AcqRel) { in take()
|
| /external/rust/crates/tokio/src/sync/task/ |
| D | atomic_waker.rs | 258 match self.state.fetch_or(WAKING, AcqRel) { in take_waker()
|
| /external/rust/crates/futures-util/src/lock/ |
| D | mutex.rs | 103 let old_state = self.state.fetch_or(IS_LOCKED, Ordering::Acquire); in try_lock()
228 … mutex.state.fetch_or(HAS_WAITERS, Ordering::Relaxed); // released by mutex unlock in poll()
|
| /external/webrtc/third_party/abseil-cpp/absl/base/internal/ |
| D | spinlock.cc | 94 lockword_.fetch_or(kSpinLockCooperative, std::memory_order_relaxed); in InitLinkerInitializedAndCooperative()
|
| /external/abseil-cpp/absl/base/internal/ |
| D | spinlock.cc | 94 lockword_.fetch_or(kSpinLockCooperative, std::memory_order_relaxed); in InitLinkerInitializedAndCooperative()
|
| /external/rust/crates/crossbeam-deque/src/ |
| D | deque.rs | 1132 && slot.state.fetch_or(DESTROY, Ordering::AcqRel) & READ == 0 in destroy()
1274 slot.state.fetch_or(WRITE, Ordering::Release); in push()
1370 … if (offset + 1 == BLOCK_CAP) || (slot.state.fetch_or(READ, Ordering::AcqRel) & DESTROY != 0) { in steal()
1527 if slot.state.fetch_or(READ, Ordering::AcqRel) & DESTROY != 0 { in steal_batch()
1691 if slot.state.fetch_or(READ, Ordering::AcqRel) & DESTROY != 0 { in steal_batch_and_pop()
|
| /external/rust/crates/parking_lot/src/ |
| D | raw_mutex.rs | 206 self.state.fetch_or(PARKED_BIT, Ordering::Relaxed); in mark_parked()
|
| /external/libcxx/include/ |
| D | atomic | 174 fetch_or(integral op, memory_order m = memory_order_seq_cst) volatile noexcept;
175 integral fetch_or(integral op, memory_order m = memory_order_seq_cst) noexcept;
1031 _Tp fetch_or(_Tp __op, memory_order __m = memory_order_seq_cst) volatile _NOEXCEPT
1034 _Tp fetch_or(_Tp __op, memory_order __m = memory_order_seq_cst) _NOEXCEPT
1072 _Tp operator|=(_Tp __op) volatile _NOEXCEPT {return fetch_or(__op) | __op;}
1074 _Tp operator|=(_Tp __op) _NOEXCEPT {return fetch_or(__op) | __op;}
1625 return __o->fetch_or(__op);
1637 return __o->fetch_or(__op);
1651 return __o->fetch_or(__op, __m);
1663 return __o->fetch_or(__op, __m);
|
| /external/rust/crates/async-trait/tests/ |
| D | test.rs | 1184 flag.fetch_or(true, Ordering::AcqRel); in async_trait()
1189 flag.fetch_or(true, Ordering::AcqRel); in standalone()
1200 flag.fetch_or(true, Ordering::AcqRel); in async_trait()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | state.rs | 176 let prev = Snapshot(self.val.fetch_or(NOTIFIED, AcqRel)); in transition_to_notified()
|
| /external/openscreen/third_party/abseil/src/absl/container/internal/ |
| D | hashtablez_sampler.cc | 237 info->hashes_bitwise_or.fetch_or(hash, std::memory_order_relaxed); in RecordInsertSlow()
|
| /external/libtextclassifier/abseil-cpp/absl/container/internal/ |
| D | hashtablez_sampler.cc | 237 info->hashes_bitwise_or.fetch_or(hash, std::memory_order_relaxed); in RecordInsertSlow()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/container/internal/ |
| D | hashtablez_sampler.cc | 237 info->hashes_bitwise_or.fetch_or(hash, std::memory_order_relaxed); in RecordInsertSlow()
|
| /external/webrtc/third_party/abseil-cpp/absl/container/internal/ |
| D | hashtablez_sampler.cc | 236 info->hashes_bitwise_or.fetch_or(hash, std::memory_order_relaxed); in RecordInsertSlow()
|
| /external/libchrome/base/android/orderfile/ |
| D | orderfile_instrumentation.cc | 153 auto before = element->fetch_or(mask, std::memory_order_relaxed); in RecordAddress()
|
| /external/angle/third_party/abseil-cpp/absl/container/internal/ |
| D | hashtablez_sampler.cc | 240 info->hashes_bitwise_or.fetch_or(hash, std::memory_order_relaxed); in RecordInsertSlow()
|