if (in_progress) {
// resharding must not have ended correctly, clean up
int ret =
- RGWBucketReshard::clear_index_shard_reshard_status(store, bucket_info);
+ RGWBucketReshard::clear_index_shard_reshard_status(store, bucket_info);
if (ret < 0) {
lderr(store->ctx()) << "Error: " << __func__ <<
" clear_index_shard_status returned " << ret << dendl;
}
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(cls_rgw_reshard_status::IN_PROGRESS);
- if (ret < 0) {
- return ret;
- goto error_out;
- }
ret = do_reshard(num_shards,
max_op_entries,