Home
last modified time | relevance | path

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

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc62 UntypedCall<GrpcEagerServiceImpl>::Tag* callback_tag = in HandleRPCsLoop() local
65 if (callback_tag) { in HandleRPCsLoop()
66 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
Dgrpc_eager_client.cc111 GrpcClientCQTag* callback_tag = in GrpcEagerClientThread() local
113 callback_tag->OnCompleted(ok); in GrpcEagerClientThread()
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service.cc90 UntypedCall<GrpcVerbsService>::Tag* callback_tag = in HandleRPCsLoop() local
92 if (callback_tag) { in HandleRPCsLoop()
93 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_worker_cache.cc112 GrpcClientCQTag* callback_tag = in GrpcWorkerCacheThread() local
114 callback_tag->OnCompleted(ok); in GrpcWorkerCacheThread()
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_rpc_factory.cc90 GrpcClientCQTag* callback_tag = static_cast<GrpcClientCQTag*>(tag); in GrpcRPCFactory() local
91 callback_tag->OnCompleted(ok); in GrpcRPCFactory()
Dgrpc_worker_service.cc164 UntypedCall<GrpcWorkerServiceThread>::Tag* callback_tag = in HandleRPCsLoop() local
166 CHECK(callback_tag); in HandleRPCsLoop()
167 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()