Lines Matching defs:cur_state

439       int32_t cur_state = state_.LoadRelaxed();
440 if (LIKELY(cur_state == 0)) {
442 done = state_.CompareAndSetWeakAcquire(0 /* cur_state */, 1 /* new state */);
485 int32_t cur_state = state_.LoadRelaxed();
486 if (cur_state == 0) {
488 done = state_.CompareAndSetWeakAcquire(0 /* cur_state */, 1 /* new state */);
542 int32_t cur_state = state_.LoadRelaxed();
543 if (LIKELY(cur_state == 1)) {
550 done = state_.CompareAndSetWeakSequentiallyConsistent(cur_state, 0 /* new state */);
560 LOG(FATAL) << "Unexpected state_ in unlock " << cur_state << " for " << name_;
566 cur_state, name_).c_str());
640 int32_t cur_state = state_.LoadRelaxed();
641 if (LIKELY(cur_state == 0)) {
643 done = state_.CompareAndSetWeakAcquire(0 /* cur_state*/, -1 /* new state */);
651 if (futex(state_.Address(), FUTEX_WAIT, cur_state, nullptr, nullptr, 0) != 0) {
679 int32_t cur_state = state_.LoadRelaxed();
680 if (LIKELY(cur_state == -1)) {
687 done = state_.CompareAndSetWeakSequentiallyConsistent(-1 /* cur_state*/, 0 /* new state */);
696 LOG(FATAL) << "Unexpected state_:" << cur_state << " for " << name_;
713 int32_t cur_state = state_.LoadRelaxed();
714 if (cur_state == 0) {
716 done = state_.CompareAndSetWeakAcquire(0 /* cur_state */, -1 /* new state */);
730 if (futex(state_.Address(), FUTEX_WAIT, cur_state, &rel_ts, nullptr, 0) != 0) {
764 void ReaderWriterMutex::HandleSharedLockContention(Thread* self, int32_t cur_state) {
771 if (futex(state_.Address(), FUTEX_WAIT, cur_state, nullptr, nullptr, 0) != 0) {
785 int32_t cur_state = state_.LoadRelaxed();
786 if (cur_state >= 0) {
788 done = state_.CompareAndSetWeakAcquire(cur_state, cur_state + 1);