]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
rgw: remove unused attrs from RGWBucketReshard
authorCasey Bodley <cbodley@redhat.com>
Tue, 15 Dec 2020 17:06:24 +0000 (12:06 -0500)
committerAdam C. Emerson <aemerson@redhat.com>
Tue, 1 Feb 2022 14:03:19 +0000 (09:03 -0500)
Signed-off-by: Casey Bodley <cbodley@redhat.com>
src/rgw/rgw_admin.cc
src/rgw/rgw_reshard.cc
src/rgw/rgw_reshard.h

index 54a11bc55a9a277bc4bcab25b20fb14dcb7cafe2..e69d1aec81b3933820bce2d84c4b445d6066742f 100644 (file)
@@ -7564,7 +7564,7 @@ next:
       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) {
@@ -7662,7 +7662,7 @@ next:
       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) {
@@ -7705,8 +7705,7 @@ next:
 
     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) {
index facaae79dfa321b29a0e488aa9536d8db58edbe5..5001e336682fac3cefb4814fe9d9de637cc569a7 100644 (file)
@@ -253,9 +253,8 @@ public:
 
 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)
 { }
@@ -1002,12 +1001,11 @@ int RGWReshard::process_single_logshard(int logshard_num, const DoutPrefixProvid
 
        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__ <<
@@ -1043,7 +1041,7 @@ int RGWReshard::process_single_logshard(int logshard_num, const DoutPrefixProvid
        }
 
        {
-       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,
index 2bba9a36902109c725361c7292f0765f4f9d7908..2594ae295bc3c4768677cd196bc4d61e52550c6d 100644 (file)
@@ -76,7 +76,6 @@ private:
 
   rgw::sal::RadosStore* store;
   RGWBucketInfo bucket_info;
-  std::map<std::string, bufferlist> bucket_attrs;
   rgw::bucket_index_layout_generation prev_index;
 
   RGWBucketReshardLock reshard_lock;
@@ -101,7 +100,6 @@ public:
   // 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,