Lines Matching refs:state_
545 , state_(0), num_pending_readers_(0), num_pending_writers_(0) in ReaderWriterMutex()
556 CHECK_EQ(state_.load(std::memory_order_relaxed), 0); in ~ReaderWriterMutex()
578 int32_t cur_state = state_.load(std::memory_order_relaxed); in ExclusiveLock()
581 done = state_.CompareAndSetWeakAcquire(0 /* cur_state*/, -1 /* new state */); in ExclusiveLock()
589 if (futex(state_.Address(), FUTEX_WAIT_PRIVATE, cur_state, nullptr, nullptr, 0) != 0) { in ExclusiveLock()
599 DCHECK_EQ(state_.load(std::memory_order_relaxed), -1); in ExclusiveLock()
617 int32_t cur_state = state_.load(std::memory_order_relaxed); in ExclusiveUnlock()
625 done = state_.CompareAndSetWeakSequentiallyConsistent(-1 /* cur_state*/, 0 /* new state */); in ExclusiveUnlock()
630 futex(state_.Address(), FUTEX_WAKE_PRIVATE, kWakeAll, nullptr, nullptr, 0); in ExclusiveUnlock()
651 int32_t cur_state = state_.load(std::memory_order_relaxed); in ExclusiveLockWithTimeout()
654 done = state_.CompareAndSetWeakAcquire(0 /* cur_state */, -1 /* new state */); in ExclusiveLockWithTimeout()
668 if (futex(state_.Address(), FUTEX_WAIT_PRIVATE, cur_state, &rel_ts, nullptr, 0) != 0) { in ExclusiveLockWithTimeout()
709 if (futex(state_.Address(), FUTEX_WAIT_PRIVATE, cur_state, nullptr, nullptr, 0) != 0) { in HandleSharedLockContention()
723 int32_t cur_state = state_.load(std::memory_order_relaxed); in SharedTryLock()
726 done = state_.CompareAndSetWeakAcquire(cur_state, cur_state + 1); in SharedTryLock()
763 << " state=" << state_.load(std::memory_order_seq_cst) in Dump()
787 futex(state_.Address(), FUTEX_WAKE_PRIVATE, kWakeAll, nullptr, nullptr, 0); in WakeupToRespondToEmptyCheckpoint()