ceph/src/rgw/rgw_request.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab ft=cpp
   3
   4 #pragma once
   5
   6 #include "rgw_common.h"
   7 #include "rgw_acl.h"
   8 #include "rgw_user.h"
   9 #include "rgw_op.h"
  10
  11 #include "common/QueueRing.h"
  12
  13 #include <atomic>
  14
  15 struct RGWRequest
  16 {
  17   uint64_t id;
  18   req_state *s;
  19   RGWOp *op;
  20
  21   explicit RGWRequest(uint64_t id) : id(id), s(NULL), op(NULL) {}
  22
  23   virtual ~RGWRequest() {}
  24
  25   void init_state(req_state *_s) {
  26     s = _s;
  27   }
  28 }; /* RGWRequest */
  29
  30 struct RGWLoadGenRequest : public RGWRequest {
  31         std::string method;
  32         std::string resource;
  33         int content_length;
  34         std::atomic<bool>* fail_flag = nullptr;
  35
  36 RGWLoadGenRequest(uint64_t req_id, const std::string& _m, const std::string& _r, int _cl,
  37                 std::atomic<bool> *ff)
  38         : RGWRequest(req_id), method(_m), resource(_r), content_length(_cl),
  39                 fail_flag(ff) {}
  40 };