for(auto& entry: entries) { // logshard entries
process_entry(entry, max_entries, dpp, y);
- if (ret < 0) {
- return ret;
- }
Clock::time_point now = Clock::now();
if (logshard_lock.should_renew(now)) {
rgw_zone_set *zones_trace, bool *canceled,
optional_yield y)
{
- int ret = 0;
/* XXX: same as AtomicWriter..consolidate code */
parent_op.meta.mtime = mtime;
parent_op.meta.delete_at = delete_at;
/* XXX: handle accounted size */
accounted_size = total_data_size;
- if (ret < 0)
- return ret;
-
RGWUploadPartInfo info;
info.num = part_num;
info.etag = etag;
DB::Object op_target(store->getDB(),
meta_obj->get_bucket()->get_info(), meta_obj->get_obj());
- ret = op_target.add_mp_part(dpp, info);
+ auto ret = op_target.add_mp_part(dpp, info);
if (ret < 0) {
return ret == -ENOENT ? -ERR_NO_SUCH_UPLOAD : ret;
}