Searched refs:pending_threads (Results 1 – 2 of 2) sorted by relevance
| /art/runtime/ |
| D | thread_list.cc | 682 AtomicInteger pending_threads; in SuspendAllInternal() local
695 pending_threads.store(list_.size() - num_ignored, std::memory_order_relaxed); in SuspendAllInternal()
702 bool updated = thread->ModifySuspendCount(self, +1, &pending_threads, reason); in SuspendAllInternal()
710 thread->ClearSuspendBarrier(&pending_threads); in SuspendAllInternal()
711 pending_threads.fetch_sub(1, std::memory_order_seq_cst); in SuspendAllInternal()
724 int32_t cur_val = pending_threads.load(std::memory_order_relaxed); in SuspendAllInternal()
727 if (futex(pending_threads.Address(), FUTEX_WAIT_PRIVATE, cur_val, &wait_timeout, nullptr, 0) in SuspendAllInternal()
|
| D | thread.cc | 1516 AtomicInteger* pending_threads = pass_barriers[i]; in PassActiveSuspendBarriers() local
1517 if (pending_threads != nullptr) { in PassActiveSuspendBarriers()
1520 int32_t cur_val = pending_threads->load(std::memory_order_relaxed); in PassActiveSuspendBarriers()
1523 done = pending_threads->CompareAndSetWeakRelaxed(cur_val, cur_val - 1); in PassActiveSuspendBarriers()
1526 futex(pending_threads->Address(), FUTEX_WAKE_PRIVATE, INT_MAX, nullptr, nullptr, 0); in PassActiveSuspendBarriers()
|