rgw_env.set("HTTP_HOST", "");
/* XXX and -then- bloat up req_state with string copies from it */
- const uint64_t reqid = store->get_new_req_id();
- struct req_state rstate(req->cct, &rgw_env, req->get_user(), reqid);
+ struct req_state rstate(req->cct, &rgw_env, req->get_user(), req->id);
struct req_state *s = &rstate;
// XXX fix this
RGWWriteRequest(CephContext* _cct, RGWUserInfo *_user, RGWFileHandle* _fh,
const std::string& _bname, const std::string& _oname)
- : RGWLibContinuedReq(_cct, _user, rgwlib.get_store()->get_new_req_id()),
+ : RGWLibContinuedReq(_cct, _user),
bucket_name(_bname), obj_name(_oname),
rgw_fh(_fh), filter(nullptr), real_ofs(0),
bytes_written(0), eio(false) {
/* unambiguiously return req_state */
inline struct req_state* get_state() { return this->RGWRequest::s; }
- RGWLibRequest(CephContext* _cct, RGWUserInfo* _user, uint64_t id = 0)
- : RGWRequest(id), cct(_cct), user(_user)
+ RGWLibRequest(CephContext* _cct, RGWUserInfo* _user)
+ : RGWRequest(rgwlib.get_store()->get_new_req_id()), cct(_cct),
+ user(_user)
{}
RGWUserInfo* get_user() { return user; }
RGWObjectCtx rados_ctx;
public:
- RGWLibContinuedReq(CephContext* _cct, RGWUserInfo* _user, uint64_t id = 0)
- : RGWLibRequest(_cct, _user, id), io_ctx(),
+ RGWLibContinuedReq(CephContext* _cct, RGWUserInfo* _user)
+ : RGWLibRequest(_cct, _user), io_ctx(),
rstate(_cct, &io_ctx.get_env(), _user, id),
rados_ctx(rgwlib.get_store(), &rstate)
{