Searched refs:cur_val (Results 1 – 2 of 2) sorted by relevance
733 int32_t cur_val = pending_threads.load(std::memory_order_relaxed); in SuspendAllInternal() local734 if (LIKELY(cur_val > 0)) { in SuspendAllInternal()736 if (futex(pending_threads.Address(), FUTEX_WAIT_PRIVATE, cur_val, &wait_timeout, nullptr, 0) in SuspendAllInternal()768 CHECK_EQ(cur_val, 0); in SuspendAllInternal()
1510 int32_t cur_val = pending_threads->load(std::memory_order_relaxed); in PassActiveSuspendBarriers() local1511 CHECK_GT(cur_val, 0) << "Unexpected value for PassActiveSuspendBarriers(): " << cur_val; in PassActiveSuspendBarriers()1513 done = pending_threads->CompareAndSetWeakRelaxed(cur_val, cur_val - 1); in PassActiveSuspendBarriers()1515 if (done && (cur_val - 1) == 0) { // Weak CAS may fail spuriously. in PassActiveSuspendBarriers()