Home
last modified time | relevance | path

Searched refs:RecvTensorRequest (Results 1 – 16 of 16) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/
Drecent_request_ids_test.cc30 RecvTensorRequest request; in TrackUnique()
100 RecvTensorRequest request; in BM_TrackUnique()
Dworker.h84 void RecvTensorAsync(CallOptions* opts, const RecvTensorRequest* request,
Dtest_utils.h82 void RecvTensorAsync(CallOptions* opts, const RecvTensorRequest* request, in RecvTensorAsync()
Dworker_interface.h105 const RecvTensorRequest* request,
Dworker.cc452 const RecvTensorRequest* request, in RecvTensorAsync()
/external/tensorflow/tensorflow/contrib/gdr/
Dgdr_worker.h37 const RecvTensorRequest* request,
Dgdr_worker.cc48 const RecvTensorRequest* request, in GrpcRecvTensorAsync()
Dgdr_rendezvous_mgr.cc111 RecvTensorRequest req_;
/external/tensorflow/tensorflow/contrib/mpi/
Dmpi_rendezvous_mgr.h93 RecvTensorRequest req_;
186 void AddRequest(RecvTensorRequest, const int);
Dmpi_rendezvous_mgr.cc151 void MPIRendezvousMgr::AddRequest(RecvTensorRequest request, in AddRequest()
283 RecvTensorRequest request; in MPIBackgroundThread()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_worker_service.h44 const RecvTensorRequest* request,
Dgrpc_worker_service.cc263 WorkerCall<RecvTensorRequest, ::grpc::ByteBuffer>* call) { in RecvTensorHandlerRaw() argument
353 RecvTensorRequest, ::grpc::ByteBuffer>:: in EnqueueRecvTensorRequestRaw()
445 const RecvTensorRequest* request, in GrpcRecvTensorAsync()
Drpc_rendezvous_mgr.cc160 RecvTensorRequest req_;
Dgrpc_remote_worker.cc191 void RecvTensorAsync(CallOptions* call_opts, const RecvTensorRequest* request, in RecvTensorAsync()
/external/tensorflow/tensorflow/core/protobuf/
Dworker_service.proto66 rpc RecvTensor(RecvTensorRequest) returns (RecvTensorResponse) {
Dworker.proto307 message RecvTensorRequest { message
333 // Unique identifier for this request. Every RecvTensorRequest must have a
356 // e.g. in the event that `RecvTensorRequest.dma_ok` was true.