Searched refs:pending_threads (Results 1 – 2 of 2) sorted by relevance
| /art/runtime/ |
| D | thread_list.cc | 541 AtomicInteger pending_threads; in SuspendAllInternal() local
556 pending_threads.StoreRelaxed(list_.size() - num_ignored); in SuspendAllInternal()
564 if (LIKELY(thread->ModifySuspendCount(self, +1, &pending_threads, debug_suspend))) { in SuspendAllInternal()
587 thread->ClearSuspendBarrier(&pending_threads); in SuspendAllInternal()
588 pending_threads.FetchAndSubSequentiallyConsistent(1); in SuspendAllInternal()
600 int32_t cur_val = pending_threads.LoadRelaxed(); in SuspendAllInternal()
603 if (futex(pending_threads.Address(), FUTEX_WAIT, cur_val, &wait_timeout, nullptr, 0) != 0) { in SuspendAllInternal()
613 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()
|