]>
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
9 #include "rgw_client_io.h"
12 struct RGWLoadGenRequestEnv
{
14 uint64_t content_length
;
15 std::string content_type
;
16 std::string request_method
;
18 std::string query_string
;
21 std::map
<std::string
, std::string
> headers
;
23 RGWLoadGenRequestEnv()
28 void set_date(utime_t
& tm
);
29 int sign(const DoutPrefixProvider
*dpp
, RGWAccessKey
& access_key
);
32 /* XXX does RGWLoadGenIO actually want to perform stream/HTTP I/O,
33 * or (e.g) are these NOOPs? */
34 class RGWLoadGenIO
: public rgw::io::RestfulClient
36 uint64_t left_to_read
;
37 RGWLoadGenRequestEnv
* req
;
40 int init_env(CephContext
*cct
) override
;
41 size_t read_data(char *buf
, size_t len
);
42 size_t write_data(const char *buf
, size_t len
);
45 explicit RGWLoadGenIO(RGWLoadGenRequestEnv
* const req
)
50 size_t send_status(int status
, const char *status_name
) override
;
51 size_t send_100_continue() override
;
52 size_t send_header(const std::string_view
& name
,
53 const std::string_view
& value
) override
;
54 size_t complete_header() override
;
55 size_t send_content_length(uint64_t len
) override
;
57 size_t recv_body(char* buf
, size_t max
) override
{
58 return read_data(buf
, max
);
61 size_t send_body(const char* buf
, size_t len
) override
{
62 return write_data(buf
, len
);
65 void flush() override
;
67 RGWEnv
& get_env() noexcept override
{
71 size_t complete_request() override
;