X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Frgw%2Frgw_loadgen.h;fp=src%2Fceph%2Fsrc%2Frgw%2Frgw_loadgen.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=dd9e2d8f6afc18f69772c57087b45e1341f25897;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/rgw/rgw_loadgen.h b/src/ceph/src/rgw/rgw_loadgen.h deleted file mode 100644 index dd9e2d8..0000000 --- a/src/ceph/src/rgw/rgw_loadgen.h +++ /dev/null @@ -1,75 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#ifndef CEPH_RGW_LOADGEN_H -#define CEPH_RGW_LOADGEN_H - -#include -#include - -#include "rgw_client_io.h" - - -struct RGWLoadGenRequestEnv { - int port; - uint64_t content_length; - std::string content_type; - std::string request_method; - std::string uri; - std::string query_string; - std::string date_str; - - std::map headers; - - RGWLoadGenRequestEnv() - : port(0), - content_length(0) { - } - - void set_date(utime_t& tm); - int sign(RGWAccessKey& access_key); -}; - -/* XXX does RGWLoadGenIO actually want to perform stream/HTTP I/O, - * or (e.g) are these NOOPs? */ -class RGWLoadGenIO : public rgw::io::RestfulClient -{ - uint64_t left_to_read; - RGWLoadGenRequestEnv* req; - RGWEnv env; - - void init_env(CephContext *cct) override; - size_t read_data(char *buf, size_t len); - size_t write_data(const char *buf, size_t len); - -public: - explicit RGWLoadGenIO(RGWLoadGenRequestEnv* const req) - : left_to_read(0), - req(req) { - } - - size_t send_status(int status, const char *status_name) override; - size_t send_100_continue() override; - size_t send_header(const boost::string_ref& name, - const boost::string_ref& value) override; - size_t complete_header() override; - size_t send_content_length(uint64_t len) override; - - size_t recv_body(char* buf, size_t max) override { - return read_data(buf, max); - } - - size_t send_body(const char* buf, size_t len) override { - return write_data(buf, len); - } - - void flush() override; - - RGWEnv& get_env() noexcept override { - return env; - } - - size_t complete_request() override; -}; - -#endif