]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
rgw: no need to RGWReshard::get before remove
authorOrit Wasserman <owasserm@redhat.com>
Thu, 29 Mar 2018 10:34:50 +0000 (13:34 +0300)
committerOrit Wasserman <owasserm@redhat.com>
Tue, 10 Apr 2018 10:57:17 +0000 (13:57 +0300)
Signed-off-by: Orit Wasserman <owasserm@redhat.com>
src/rgw/rgw_admin.cc
src/rgw/rgw_reshard.cc

index 786c7efdc00bd31196d36c81384e85cf43c671f0..e9dc04d29f18b4e8976d2049d683f8d0bde5f0c1 100644 (file)
@@ -5879,17 +5879,10 @@ next:
     entry.bucket_name = bucket_name;
     //entry.bucket_id = bucket_id;
 
-    ret = reshard.get(entry);
+    ret = reshard.remove(entry);
     if (ret < 0 && ret != -ENOENT) {
       cerr << "Error in getting bucket " << bucket_name << ": " << cpp_strerror(-ret) << std::endl;
       return ret;
-    } else if (ret != -ENOENT) {
-      ret = reshard.remove(entry);
-      if (ret < 0) {
-       cerr << "Error removing bucket " << bucket_name << " from resharding queue: " << cpp_strerror(-ret) <<
-         std::endl;
-       return ret;
-      }
     }
   }
 
index 5ea9b3859a6d41b56fcdc5e2c60035d3c21a7e36..cde521ff7dc47cdbce8206afe208dff8a3c044eb 100644 (file)
@@ -675,7 +675,10 @@ int RGWReshard::get(cls_rgw_reshard_entry& entry)
 
   int ret = cls_rgw_reshard_get(store->reshard_pool_ctx, logshard_oid, entry);
   if (ret < 0) {
-    lderr(store->ctx()) << "ERROR: failed to get entry from reshard log, oid=" << logshard_oid << " tenant=" << entry.tenant << " bucket=" << entry.bucket_name << dendl;
+    if (ret != -ENOENT) {
+      lderr(store->ctx()) << "ERROR: failed to get entry from reshard log, oid=" << logshard_oid << " tenant=" << entry.tenant <<
+       " bucket=" << entry.bucket_name << dendl;
+    }
     return ret;
   }