Lines Matching refs:executors

58 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)];  variable
61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
389 if (executors[static_cast<size_t>(ExecutorType::DEFAULT)] != nullptr) { in InitAll()
390 GPR_ASSERT(executors[static_cast<size_t>(ExecutorType::RESOLVER)] != in InitAll()
395 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
397 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
400 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
401 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll()
416 if (executors[static_cast<size_t>(ExecutorType::DEFAULT)] == nullptr) { in ShutdownAll()
417 GPR_ASSERT(executors[static_cast<size_t>(ExecutorType::RESOLVER)] == in ShutdownAll()
422 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Shutdown(); in ShutdownAll()
423 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Shutdown(); in ShutdownAll()
437 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll()
438 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll()
439 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = nullptr; in ShutdownAll()
440 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = nullptr; in ShutdownAll()
447 return executors[static_cast<size_t>(executor_type)]->IsThreaded(); in IsThreaded()
458 executors[i]->SetThreading(enable); in SetThreadingAll()
464 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->SetThreading(enable); in SetThreadingDefault()