Searched refs:pending_threads (Results 1 – 2 of 2) sorted by relevance
| /art/runtime/ |
| D | thread_list.cc | 546 AtomicInteger pending_threads; in SuspendAllInternal() local
561 pending_threads.StoreRelaxed(list_.size() - num_ignored); in SuspendAllInternal()
569 if (LIKELY(thread->ModifySuspendCount(self, +1, &pending_threads, debug_suspend))) { in SuspendAllInternal()
592 thread->ClearSuspendBarrier(&pending_threads); in SuspendAllInternal()
593 pending_threads.FetchAndSubSequentiallyConsistent(1); in SuspendAllInternal()
605 int32_t cur_val = pending_threads.LoadRelaxed(); in SuspendAllInternal()
608 if (futex(pending_threads.Address(), FUTEX_WAIT, cur_val, &wait_timeout, nullptr, 0) != 0) { in SuspendAllInternal()
618 cur_val = pending_threads.LoadRelaxed(); in SuspendAllInternal()
|
| D | thread.cc | 1080 AtomicInteger* pending_threads = pass_barriers[i]; in PassActiveSuspendBarriers() local
1081 if (pending_threads != nullptr) { in PassActiveSuspendBarriers()
1084 int32_t cur_val = pending_threads->LoadRelaxed(); in PassActiveSuspendBarriers()
1087 done = pending_threads->CompareExchangeWeakRelaxed(cur_val, cur_val - 1); in PassActiveSuspendBarriers()
1090 futex(pending_threads->Address(), FUTEX_WAKE, -1, nullptr, nullptr, 0); in PassActiveSuspendBarriers()
|