Lines Matching refs:state_

315   DCHECK_EQ(0, state_.LoadRelaxed());
332 if (state_.LoadRelaxed() != 0) {
365 int32_t cur_state = state_.LoadRelaxed();
368 done = state_.CompareExchangeWeakAcquire(0 /* cur_state */, 1 /* new state */);
373 if (futex(state_.Address(), FUTEX_WAIT, 1, nullptr, nullptr, 0) != 0) {
383 DCHECK_EQ(state_.LoadRelaxed(), 1);
408 int32_t cur_state = state_.LoadRelaxed();
411 done = state_.CompareExchangeWeakAcquire(0 /* cur_state */, 1 /* new state */);
416 DCHECK_EQ(state_.LoadRelaxed(), 1);
465 int32_t cur_state = state_.LoadRelaxed();
473 done = state_.CompareExchangeWeakSequentiallyConsistent(cur_state, 0 /* new state */);
477 futex(state_.Address(), FUTEX_WAKE, 1, nullptr, nullptr, 0);
483 LOG(FATAL) << "Unexpected state_ in unlock " << cur_state << " for " << name_;
486 StringPrintf("Unexpected state_ %d in unlock for %s",
516 , state_(0), num_pending_readers_(0), num_pending_writers_(0)
527 CHECK_EQ(state_.LoadRelaxed(), 0);
552 int32_t cur_state = state_.LoadRelaxed();
555 done = state_.CompareExchangeWeakAcquire(0 /* cur_state*/, -1 /* new state */);
560 if (futex(state_.Address(), FUTEX_WAIT, cur_state, nullptr, nullptr, 0) != 0) {
570 DCHECK_EQ(state_.LoadRelaxed(), -1);
588 int32_t cur_state = state_.LoadRelaxed();
596 done = state_.CompareExchangeWeakSequentiallyConsistent(-1 /* cur_state*/, 0 /* new state */);
601 futex(state_.Address(), FUTEX_WAKE, -1, nullptr, nullptr, 0);
605 LOG(FATAL) << "Unexpected state_:" << cur_state << " for " << name_;
622 int32_t cur_state = state_.LoadRelaxed();
625 done = state_.CompareExchangeWeakAcquire(0 /* cur_state */, -1 /* new state */);
636 if (futex(state_.Address(), FUTEX_WAIT, cur_state, &rel_ts, nullptr, 0) != 0) {
674 if (futex(state_.Address(), FUTEX_WAIT, cur_state, nullptr, nullptr, 0) != 0) {
688 int32_t cur_state = state_.LoadRelaxed();
691 done = state_.CompareExchangeWeakAcquire(cur_state, cur_state + 1);
728 << " state=" << state_.LoadSequentiallyConsistent()
794 guard_.state_.Address(), cur_sequence) != -1;