}
set_status(rgw::BucketReshardState::None, dpp);
}
- }
+ }
int start() {
int ret = set_status(rgw::BucketReshardState::InProgress, dpp);
return ret;
}
- ret = bucket_info_updater.complete();
- if (ret < 0) {
- ldout(store->ctx(), 0) << __func__ << ": failed to update bucket info ret=" << ret << dendl;
- /* don't error out, reshard process succeeded */
- }
-
return 0;
// NB: some error clean-up is done by ~BucketInfoReshardUpdate
} // RGWBucketReshard::do_reshard
}
}
- // set resharding status of current bucket_info & shards with
- // information about planned resharding
- ret = set_resharding_status(dpp, cls_rgw_reshard_status::IN_PROGRESS);
- if (ret < 0) {
- return ret;
- goto error_out;
- }
-
ret = do_reshard(num_shards,
max_op_entries,
verbose, out, formatter, dpp);