Home
last modified time | relevance | path

Searched refs:cur_thread_count (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dexecutor.cc206 size_t cur_thread_count = in Enqueue() local
211 if (cur_thread_count == 0) { in Enqueue()
226 cur_thread_count)]; in Enqueue()
253 ts = &thd_state_[(idx + 1) % cur_thread_count]; in Enqueue()
291 cur_thread_count < max_threads_ && !ts->shutdown; in Enqueue()
300 cur_thread_count = static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
301 if (cur_thread_count < max_threads_) { in Enqueue()
304 gpr_atm_rel_store(&num_threads_, cur_thread_count + 1); in Enqueue()
306 thd_state_[cur_thread_count].thd = grpc_core::Thread( in Enqueue()
307 name_, &GrpcExecutor::ThreadMain, &thd_state_[cur_thread_count]); in Enqueue()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dexecutor.cc265 size_t cur_thread_count = in Enqueue() local
270 if (cur_thread_count == 0) { in Enqueue()
290 cur_thread_count)]; in Enqueue()
317 ts = &thd_state_[(idx + 1) % cur_thread_count]; in Enqueue()
355 cur_thread_count < max_threads_ && !ts->shutdown; in Enqueue()
364 cur_thread_count = static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
365 if (cur_thread_count < max_threads_) { in Enqueue()
368 gpr_atm_rel_store(&num_threads_, cur_thread_count + 1); in Enqueue()
370 thd_state_[cur_thread_count].thd = grpc_core::Thread( in Enqueue()
371 name_, &Executor::ThreadMain, &thd_state_[cur_thread_count]); in Enqueue()
[all …]