/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...] |