Searched refs:cur_thread_count (Results 1 – 2 of 2) sorted by relevance
206 size_t cur_thread_count = in Enqueue() local211 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 …]
265 size_t cur_thread_count = in Enqueue() local270 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 …]