}
}
+
int RGWStreamIOBase::print(const char *format, ...)
{
#define LARGE_ENOUGH 128
return 0;
}
+
int RGWStreamIO::write(const char* const buf, const int len)
{
const auto ret = RGWStreamIOBase::write(buf, len);
virtual ~RGWClientIO() {}
void init(CephContext *cct);
- RGWEnv& get_env() { return env; }
+ RGWEnv& get_env() {
+ return env;
+ }
virtual int complete_request() = 0; /* XXX signature likely changing */
- virtual uint64_t get_bytes_sent() = 0;
- virtual uint64_t get_bytes_received() = 0;
+ virtual uint64_t get_bytes_sent() const = 0;
+ virtual uint64_t get_bytes_received() const = 0;
}; /* RGWClient IO */
class RGWStreamIOBase : public RGWClientIO {
SHA256 *sha256_hash;
- bool account() { return _account; }
+ bool account() const {
+ return _account;
+ }
public:
virtual ~RGWStreamIO() {}
_account = _accnt;
}
- uint64_t get_bytes_sent() override {
+ uint64_t get_bytes_sent() const override {
return bytes_sent;
}
- uint64_t get_bytes_received() override {
+ uint64_t get_bytes_received() const override {
return bytes_received;
}
}; /* RGWStreamIO */
RGWLibIO(const RGWUserInfo &_user_info)
: user_info(_user_info) {}
- virtual void init_env(CephContext *cct) {}
+ virtual void init_env(CephContext *cct) override {}
const RGWUserInfo& get_user() {
return user_info;
int complete_header();
int send_content_length(uint64_t len);
- int complete_request() { /* XXX */
+ int complete_request() override { /* XXX */
return 0;
};
- uint64_t get_bytes_sent() override {
+ uint64_t get_bytes_sent() const override {
return 0;
}
- uint64_t get_bytes_received() override {
+ uint64_t get_bytes_received() const override {
return 0;
}