Searched refs:ConcurrencyTracker (Results 1 – 9 of 9) sorted by relevance
33 class ConcurrencyTracker {49 ConcurrencyTracker() : m_Outer(false) { in ConcurrencyTracker() function58 ~ConcurrencyTracker() { in ~ConcurrencyTracker()
83 utils::ConcurrencyTracker::Reset();238 while ( ++n < c_Timeout && (int)utils::ConcurrencyTracker::PeakParallelism() < expected_peak ) in WaitUntilConcurrencyPeaks()272 utils::ConcurrencyTracker ct; in operator()
67 while ( utils::ConcurrencyTracker::PeakParallelism() < m_pOwner->m_numThreads ) in operator ()()79 utils::ConcurrencyTracker ct; in Spawn()97 m_barrier.wait( &utils::ConcurrencyTracker::Reset ); in Wait()99 utils::ConcurrencyTracker ct; in Wait()102 if ( utils::ConcurrencyTracker::PeakParallelism() == 1 ) { in Wait()125 utils::ConcurrencyTracker::Reset(); in SharedGroupBodyImpl()280 utils::ConcurrencyTracker::Reset()283 CHECK(utils::ConcurrencyTracker::PeakParallelism() <= g_MaxConcurrency); \297 utils::ConcurrencyTracker ct; in operator ()()425 utils::ConcurrencyTracker ct; in operator ()()[all …]
242 utils::ConcurrencyTracker ct; in operator ()()264 utils::ConcurrencyTracker ct; in operator ()()520 utils::ConcurrencyTracker ct; in operator ()()533 utils::ConcurrencyTracker ct; in operator ()()821 utils::ConcurrencyTracker ct; in operator ()()1197 utils::ConcurrencyTracker ct; in operator ()()1317 utils::ConcurrencyTracker ct; in operator ()()1684 utils::ConcurrencyTracker ct; in operator ()()
369 utils::ConcurrencyTracker ct; in __anon8532fc101102()371 CHECK(utils::ConcurrencyTracker::PeakParallelism() == 1); in __anon8532fc101102()
94 utils::ConcurrencyTracker ct; in WaitAndThrow()105 utils::ConcurrencyTracker ct; in WaitAndThrow()125 utils::ConcurrencyTracker ct; in WaitAndThrow()134 utils::ConcurrencyTracker ct; in WaitAndThrow()147 utils::ConcurrencyTracker ct; in WaitAndThrow()156 utils::ConcurrencyTracker ct; in WaitAndThrow()
298 utils::ConcurrencyTracker ct; in operator()305 CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency, in operator()311 utils::ConcurrencyTracker ct; in operator()313 CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency, in operator()319 utils::ConcurrencyTracker ct; in operator()321 CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency, in operator()327 utils::ConcurrencyTracker ct; in operator()329 CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency, in operator()670 utils::ConcurrencyTracker::Reset(); in test_concurrency()
46 utils::ConcurrencyTracker ct; in operator ()()76 utils::ConcurrencyTracker ct; in TestDeterministicReductionFor()
177 utils::ConcurrencyTracker::Reset();