Signed-off-by: Orit Wasserman <owasserm@redhat.com>
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;
- }
}
}
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;
}