| /external/tensorflow/tensorflow/contrib/gdr/ |
| D | gdr_collective_executor_mgr.cc | 44 req_.set_step_id(step_id); in RecvBufCall()
45 req_.set_buf_rendezvous_key(key); in RecvBufCall()
46 *req_.mutable_client_locality() = client_locality; in RecvBufCall()
47 *req_.mutable_server_locality() = server_locality; in RecvBufCall()
48 req_.set_num_bytes(to_tensor->TotalBytes()); in RecvBufCall()
49 req_.set_buf_ptr(reinterpret_cast<int64>(DMAHelper::base(to_tensor))); in RecvBufCall()
50 req_.set_src_device(peer_device); in RecvBufCall()
51 req_.set_dst_device(to_device->name()); in RecvBufCall()
52 req_.set_request_id(GetUniqueRequestId()); in RecvBufCall()
58 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
[all …]
|
| D | gdr_rendezvous_mgr.cc | 49 req_.set_step_id(step_id); in GdrRecvTensorCall()
50 req_.set_rendezvous_key(key.data(), key.size()); in GdrRecvTensorCall()
51 req_.set_request_id(GetUniqueRequestId()); in GdrRecvTensorCall()
57 req_.set_dma_ok(true); in Start()
82 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in Start()
111 RecvTensorRequest req_; member in tensorflow::__anon5c78cdd40111::GdrRecvTensorCall
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_rma_distributed.cc | 43 req_.set_step_id(step_id); in RecvBufCall()
44 req_.set_buf_rendezvous_key(key); in RecvBufCall()
45 *req_.mutable_client_locality() = client_locality; in RecvBufCall()
46 *req_.mutable_server_locality() = server_locality; in RecvBufCall()
47 req_.set_num_bytes(to_tensor->TotalBytes()); in RecvBufCall()
48 req_.set_buf_ptr(reinterpret_cast<int64>(DMAHelper::base(to_tensor))); in RecvBufCall()
49 req_.set_src_device(peer_device); in RecvBufCall()
50 req_.set_dst_device(to_device->name()); in RecvBufCall()
51 req_.set_request_id(GetUniqueRequestId()); in RecvBufCall()
57 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
[all …]
|
| D | collective_param_resolver_distributed.cc | 31 req_.set_group_key(group.group_key); in CompleteGroupCall()
32 req_.set_group_size(group.group_size); in CompleteGroupCall()
33 req_.set_device_type(group.device_type.type_string()); in CompleteGroupCall()
34 req_.add_device_name(device_name); in CompleteGroupCall()
39 wi_->CompleteGroupAsync(&opts_, &req_, &resp_, done); in IssueCall()
42 CompleteGroupRequest req_; member in tensorflow::__anonb3ac978c0111::CompleteGroupCall
54 req_.set_name(node_name); in CompleteInstanceCall()
55 req_.set_type(instance.type); in CompleteInstanceCall()
56 req_.set_data_type(instance.data_type); in CompleteInstanceCall()
57 instance.shape.AsProto(req_.mutable_shape()); in CompleteInstanceCall()
[all …]
|
| D | master_session.cc | 822 req_.set_step_id(step_id); in CleanupBroadcastHelper()
826 CleanupGraphRequest* request() { return &req_; } in request()
852 CleanupGraphRequest req_; member in tensorflow::__anon26c900ce0711::CleanupBroadcastHelper
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 262 request_method_(srv_ctx_.get(), &req_, &response_writer_, in ServerRpcContextUnaryImpl()
269 req_ = RequestType(); in Reset()
275 request_method_(srv_ctx_.get(), &req_, &response_writer_, in Reset()
287 grpc::Status status = invoke_method_(&req_, &response_); in invoker()
295 RequestType req_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextUnaryImpl
324 req_ = RequestType(); in Reset()
339 stream_.Read(&req_, AsyncQpsServerTest::tag(this)); in request_done()
347 grpc::Status status = invoke_method_(&req_, &response_); in read_done()
362 stream_.Read(&req_, AsyncQpsServerTest::tag(this)); in write_done()
372 RequestType req_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl
[all …]
|
| D | client_async.cc | 78 req_(req), in ClientRpcContextUnaryImpl()
93 response_reader_ = prepare_req_(stub_, &context_, req_, cq_); in RunNextState()
112 auto* clone = new ClientRpcContextUnaryImpl(stub_, req_, next_issue_, in StartNewClone()
123 const RequestType& req_; member in grpc::testing::ClientRpcContextUnaryImpl
349 req_(req), in ClientRpcContextStreamingPingPongImpl()
382 stream_->WriteLast(req_, WriteOptions(), in RunNextState()
385 stream_->Write(req_, ClientRpcContext::tag(this)); in RunNextState()
428 stub_, req_, next_issue_, prepare_req_, callback_); in StartNewClone()
438 const RequestType& req_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl
534 req_(req), in ClientRpcContextStreamingFromClientImpl()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr.cc | 69 req_.set_step_id(step_id); in Init()
70 req_.set_rendezvous_key(key.data(), key.size()); in Init()
71 req_.set_request_id(GetUniqueRequestId()); in Init()
84 req_.Clear(); in Reset()
151 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in StartRTCall()
160 RecvTensorRequest req_; member in tensorflow::__anon9a114d310111::RpcRecvTensorCall
|
| /external/tensorflow/tensorflow/contrib/mpi/ |
| D | mpi_rendezvous_mgr.h | 93 RecvTensorRequest req_; variable
107 req_.set_step_id(step_id); in Init()
108 req_.set_rendezvous_key(parsed.FullKey().data(), parsed.FullKey().size()); in Init()
109 req_.set_request_id(GetUniqueRequestId()); in Init()
110 request_buffer_size_ = req_.ByteSize(); in Init()
|
| D | mpi_rendezvous_mgr.cc | 93 rendezvous_call->req_.SerializeToArray( in RecvFromRemoteAsync()
|
| /external/libevent/include/event2/ |
| D | rpc.h | 275 struct evrpc_req_generic *req_ = (struct evrpc_req_generic *)(rpc_req); \
276 evrpc_request_done(req_); \
|
| /external/libevent/ |
| D | evdns.c | 1759 evdns_server_request_add_reply(struct evdns_server_request *req_, int section, const char *name, in… in evdns_server_request_add_reply() argument
1761 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_add_reply()
1989 evdns_server_request_respond(struct evdns_server_request *req_, int err) in evdns_server_request_respond() argument
1991 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_respond()
2137 evdns_server_request_drop(struct evdns_server_request *req_) in evdns_server_request_drop() argument
2139 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_drop()
2146 evdns_server_request_get_requesting_addr(struct evdns_server_request *req_, struct sockaddr *sa, in… in evdns_server_request_get_requesting_addr() argument
2148 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_get_requesting_addr()
|