Searched refs:cur_state (Results 1 – 3 of 3) sorted by relevance
131 int32_t cur_state = state_.LoadRelaxed(); in SharedLock() local132 if (LIKELY(cur_state >= 0)) { in SharedLock()134 done = state_.CompareExchangeWeakAcquire(cur_state, cur_state + 1); in SharedLock()136 HandleSharedLockContention(self, cur_state); in SharedLock()155 int32_t cur_state = state_.LoadRelaxed(); in SharedUnlock() local156 if (LIKELY(cur_state > 0)) { in SharedUnlock()161 done = state_.CompareExchangeWeakSequentiallyConsistent(cur_state, cur_state - 1); in SharedUnlock()162 if (done && (cur_state - 1) == 0) { // Weak CAS may fail spuriously. in SharedUnlock()170 LOG(FATAL) << "Unexpected state_:" << cur_state << " for " << name_; in SharedUnlock()
368 int32_t cur_state = state_.LoadRelaxed(); in ExclusiveLock() local369 if (LIKELY(cur_state == 0)) { in ExclusiveLock()411 int32_t cur_state = state_.LoadRelaxed(); in ExclusiveTryLock() local412 if (cur_state == 0) { in ExclusiveTryLock()468 int32_t cur_state = state_.LoadRelaxed(); in ExclusiveUnlock() local469 if (LIKELY(cur_state == 1)) { in ExclusiveUnlock()476 done = state_.CompareExchangeWeakSequentiallyConsistent(cur_state, 0 /* new state */); in ExclusiveUnlock()486 LOG(FATAL) << "Unexpected state_ in unlock " << cur_state << " for " << name_; in ExclusiveUnlock()490 cur_state, name_).c_str()); in ExclusiveUnlock()555 int32_t cur_state = state_.LoadRelaxed(); in ExclusiveLock() local[all …]
392 void HandleSharedLockContention(Thread* self, int32_t cur_state);