Searched refs:resp_ (Results 1 – 5 of 5) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr.cc | 86 resp_.Clear(); in Reset()
126 const Tensor& tensor() const { return resp_.tensor(); } in tensor()
128 bool is_dead() const { return resp_.metadata().is_dead(); } in is_dead()
139 resp_.InitAlloc(dst_device_, alloc_attrs_); in StartRTCall()
152 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in StartRTCall()
178 TensorResponse resp_; member in tensorflow::__anona9090a8f0111::RpcRecvTensorCall
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_param_resolver_distributed.cc | 49 wi_->CompleteGroupAsync(&opts_, &req_, &resp_, done); in IssueCall()
53 CompleteGroupResponse resp_; member in tensorflow::__anon463e9d2a0111::CompleteGroupCall
82 wi_->CompleteInstanceAsync(&opts_, &req_, &resp_, done); in IssueCall()
86 CompleteInstanceResponse resp_; member in tensorflow::__anon463e9d2a0111::CompleteInstanceCall
313 Status status = UpdateGroupCache(call->resp_); in CompleteGroupDistributed()
402 s = UpdateInstanceCache(gr, cp, call->resp_); in CompleteInstanceDistributed()
|
| D | collective_rma_distributed.cc | 60 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
64 RecvBufResponse resp_; member in tensorflow::__anon35c4ad880111::RecvBufCall
109 state->call->resp_.transport_options().UnpackTo(&extra); in RecvFromPeer()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | server_callback_handlers.h | 329 finish_ops_.SendMessagePtr(&resp_)); in Finish()
399 ResponseType* response() { return &resp_; } in response()
429 ResponseType resp_; variable
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | server_callback_handlers.h | 329 finish_ops_.SendMessagePtr(&resp_)); in Finish()
399 ResponseType* response() { return &resp_; } in response()
429 ResponseType resp_; variable
|