Searched refs:worker_service_ (Results 1 – 3 of 3) sorted by relevance
81 worker_service_, cq_.get(), \107 worker_service_(worker_service), in GrpcWorkerServiceThread()348 worker_service_, cq_.get(), in EnqueueRecvTensorRequestRaw()360 grpc::WorkerService::AsyncService* const worker_service_; member in tensorflow::__anon880ff86a0111::GrpcWorkerServiceThread372 builder->RegisterService(&worker_service_); in GrpcWorkerService()377 cache_.get(), &worker_service_)); in GrpcWorkerService()409 grpc::WorkerService::AsyncService worker_service_; member in tensorflow::__anon880ff86a0111::GrpcWorkerService
105 delete worker_service_; in ~GrpcServer()231 worker_service_ = NewGrpcWorkerService(worker_impl_.get(), &builder, in Init()385 [this] { worker_service_->HandleRPCsLoop(); })); in Start()
163 AsyncServiceInterface* worker_service_ = nullptr; variable