Home
last modified time | relevance | path

Searched refs:callback_tag (Results 1 – 6 of 6) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc76 GrpcCallTag<GrpcEagerServiceImpl>* callback_tag = in HandleRPCsLoop() local
79 if (callback_tag) { in HandleRPCsLoop()
80 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
Dgrpc_eager_client.cc83 GrpcClientCQTag* callback_tag = static_cast<GrpcClientCQTag*>(tag); in GrpcEagerClientThread() local
84 callback_tag->OnCompleted(ok); in GrpcEagerClientThread()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service.cc123 UntypedCall<GrpcMasterService>::Tag* callback_tag = in HandleRPCsLoop() local
125 if (callback_tag) { in HandleRPCsLoop()
126 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
Dgrpc_worker_cache.cc135 GrpcClientCQTag* callback_tag = static_cast<GrpcClientCQTag*>(tag); in GrpcWorkerCacheThread() local
136 callback_tag->OnCompleted(ok); in GrpcWorkerCacheThread()
Dgrpc_worker_service.cc165 UntypedCall<GrpcWorkerServiceThread>::Tag* callback_tag = in HandleRPCsLoop() local
167 CHECK(callback_tag); in HandleRPCsLoop()
168 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
/external/tensorflow/tensorflow/core/tpu/kernels/
Dtpu_compilation_cache_service.cc168 UntypedCall<TpuCompilationCacheService>::Tag* callback_tag = in HandleRPCsLoop() local
170 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()