ret = store->update_containers_stats(m);
if (ret > 0) {
bucket = m.begin()->second;
- }
+ }
}
RGWRados::Bucket target(store, s->bucket);
goto done;
}
+ ret = store->check_quota(s->bucket_owner.get_id(), s->bucket,
+ user_quota, bucket_quota, s->content_length);
+ if (ret < 0) {
+ goto done;
+ }
+
processor = select_processor(*static_cast<RGWObjectCtx *>(s->obj_ctx));
ret = processor->prepare(store, NULL);
s->obj_size = ofs;
+ ret = store->check_quota(s->bucket_owner.get_id(), s->bucket,
+ user_quota, bucket_quota, s->obj_size);
+ if (ret < 0) {
+ goto done;
+ }
+
hash.Final(m);
buf_to_hex(m, CEPH_CRYPTO_MD5_DIGESTSIZE, calc_md5);
int ret;
parts.clear();
-
+
if (sorted_omap) {
string p;
p = "part.";