1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #ifndef CEPH_RGW_LOADGEN_H
5 #define CEPH_RGW_LOADGEN_H
10 #include "rgw_client_io.h"
13 struct RGWLoadGenRequestEnv {
15 uint64_t content_length;
16 std::string content_type;
17 std::string request_method;
19 std::string query_string;
22 std::map<std::string, std::string> headers;
24 RGWLoadGenRequestEnv()
29 void set_date(utime_t& tm);
30 int sign(RGWAccessKey& access_key);
33 /* XXX does RGWLoadGenIO actually want to perform stream/HTTP I/O,
34 * or (e.g) are these NOOPs? */
35 class RGWLoadGenIO : public rgw::io::RestfulClient
37 uint64_t left_to_read;
38 RGWLoadGenRequestEnv* req;
41 void init_env(CephContext *cct) override;
42 size_t read_data(char *buf, size_t len);
43 size_t write_data(const char *buf, size_t len);
46 explicit RGWLoadGenIO(RGWLoadGenRequestEnv* const req)
51 size_t send_status(int status, const char *status_name) override;
52 size_t send_100_continue() override;
53 size_t send_header(const boost::string_ref& name,
54 const boost::string_ref& value) override;
55 size_t complete_header() override;
56 size_t send_content_length(uint64_t len) override;
58 size_t recv_body(char* buf, size_t max) override {
59 return read_data(buf, max);
62 size_t send_body(const char* buf, size_t len) override {
63 return write_data(buf, len);
66 void flush() override;
68 RGWEnv& get_env() noexcept override {
72 size_t complete_request() override;