void RGWGetObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
static bool object_is_expired(map<string, bufferlist>& attrs) {
goto done_err;
}
- send_response_data(bl, 0, 0);
+ ret = send_response_data(bl, 0, 0);
+ if (ret < 0) {
+ goto done_err;
+ }
return;
done_err:
void RGWGetBucketVersioning::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWGetBucketVersioning::execute()
void RGWSetBucketVersioning::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWSetBucketVersioning::execute()
void RGWGetBucketWebsite::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWGetBucketWebsite::execute()
void RGWSetBucketWebsite::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWSetBucketWebsite::execute()
void RGWDeleteBucketWebsite::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWDeleteBucketWebsite::execute()
void RGWStatBucket::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWStatBucket::execute()
void RGWListBucket::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWListBucket::execute()
void RGWCreateBucket::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWCreateBucket::execute()
void RGWDeleteBucket::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWDeleteBucket::execute()
void RGWPutObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
static int put_data_and_throttle(RGWPutObjProcessor *processor, bufferlist& data, off_t ofs,
void RGWPostObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWPostObj::execute()
void RGWPutMetadataBucket::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWPutMetadataBucket::execute()
void RGWPutMetadataObject::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWPutMetadataObject::execute()
void RGWDeleteObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWDeleteObj::execute()
void RGWCopyObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWCopyObj::execute()
void RGWGetACLs::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWGetACLs::execute()
void RGWPutACLs::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWPutACLs::execute()
void RGWGetRequestPayment::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWGetRequestPayment::execute()
void RGWInitMultipart::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWInitMultipart::execute()
void RGWCompleteMultipart::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWCompleteMultipart::execute()
void RGWAbortMultipart::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWAbortMultipart::execute()
void RGWListMultipart::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWListMultipart::execute()
void RGWListBucketMultiparts::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWListBucketMultiparts::execute()
void RGWDeleteMultiObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);
+ ret = 0;
}
void RGWDeleteMultiObj::execute()
bool cors_exist;
RGWQuotaInfo bucket_quota;
RGWQuotaInfo user_quota;
+ int ret;
virtual int init_quota();
public:
virtual uint32_t op_mask() { return 0; }
virtual int error_handler(int err_no, string *error_content);
+ int get_ret() { return ret; };
};
class RGWGetObj : public RGWOp {
time_t *mod_ptr;
time_t *unmod_ptr;
map<string, bufferlist> attrs;
- int ret;
bool get_data;
bool partial_content;
bool range_parsed;
partial_content = false;
range_parsed = false;
skip_manifest = false;
- ret = 0;
is_slo = false;
}
class RGWListBuckets : public RGWOp {
protected:
- int ret;
bool sent_data;
string marker;
string end_marker;
map<string, bufferlist> attrs;
public:
- RGWListBuckets() : ret(0), sent_data(false) {
+ RGWListBuckets() : sent_data(false) {
limit = limit_max = RGW_LIST_BUCKETS_LIMIT_MAX;
buckets_count = 0;
buckets_objcount = 0;
class RGWStatAccount : public RGWOp {
protected:
- int ret;
uint32_t buckets_count;
uint64_t buckets_objcount;
uint64_t buckets_size;
string encoding_type;
bool list_versions;
int max;
- int ret;
vector<RGWObjEnt> objs;
map<string, bool> common_prefixes;
int parse_max_keys();
public:
- RGWListBucket() : list_versions(false), max(0), ret(0),
+ RGWListBucket() : list_versions(false), max(0),
default_max(0), is_truncated(false) {}
int verify_permission();
void pre_exec();
public:
RGWGetBucketLogging() {}
int verify_permission();
- void execute() {}
+ void execute() { ret = 0; }
virtual void send_response() = 0;
virtual const string name() { return "get_bucket_logging"; }
RGWGetBucketLocation() {}
~RGWGetBucketLocation() {}
int verify_permission();
- void execute() {}
+ void execute() { ret = 0; }
virtual void send_response() = 0;
virtual const string name() { return "get_bucket_location"; }
class RGWSetBucketVersioning : public RGWOp {
protected:
bool enable_versioning;
- int ret;
public:
- RGWSetBucketVersioning() : enable_versioning(false), ret(0) {}
+ RGWSetBucketVersioning() : enable_versioning(false) {}
int verify_permission();
void pre_exec();
};
class RGWGetBucketWebsite : public RGWOp {
-protected:
- int ret;
public:
- RGWGetBucketWebsite() : ret(0) {}
+ RGWGetBucketWebsite() {}
int verify_permission();
void pre_exec();
class RGWSetBucketWebsite : public RGWOp {
protected:
- int ret;
RGWBucketWebsiteConf website_conf;
public:
- RGWSetBucketWebsite() : ret(0) {}
+ RGWSetBucketWebsite() {}
int verify_permission();
void pre_exec();
};
class RGWDeleteBucketWebsite : public RGWOp {
-protected:
- int ret;
public:
- RGWDeleteBucketWebsite() : ret(0) {}
+ RGWDeleteBucketWebsite() {}
int verify_permission();
void pre_exec();
class RGWStatBucket : public RGWOp {
protected:
- int ret;
RGWBucketEnt bucket;
public:
- RGWStatBucket() : ret(0) {}
+ RGWStatBucket() {}
~RGWStatBucket() {}
int verify_permission();
class RGWCreateBucket : public RGWOp {
protected:
- int ret;
RGWAccessControlPolicy policy;
string location_constraint;
string placement_rule;
bufferlist in_data;
public:
- RGWCreateBucket() : ret(0), has_cors(false) {}
+ RGWCreateBucket() : has_cors(false) {}
int verify_permission();
void pre_exec();
class RGWDeleteBucket : public RGWOp {
protected:
- int ret;
-
RGWObjVersionTracker objv_tracker;
public:
- RGWDeleteBucket() : ret(0) {}
+ RGWDeleteBucket() {}
int verify_permission();
void pre_exec();
friend class RGWPutObjProcessor;
protected:
- int ret;
off_t ofs;
const char *supplied_md5_b64;
const char *supplied_etag;
time_t delete_at;
public:
- RGWPutObj() : ret(0), ofs(0),
+ RGWPutObj() : ofs(0),
supplied_md5_b64(NULL),
supplied_etag(NULL),
if_match(NULL),
protected:
off_t min_len;
off_t max_len;
- int ret;
int len;
off_t ofs;
const char *supplied_md5_b64;
time_t delete_at;
public:
- RGWPostObj() : min_len(0), max_len(LLONG_MAX), ret(0), len(0), ofs(0),
+ RGWPostObj() : min_len(0), max_len(LLONG_MAX), len(0), ofs(0),
supplied_md5_b64(NULL), supplied_etag(NULL),
data_pending(false), delete_at(0) {}
class RGWPutMetadataAccount : public RGWOp {
protected:
- int ret;
set<string> rmattr_names;
RGWAccessControlPolicy policy;
public:
- RGWPutMetadataAccount()
- : ret(0)
- {}
+ RGWPutMetadataAccount() {}
virtual void init(RGWRados *store, struct req_state *s, RGWHandler *h) {
RGWOp::init(store, s, h);
policy.set_ctx(s->cct);
}
int verify_permission();
- void pre_exec() { return; }
+ void pre_exec() { ret = 0; }
void execute();
virtual int get_params() = 0;
class RGWPutMetadataBucket : public RGWOp {
protected:
- int ret;
set<string> rmattr_names;
bool has_policy, has_cors;
RGWAccessControlPolicy policy;
public:
RGWPutMetadataBucket()
- : ret(0), has_policy(false), has_cors(false)
+ : has_policy(false), has_cors(false)
{}
virtual void init(RGWRados *store, struct req_state *s, RGWHandler *h) {
class RGWPutMetadataObject : public RGWOp {
protected:
- int ret;
RGWAccessControlPolicy policy;
string placement_rule;
time_t delete_at;
public:
RGWPutMetadataObject()
- : ret(0),
- delete_at(0),
+ : delete_at(0),
dlo_manifest(NULL)
{}
class RGWDeleteObj : public RGWOp {
protected:
- int ret;
bool delete_marker;
bool multipart_delete;
string version_id;
public:
RGWDeleteObj()
- : ret(0),
- delete_marker(false),
+ : delete_marker(false),
multipart_delete(false),
deleter(nullptr) {
}
time_t unmod_time;
time_t *mod_ptr;
time_t *unmod_ptr;
- int ret;
map<string, bufferlist> attrs;
string src_tenant_name, src_bucket_name;
rgw_bucket src_bucket;
class RGWGetACLs : public RGWOp {
protected:
- int ret;
string acls;
public:
- RGWGetACLs() : ret(0) {}
+ RGWGetACLs() {}
int verify_permission();
void pre_exec();
class RGWPutACLs : public RGWOp {
protected:
- int ret;
size_t len;
char *data;
ACLOwner owner;
class RGWGetCORS : public RGWOp {
protected:
- int ret;
public:
- RGWGetCORS() : ret(0) {}
+ RGWGetCORS() {}
int verify_permission();
void execute();
class RGWPutCORS : public RGWOp {
protected:
- int ret;
bufferlist cors_bl;
public:
class RGWDeleteCORS : public RGWOp {
protected:
- int ret;
public:
- RGWDeleteCORS() : ret(0) {}
+ RGWDeleteCORS() {}
int verify_permission();
void execute();
class RGWOptionsCORS : public RGWOp {
protected:
- int ret;
RGWCORSRule *rule;
const char *origin, *req_hdrs, *req_meth;
public:
- RGWOptionsCORS() : ret(0), rule(NULL), origin(NULL),
+ RGWOptionsCORS() : rule(NULL), origin(NULL),
req_hdrs(NULL), req_meth(NULL) {
}
class RGWSetRequestPayment : public RGWOp {
protected:
bool requester_pays;
- int ret;
public:
- RGWSetRequestPayment() : requester_pays(false), ret(0) {}
+ RGWSetRequestPayment() : requester_pays(false) {}
int verify_permission();
void pre_exec();
class RGWInitMultipart : public RGWOp {
protected:
- int ret;
string upload_id;
RGWAccessControlPolicy policy;
class RGWCompleteMultipart : public RGWOp {
protected:
- int ret;
string upload_id;
string etag;
char *data;
class RGWAbortMultipart : public RGWOp {
protected:
- int ret;
-
public:
- RGWAbortMultipart() : ret(0) {}
+ RGWAbortMultipart() {}
int verify_permission();
void pre_exec();
class RGWListMultipart : public RGWOp {
protected:
- int ret;
string upload_id;
map<uint32_t, RGWUploadPartInfo> parts;
int max_parts;
RGWMultipartUploadEntry next_marker;
int max_uploads;
string delimiter;
- int ret;
vector<RGWMultipartUploadEntry> uploads;
map<string, bool> common_prefixes;
bool is_truncated;
class RGWDeleteMultiObj : public RGWOp {
protected:
- int ret;
int max_to_delete;
size_t len;
char *data;