return ret;
}
- RGWBucketReshard br(static_cast<rgw::sal::RadosStore*>(store), bucket->get_info(), bucket->get_attrs(), nullptr /* no callback */);
+ RGWBucketReshard br(static_cast<rgw::sal::RadosStore*>(store), bucket->get_info(), nullptr /* no callback */);
#define DEFAULT_RESHARD_MAX_ENTRIES 1000
if (max_entries < 1) {
return -ret;
}
- RGWBucketReshard br(static_cast<rgw::sal::RadosStore*>(store), bucket->get_info(), bucket->get_attrs(), nullptr /* no callback */);
+ RGWBucketReshard br(static_cast<rgw::sal::RadosStore*>(store), bucket->get_info(), nullptr /* no callback */);
list<cls_rgw_bucket_instance_entry> status;
int r = br.get_status(dpp(), &status);
if (r < 0) {
if (bucket_initable) {
// we did not encounter an error, so let's work with the bucket
- RGWBucketReshard br(static_cast<rgw::sal::RadosStore*>(store), bucket->get_info(), bucket->get_attrs(),
- nullptr /* no callback */);
+ RGWBucketReshard br(static_cast<rgw::sal::RadosStore*>(store), bucket->get_info(), nullptr /* no callback */);
int ret = br.cancel(dpp());
if (ret < 0) {
if (ret == -EBUSY) {
RGWBucketReshard::RGWBucketReshard(rgw::sal::RadosStore* _store,
const RGWBucketInfo& _bucket_info,
- const map<string, bufferlist>& _bucket_attrs,
RGWBucketReshardLock* _outer_reshard_lock) :
- store(_store), bucket_info(_bucket_info), bucket_attrs(_bucket_attrs),
+ store(_store), bucket_info(_bucket_info),
reshard_lock(store, bucket_info, true),
outer_reshard_lock(_outer_reshard_lock)
{ }
rgw_bucket bucket;
RGWBucketInfo bucket_info;
- map<string, bufferlist> attrs;
ret = store->getRados()->get_bucket_info(store->svc(),
entry.tenant, entry.bucket_name,
bucket_info, nullptr,
- null_yield, dpp, &attrs);
+ null_yield, dpp, nullptr);
if (ret < 0 || bucket_info.bucket.bucket_id != entry.bucket_id) {
if (ret < 0) {
ldpp_dout(dpp, 0) << __func__ <<
}
{
- RGWBucketReshard br(store, bucket_info, attrs, nullptr);
+ RGWBucketReshard br(store, bucket_info, nullptr);
FaultInjector<std::string_view> f;
ret = br.execute(entry.new_num_shards, f, max_entries, dpp,
rgw::sal::RadosStore* store;
RGWBucketInfo bucket_info;
- std::map<std::string, bufferlist> bucket_attrs;
rgw::bucket_index_layout_generation prev_index;
RGWBucketReshardLock reshard_lock;
// manage
RGWBucketReshard(rgw::sal::RadosStore* _store,
const RGWBucketInfo& _bucket_info,
- const std::map<std::string, bufferlist>& _bucket_attrs,
RGWBucketReshardLock* _outer_reshard_lock);
int execute(int num_shards, FaultInjector<std::string_view>& f,
int max_op_entries, const DoutPrefixProvider *dpp,