Home
last modified time | relevance | path

Searched refs:RecvBufAsync (Results 1 – 12 of 12) sorted by relevance

/external/tensorflow/tensorflow/contrib/gdr/
Dgdr_worker.h41 virtual void RecvBufAsync(CallOptions* opts, const RecvBufRequest* request,
Dgdr_collective_executor_mgr.cc58 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
Dgdr_worker.cc150 void GdrWorker::RecvBufAsync(CallOptions* opts, const RecvBufRequest* request, in RecvBufAsync() function in tensorflow::GdrWorker
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_worker_service.h51 virtual void RecvBufAsync(CallOptions* opts, const RecvBufRequest* request,
Dgrpc_worker_service.cc297 worker_->RecvBufAsync(call_opts, &call->request, &call->response, in RecvBufHandler()
555 void GrpcWorker::RecvBufAsync(CallOptions* opts, const RecvBufRequest* request, in RecvBufAsync() function in tensorflow::GrpcWorker
Dgrpc_remote_worker.cc128 void RecvBufAsync(CallOptions* call_opts, const RecvBufRequest* request, in RecvBufAsync() function in tensorflow::GrpcRemoteWorker
/external/tensorflow/tensorflow/core/distributed_runtime/
Dworker.h93 void RecvBufAsync(CallOptions* opts, const RecvBufRequest* request,
Dcollective_rma_distributed.cc57 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
Dtest_utils.h97 void RecvBufAsync(CallOptions* opts, const RecvBufRequest* request, in RecvBufAsync() function
Dworker_interface.h115 virtual void RecvBufAsync(CallOptions* opts, const RecvBufRequest* request,
Dcollective_rma_distributed_test.cc85 void RecvBufAsync(CallOptions* opts, const RecvBufRequest* request, in RecvBufAsync() function in tensorflow::__anon7e5c43490111::FakeWorker
Dworker.cc382 void Worker::RecvBufAsync(CallOptions* opts, const RecvBufRequest* request, in RecvBufAsync() function in tensorflow::Worker