Searched refs:GrpcExecutor (Results 1 – 2 of 2) sorted by relevance
52 GrpcExecutor::GrpcExecutor(const char* name) : name_(name) { in GrpcExecutor() function in GrpcExecutor58 void GrpcExecutor::Init() { SetThreading(true); } in Init()60 size_t GrpcExecutor::RunClosures(const char* executor_name, in RunClosures()85 bool GrpcExecutor::IsThreaded() const { in IsThreaded()89 void GrpcExecutor::SetThreading(bool threading) { in SetThreading()115 grpc_core::Thread(name_, &GrpcExecutor::ThreadMain, &thd_state_[0]); in SetThreading()156 void GrpcExecutor::Shutdown() { SetThreading(false); } in Shutdown()158 void GrpcExecutor::ThreadMain(void* arg) { in ThreadMain()195 void GrpcExecutor::Enqueue(grpc_closure* closure, grpc_error* error, in Enqueue()307 name_, &GrpcExecutor::ThreadMain, &thd_state_[cur_thread_count]); in Enqueue()[all …]
46 class GrpcExecutor {48 GrpcExecutor(const char* executor_name);