ceph::bufferlist response;
rgw_user user;
- int ret = conn->forward(dpp(), user, info, nullptr, MAX_REST_RESPONSE, &in_data, &response, null_yield);
+ int ret = conn->forward(dpp(), user, info, MAX_REST_RESPONSE, &in_data, &response, null_yield);
int parse_ret = parser.parse(response.c_str(), response.length());
if (parse_ret < 0) {
creds, site.get_zonegroup().id, zg->second.api_name};
bufferlist outdata;
constexpr size_t max_response_size = 128 * 1024; // we expect a very small response
- int ret = conn.forward(dpp, effective_owner, req, nullptr,
+ int ret = conn.forward(dpp, effective_owner, req,
max_response_size, indata, &outdata, y);
if (ret < 0) {
return ret;
bufferlist data;
#define MAX_REST_RESPONSE (128 * 1024)
- int r = conn->forward(dpp, user, info, nullptr, MAX_REST_RESPONSE, nullptr, &data, y);
+ int r = conn->forward(dpp, user, info, MAX_REST_RESPONSE, nullptr, &data, y);
if (r < 0) {
return r;
}
populate_zonegroup(params, zonegroup);
}
-int RGWRESTConn::forward(const DoutPrefixProvider *dpp, const rgw_owner& uid, const req_info& info, obj_version *objv, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y)
+int RGWRESTConn::forward(const DoutPrefixProvider *dpp, const rgw_owner& uid, const req_info& info, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y)
{
int ret = 0;
return ret;
param_vec_t params;
populate_params(params, &uid, self_zone_group);
- if (objv) {
- params.push_back(param_pair_t(RGW_SYS_PARAM_PREFIX "tag", objv->tag));
- char buf[16];
- snprintf(buf, sizeof(buf), "%lld", (long long)objv->ver);
- params.push_back(param_pair_t(RGW_SYS_PARAM_PREFIX "ver", buf));
- }
RGWRESTSimpleRequest req(cct, info.method, url, NULL, ¶ms, api_name);
ret = req.forward_request(dpp, key, info, max_response, inbl, outbl, y);
if (ret == -EIO) {
return ret;
}
-int RGWRESTConn::forward_iam_request(const DoutPrefixProvider *dpp, const req_info& info, obj_version *objv, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y)
+int RGWRESTConn::forward_iam_request(const DoutPrefixProvider *dpp, const req_info& info, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y)
{
int ret = 0;
if (ret < 0)
return ret;
param_vec_t params;
- if (objv) {
- params.push_back(param_pair_t(RGW_SYS_PARAM_PREFIX "tag", objv->tag));
- char buf[16];
- snprintf(buf, sizeof(buf), "%lld", (long long)objv->ver);
- params.push_back(param_pair_t(RGW_SYS_PARAM_PREFIX "ver", buf));
- }
std::string service = "iam";
RGWRESTSimpleRequest req(cct, info.method, url, NULL, ¶ms, api_name);
// coverity[uninit_use_in_call:SUPPRESS]
virtual void populate_params(param_vec_t& params, const rgw_owner* uid, const std::string& zonegroup);
/* sync request */
- int forward(const DoutPrefixProvider *dpp, const rgw_owner& uid, const req_info& info, obj_version *objv, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y);
+ int forward(const DoutPrefixProvider *dpp, const rgw_owner& uid, const req_info& info, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y);
/* sync request */
- int forward_iam_request(const DoutPrefixProvider *dpp, const req_info& info, obj_version *objv, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y);
+ int forward_iam_request(const DoutPrefixProvider *dpp, const req_info& info, size_t max_response, bufferlist *inbl, bufferlist *outbl, optional_yield y);
/* async requests */
std::move(creds), zg->second.id, zg->second.api_name};
bufferlist outdata;
constexpr size_t max_response_size = 128 * 1024; // we expect a very small response
- int ret = conn.forward_iam_request(dpp, req, nullptr, max_response_size,
+ int ret = conn.forward_iam_request(dpp, req, max_response_size,
&indata, &outdata, y);
if (ret < 0) {
return ret;