Searched refs:resp_ (Results 1 – 5 of 5) sorted by relevance
| /external/tensorflow/tensorflow/contrib/gdr/ |
| D | gdr_rendezvous_mgr.cc | 58 resp_.InitAlloc(dst_device_, recv_args_.alloc_attrs); in Start()
60 bool dma_ok = resp_.metadata().has_transport_options(); in Start()
62 auto transport_options = resp_.metadata().transport_options(); in Start()
82 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in Start()
98 const Tensor& tensor() const { return resp_.tensor(); } in tensor()
100 bool is_dead() const { return resp_.metadata().is_dead(); } in is_dead()
112 TensorResponse resp_; member in tensorflow::__anon5c78cdd40111::GdrRecvTensorCall
|
| D | gdr_collective_executor_mgr.cc | 58 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
62 RecvBufResponse resp_; member in tensorflow::__anon0f845a970111::RecvBufCall
106 to_tensor, state->call->resp_.transport_options(), to_device, in RecvFromPeer()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr.cc | 85 resp_.Clear(); in Reset()
125 const Tensor& tensor() const { return resp_.tensor(); } in tensor()
127 bool is_dead() const { return resp_.metadata().is_dead(); } in is_dead()
138 resp_.InitAlloc(dst_device_, alloc_attrs_); in StartRTCall()
151 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in StartRTCall()
161 TensorResponse resp_; member in tensorflow::__anon9a114d310111::RpcRecvTensorCall
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_rma_distributed.cc | 57 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
61 RecvBufResponse resp_; member in tensorflow::__anon2091712a0111::RecvBufCall
106 state->call->resp_.transport_options().UnpackTo(&extra); in RecvFromPeer()
|
| D | collective_param_resolver_distributed.cc | 39 wi_->CompleteGroupAsync(&opts_, &req_, &resp_, done); in IssueCall()
43 CompleteGroupResponse resp_; member in tensorflow::__anonb3ac978c0111::CompleteGroupCall
72 wi_->CompleteInstanceAsync(&opts_, &req_, &resp_, done); in IssueCall()
76 CompleteInstanceResponse resp_; member in tensorflow::__anonb3ac978c0111::CompleteInstanceCall
267 Status status = UpdateGroupCache(call->resp_); in CompleteGroupDistributed()
377 gr, cp, call->resp_, [this, device, gr, cp, done](const Status& s) { in CompleteInstanceDistributed()
|