Searched refs:pending_threads (Results 1 – 2 of 2) sorted by relevance
| /art/runtime/ |
| D | thread_list.cc | 691 AtomicInteger pending_threads; in SuspendAllInternal() local
704 pending_threads.store(list_.size() - num_ignored, std::memory_order_relaxed); in SuspendAllInternal()
711 bool updated = thread->ModifySuspendCount(self, +1, &pending_threads, reason); in SuspendAllInternal()
719 thread->ClearSuspendBarrier(&pending_threads); in SuspendAllInternal()
720 pending_threads.fetch_sub(1, std::memory_order_seq_cst); in SuspendAllInternal()
733 int32_t cur_val = pending_threads.load(std::memory_order_relaxed); in SuspendAllInternal()
736 if (futex(pending_threads.Address(), FUTEX_WAIT_PRIVATE, cur_val, &wait_timeout, nullptr, 0) in SuspendAllInternal()
|
| D | thread.cc | 1506 AtomicInteger* pending_threads = pass_barriers[i]; in PassActiveSuspendBarriers() local
1507 if (pending_threads != nullptr) { in PassActiveSuspendBarriers()
1510 int32_t cur_val = pending_threads->load(std::memory_order_relaxed); in PassActiveSuspendBarriers()
1513 done = pending_threads->CompareAndSetWeakRelaxed(cur_val, cur_val - 1); in PassActiveSuspendBarriers()
1516 futex(pending_threads->Address(), FUTEX_WAKE_PRIVATE, INT_MAX, nullptr, nullptr, 0); in PassActiveSuspendBarriers()
|