Home
last modified time | relevance | path

Searched refs:BlockUntilThreadCount (Results 1 – 8 of 8) sorted by relevance

/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/thread_pool/
Doriginal_thread_pool.cc151 state_->thread_count.BlockUntilThreadCount( in Quiesce()
221 void OriginalThreadPool::ThreadCount::BlockUntilThreadCount(int threads, in BlockUntilThreadCount() function in grpc_event_engine::experimental::OriginalThreadPool::ThreadCount
241 state_->thread_count.BlockUntilThreadCount(0, "forking"); in PrepareFork()
Dwork_stealing_thread_pool.cc159 thread_count()->BlockUntilThreadCount(CounterType::kLivingThreadCount, in Quiesce()
199 thread_count()->BlockUntilThreadCount(CounterType::kLivingThreadCount, 0, in PrepareFork()
435 void WorkStealingThreadPool::ThreadCount::BlockUntilThreadCount( in BlockUntilThreadCount() function in grpc_event_engine::experimental::WorkStealingThreadPool::ThreadCount
Doriginal_thread_pool.h95 void BlockUntilThreadCount(int threads, const char* why);
Dwork_stealing_thread_pool.h93 void BlockUntilThreadCount(CounterType counter_type, int desired_threads,
/aosp_15_r20/external/grpc-grpc/src/core/lib/event_engine/thread_pool/
H A Dwork_stealing_thread_pool.cc277 auto threads_were_shut_down = living_thread_count_.BlockUntilThreadCount( in Quiesce()
323 auto threads_were_shut_down = living_thread_count_.BlockUntilThreadCount( in PrepareFork()
H A Dthread_count.cc36 absl::Status LivingThreadCount::BlockUntilThreadCount( in BlockUntilThreadCount() function in grpc_event_engine::experimental::LivingThreadCount
H A Dthread_count.h158 absl::Status BlockUntilThreadCount(size_t desired_threads, const char* why,
/aosp_15_r20/external/grpc-grpc/test/core/event_engine/
H A Dthread_pool_test.cc468 std::ignore = living_thread_count.BlockUntilThreadCount( in TEST_F()
471 std::ignore = living_thread_count.BlockUntilThreadCount( in TEST_F()