Searched refs:pending_threads (Results 1 – 2 of 2) sorted by relevance
| /art/runtime/ |
| D | thread_list.cc | 693 AtomicInteger pending_threads; in SuspendAllInternal() local
709 pending_threads.store(list_.size() - num_ignored, std::memory_order_relaxed); in SuspendAllInternal()
716 bool updated = thread->ModifySuspendCount(self, +1, &pending_threads, reason); in SuspendAllInternal()
724 thread->ClearSuspendBarrier(&pending_threads); in SuspendAllInternal()
725 pending_threads.fetch_sub(1, std::memory_order_seq_cst); in SuspendAllInternal()
738 int32_t cur_val = pending_threads.load(std::memory_order_relaxed); in SuspendAllInternal()
741 if (futex(pending_threads.Address(), FUTEX_WAIT_PRIVATE, cur_val, &wait_timeout, nullptr, 0) in SuspendAllInternal()
|
| D | thread.cc | 1498 AtomicInteger* pending_threads = pass_barriers[i]; in PassActiveSuspendBarriers() local
1499 if (pending_threads != nullptr) { in PassActiveSuspendBarriers()
1502 int32_t cur_val = pending_threads->load(std::memory_order_relaxed); in PassActiveSuspendBarriers()
1505 done = pending_threads->CompareAndSetWeakRelaxed(cur_val, cur_val - 1); in PassActiveSuspendBarriers()
1508 futex(pending_threads->Address(), FUTEX_WAKE_PRIVATE, INT_MAX, nullptr, nullptr, 0); in PassActiveSuspendBarriers()
|