| /device/google/cuttlefish_common/host/commands/virtual_usb_manager/vadb/ |
| usb_cmd_attach.h | 39 usb_forward::AttachRequest req_; member in class:vadb::USBCmdAttach
|
| usb_cmd_control_transfer.h | 51 usb_forward::ControlTransfer req_; member in class:vadb::USBCmdControlTransfer
|
| usb_cmd_data_transfer.h | 50 usb_forward::DataTransfer req_; member in class:vadb::USBCmdDataTransfer
|
| /external/tensorflow/tensorflow/contrib/gdr/ |
| gdr_collective_executor_mgr.cc | 44 req_.set_step_id(step_id);
45 req_.set_buf_rendezvous_key(key);
46 *req_.mutable_client_locality() = client_locality;
47 *req_.mutable_server_locality() = server_locality;
48 req_.set_num_bytes(to_tensor->TotalBytes());
49 req_.set_buf_ptr(reinterpret_cast<int64>(DMAHelper::base(to_tensor)));
50 req_.set_src_device(peer_device);
51 req_.set_dst_device(to_device->name());
52 req_.set_request_id(GetUniqueRequestId());
58 wi_->RecvBufAsync(&opts_, &req_, &resp_, done)
61 RecvBufRequest req_; member in class:tensorflow::__anon44746::RecvBufCall
[all...] |
| gdr_rendezvous_mgr.cc | 49 req_.set_step_id(step_id);
50 req_.set_rendezvous_key(key.data(), key.size());
51 req_.set_request_id(GetUniqueRequestId());
57 req_.set_dma_ok(true);
82 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb));
111 RecvTensorRequest req_; member in class:tensorflow::__anon44748::GdrRecvTensorCall
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| collective_rma_distributed.cc | 43 req_.set_step_id(step_id);
44 req_.set_buf_rendezvous_key(key);
45 *req_.mutable_client_locality() = client_locality;
46 *req_.mutable_server_locality() = server_locality;
47 req_.set_num_bytes(to_tensor->TotalBytes());
48 req_.set_buf_ptr(reinterpret_cast<int64>(DMAHelper::base(to_tensor)));
49 req_.set_src_device(peer_device);
50 req_.set_dst_device(to_device->name());
51 req_.set_request_id(GetUniqueRequestId());
57 wi_->RecvBufAsync(&opts_, &req_, &resp_, done)
60 RecvBufRequest req_; member in class:tensorflow::__anon44909::RecvBufCall
[all...] |
| collective_param_resolver_distributed.cc | 31 req_.set_group_key(group.group_key);
32 req_.set_group_size(group.group_size);
33 req_.set_device_type(group.device_type.type_string());
34 req_.add_device_name(device_name);
39 wi_->CompleteGroupAsync(&opts_, &req_, &resp_, done);
42 CompleteGroupRequest req_; member in class:tensorflow::__anon44907::CompleteGroupCall
54 req_.set_name(node_name);
55 req_.set_type(instance.type);
56 req_.set_data_type(instance.data_type);
57 instance.shape.AsProto(req_.mutable_shape())
75 CompleteInstanceRequest req_; member in class:tensorflow::__anon44907::CompleteInstanceCall
[all...] |
| master_session.cc | 822 req_.set_step_id(step_id);
826 CleanupGraphRequest* request() { return &req_; }
852 CleanupGraphRequest req_; member in class:tensorflow::__anon44918::CleanupBroadcastHelper
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| rpc_rendezvous_mgr.cc | 69 req_.set_step_id(step_id);
70 req_.set_rendezvous_key(key.data(), key.size());
71 req_.set_request_id(GetUniqueRequestId());
84 req_.Clear();
151 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb));
160 RecvTensorRequest req_; member in class:tensorflow::__anon44940::RpcRecvTensorCall
|
| /external/tensorflow/tensorflow/contrib/mpi/ |
| mpi_rendezvous_mgr.h | 93 RecvTensorRequest req_; member in class:tensorflow::MPIRequestTensorCall
107 req_.set_step_id(step_id);
108 req_.set_rendezvous_key(parsed.FullKey().data(), parsed.FullKey().size());
109 req_.set_request_id(GetUniqueRequestId());
110 request_buffer_size_ = req_.ByteSize();
112 // req_.SerializeToArray(request_buffer_, request_buffer_size_);
|
| /external/grpc-grpc/test/cpp/qps/ |
| client_async.cc | 78 req_(req),
93 response_reader_ = prepare_req_(stub_, &context_, req_, cq_);
112 auto* clone = new ClientRpcContextUnaryImpl(stub_, req_, next_issue_,
123 const RequestType& req_; member in class:grpc::testing::ClientRpcContextUnaryImpl
349 req_(req),
382 stream_->WriteLast(req_, WriteOptions(),
385 stream_->Write(req_, ClientRpcContext::tag(this));
428 stub_, req_, next_issue_, prepare_req_, callback_);
438 const RequestType& req_; member in class:grpc::testing::ClientRpcContextStreamingPingPongImpl
534 req_(req)
593 const RequestType& req_; member in class:grpc::testing::ClientRpcContextStreamingFromClientImpl
713 const RequestType& req_; member in class:grpc::testing::ClientRpcContextStreamingFromServerImpl
858 ByteBuffer req_; member in class:grpc::testing::ClientRpcContextGenericStreamingImpl
[all...] |
| server_async.cc | 262 request_method_(srv_ctx_.get(), &req_, &response_writer_,
269 req_ = RequestType();
275 request_method_(srv_ctx_.get(), &req_, &response_writer_,
287 grpc::Status status = invoke_method_(&req_, &response_);
295 RequestType req_; member in class:grpc::testing::final::final
324 req_ = RequestType();
339 stream_.Read(&req_, AsyncQpsServerTest::tag(this));
347 grpc::Status status = invoke_method_(&req_, &response_);
362 stream_.Read(&req_, AsyncQpsServerTest::tag(this));
372 RequestType req_; member in class:grpc::testing::final::final
441 RequestType req_; member in class:grpc::testing::final::final
509 RequestType req_; member in class:grpc::testing::final::final
[all...] |
