]>
git.proxmox.com Git - ceph.git/blob - ceph/src/rgw/rgw_loadgen.h
1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab ft=cpp
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(const DoutPrefixProvider
*dpp
, 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 int 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 std::string_view
& name
,
54 const std::string_view
& 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
;