return bucket_info;
}
-int DaosBucket::remove_bucket(const DoutPrefixProvider* dpp,
- bool delete_children, optional_yield y) {
+int DaosBucket::remove(const DoutPrefixProvider* dpp,
+ bool delete_children, optional_yield y) {
ldpp_dout(dpp, 20) << "DEBUG: remove_bucket, delete_children="
<< delete_children << dendl;
nullptr);
}
-int DaosBucket::remove_bucket_bypass_gc(int concurrent_max,
- bool keep_index_consistent,
- optional_yield y,
- const DoutPrefixProvider* dpp) {
+int DaosBucket::remove_bypass_gc(int concurrent_max,
+ bool keep_index_consistent,
+ optional_yield y,
+ const DoutPrefixProvider* dpp) {
ldpp_dout(dpp, 20) << "DEBUG: remove_bucket_bypass_gc, concurrent_max="
<< concurrent_max
virtual std::unique_ptr<Object> get_object(const rgw_obj_key& k) override;
virtual int list(const DoutPrefixProvider* dpp, ListParams&, int,
ListResults&, optional_yield y) override;
- virtual int remove_bucket(const DoutPrefixProvider* dpp, bool delete_children,
- optional_yield y) override;
- virtual int remove_bucket_bypass_gc(int concurrent_max,
- bool keep_index_consistent,
- optional_yield y,
- const DoutPrefixProvider* dpp) override;
+ virtual int remove(const DoutPrefixProvider* dpp, bool delete_children,
+ optional_yield y) override;
+ virtual int remove_bypass_gc(int concurrent_max,
+ bool keep_index_consistent,
+ optional_yield y,
+ const DoutPrefixProvider* dpp) override;
virtual RGWAccessControlPolicy& get_acl(void) override { return acls; }
virtual int set_acl(const DoutPrefixProvider* dpp,
RGWAccessControlPolicy& acl, optional_yield y) override;
return 0;
}
-int MotrBucket::remove_bucket(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y)
+int MotrBucket::remove(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y)
{
int ret;
return ret;
}
-int MotrBucket::remove_bucket_bypass_gc(int concurrent_max, bool
+int MotrBucket::remove_bypass_gc(int concurrent_max, bool
keep_index_consistent,
optional_yield y, const
DoutPrefixProvider *dpp) {
virtual std::unique_ptr<Object> get_object(const rgw_obj_key& k) override;
virtual int list(const DoutPrefixProvider *dpp, ListParams&, int, ListResults&, optional_yield y) override;
- virtual int remove_bucket(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y) override;
- virtual int remove_bucket_bypass_gc(int concurrent_max, bool
+ virtual int remove(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y) override;
+ virtual int remove_bypass_gc(int concurrent_max, bool
keep_index_consistent,
optional_yield y, const
DoutPrefixProvider *dpp) override;
return write_attrs(dpp, y);
}
-int POSIXBucket::remove_bucket(const DoutPrefixProvider* dpp,
- bool delete_children,
- optional_yield y)
+int POSIXBucket::remove(const DoutPrefixProvider* dpp,
+ bool delete_children,
+ optional_yield y)
{
return delete_directory(parent_fd, get_fname().c_str(),
delete_children, dpp);
}
-int POSIXBucket::remove_bucket_bypass_gc(int concurrent_max,
- bool keep_index_consistent,
- optional_yield y,
- const DoutPrefixProvider *dpp)
+int POSIXBucket::remove_bypass_gc(int concurrent_max,
+ bool keep_index_consistent,
+ optional_yield y,
+ const DoutPrefixProvider *dpp)
{
- return remove_bucket(dpp, true, y);
+ return remove(dpp, true, y);
}
int POSIXBucket::load_bucket(const DoutPrefixProvider* dpp, optional_yield y)
if (!b->versioned()) {
if (shadow) {
- ret = shadow->remove_bucket(dpp, true, y);
+ ret = shadow->remove(dpp, true, y);
if (ret < 0) {
return ret;
}
return ret;
}
- shadow->remove_bucket(dpp, true, y);
+ shadow->remove(dpp, true, y);
return 0;
}
ListResults&, optional_yield y) override;
virtual int merge_and_store_attrs(const DoutPrefixProvider* dpp,
Attrs& new_attrs, optional_yield y) override;
- virtual int remove_bucket(const DoutPrefixProvider* dpp, bool delete_children,
- optional_yield y) override;
- virtual int remove_bucket_bypass_gc(int concurrent_max,
- bool keep_index_consistent,
- optional_yield y,
- const DoutPrefixProvider *dpp) override;
+ virtual int remove(const DoutPrefixProvider* dpp, bool delete_children,
+ optional_yield y) override;
+ virtual int remove_bypass_gc(int concurrent_max,
+ bool keep_index_consistent,
+ optional_yield y,
+ const DoutPrefixProvider *dpp) override;
virtual int create(const DoutPrefixProvider* dpp,
const CreateParams& params,
optional_yield y) override;
return ret;
if (bypass_gc)
- ret = bucket->remove_bucket_bypass_gc(op_state.get_max_aio(), keep_index_consistent, y, dpp);
+ ret = bucket->remove_bypass_gc(op_state.get_max_aio(), keep_index_consistent, y, dpp);
else
- ret = bucket->remove_bucket(dpp, op_state.will_delete_children(), y);
+ ret = bucket->remove(dpp, op_state.will_delete_children(), y);
return ret;
}
return;
}
- op_ret = bucket->remove_bucket(s, delete_children, s->yield);
+ op_ret = bucket->remove(s, delete_children, s->yield);
}
class RGWOp_Set_Bucket_Quota : public RGWRESTOp {
RadosBucket::~RadosBucket() {}
-int RadosBucket::remove_bucket(const DoutPrefixProvider* dpp,
- bool delete_children,
- optional_yield y)
+int RadosBucket::remove(const DoutPrefixProvider* dpp,
+ bool delete_children,
+ optional_yield y)
{
int ret;
return ret;
}
-int RadosBucket::remove_bucket_bypass_gc(int concurrent_max, bool
- keep_index_consistent,
- optional_yield y, const
- DoutPrefixProvider *dpp)
+int RadosBucket::remove_bypass_gc(int concurrent_max, bool
+ keep_index_consistent,
+ optional_yield y, const
+ DoutPrefixProvider *dpp)
{
int ret;
map<RGWObjCategory, RGWStorageStats> stats;
// this function can only be run if caller wanted children to be
// deleted, so we can ignore the check for children as any that
// remain are detritus from a prior bug
- ret = remove_bucket(dpp, true, y);
+ ret = remove(dpp, true, y);
if (ret < 0) {
ldpp_dout(dpp, -1) << "ERROR: could not remove bucket " << this << dendl;
return ret;
virtual ~RadosBucket();
virtual std::unique_ptr<Object> get_object(const rgw_obj_key& k) override;
virtual int list(const DoutPrefixProvider* dpp, ListParams&, int, ListResults&, optional_yield y) override;
- virtual int remove_bucket(const DoutPrefixProvider* dpp, bool delete_children, optional_yield y) override;
- virtual int remove_bucket_bypass_gc(int concurrent_max, bool
- keep_index_consistent,
- optional_yield y, const
- DoutPrefixProvider *dpp) override;
+ virtual int remove(const DoutPrefixProvider* dpp, bool delete_children, optional_yield y) override;
+ virtual int remove_bypass_gc(int concurrent_max, bool
+ keep_index_consistent,
+ optional_yield y, const
+ DoutPrefixProvider *dpp) override;
virtual RGWAccessControlPolicy& get_acl(void) override { return acls; }
virtual int set_acl(const DoutPrefixProvider* dpp, RGWAccessControlPolicy& acl, optional_yield y) override;
int create(const DoutPrefixProvider* dpp, const CreateParams& params,
return ret;
}
- ret = bucket->remove_bucket(dpp, true, y);
+ ret = bucket->remove(dpp, true, y);
if (ret < 0) {
set_err_msg(err_msg, "unable to delete user data");
return ret;
// do nothing; it will already have been logged
}
- op_ret = s->bucket->remove_bucket(this, false, y);
+ op_ret = s->bucket->remove(this, false, y);
if (op_ret < 0 && op_ret == -ECANCELED) {
// lost a race, either with mdlog sync or another delete bucket operation.
// in either case, we've already called ctl.bucket->unlink_bucket()
goto delop_fail;
}
}
- ret = bucket->remove_bucket(dpp, false, s->yield);
+ ret = bucket->remove(dpp, false, s->yield);
if (ret < 0) {
goto delop_fail;
}
/** Set the cached attributes on this bucket */
virtual int set_attrs(Attrs a) = 0;
/** Remove this bucket from the backing store */
- virtual int remove_bucket(const DoutPrefixProvider* dpp, bool delete_children, optional_yield y) = 0;
+ virtual int remove(const DoutPrefixProvider* dpp, bool delete_children, optional_yield y) = 0;
/** Remove this bucket, bypassing garbage collection. May be removed */
- virtual int remove_bucket_bypass_gc(int concurrent_max, bool
- keep_index_consistent,
- optional_yield y, const
- DoutPrefixProvider *dpp) = 0;
+ virtual int remove_bypass_gc(int concurrent_max, bool
+ keep_index_consistent,
+ optional_yield y, const
+ DoutPrefixProvider *dpp) = 0;
/** Get then ACL for this bucket */
virtual RGWAccessControlPolicy& get_acl(void) = 0;
/** Set the ACL for this bucket */
return 0;
}
- int DBBucket::remove_bucket(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y)
+ int DBBucket::remove(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y)
{
int ret;
return ret;
}
- int DBBucket::remove_bucket_bypass_gc(int concurrent_max, bool
- keep_index_consistent,
- optional_yield y, const
- DoutPrefixProvider *dpp) {
+ int DBBucket::remove_bypass_gc(int concurrent_max, bool
+ keep_index_consistent,
+ optional_yield y, const
+ DoutPrefixProvider *dpp) {
return 0;
}
virtual std::unique_ptr<Object> get_object(const rgw_obj_key& k) override;
virtual int list(const DoutPrefixProvider *dpp, ListParams&, int, ListResults&, optional_yield y) override;
- virtual int remove_bucket(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y) override;
- virtual int remove_bucket_bypass_gc(int concurrent_max, bool
- keep_index_consistent,
- optional_yield y, const
- DoutPrefixProvider *dpp) override;
+ virtual int remove(const DoutPrefixProvider *dpp, bool delete_children, optional_yield y) override;
+ virtual int remove_bypass_gc(int concurrent_max, bool
+ keep_index_consistent,
+ optional_yield y, const
+ DoutPrefixProvider *dpp) override;
virtual RGWAccessControlPolicy& get_acl(void) override { return acls; }
virtual int set_acl(const DoutPrefixProvider *dpp, RGWAccessControlPolicy& acl, optional_yield y) override;
int create(const DoutPrefixProvider* dpp,
return next->list(dpp, params, max, results, y);
}
-int FilterBucket::remove_bucket(const DoutPrefixProvider* dpp,
- bool delete_children,
- optional_yield y)
+int FilterBucket::remove(const DoutPrefixProvider* dpp,
+ bool delete_children,
+ optional_yield y)
{
- return next->remove_bucket(dpp, delete_children, y);
+ return next->remove(dpp, delete_children, y);
}
-int FilterBucket::remove_bucket_bypass_gc(int concurrent_max,
- bool keep_index_consistent,
- optional_yield y,
- const DoutPrefixProvider *dpp)
+int FilterBucket::remove_bypass_gc(int concurrent_max,
+ bool keep_index_consistent,
+ optional_yield y,
+ const DoutPrefixProvider *dpp)
{
- return next->remove_bucket_bypass_gc(concurrent_max, keep_index_consistent, y, dpp);
+ return next->remove_bypass_gc(concurrent_max, keep_index_consistent, y, dpp);
}
int FilterBucket::set_acl(const DoutPrefixProvider* dpp,
ListResults&, optional_yield y) override;
virtual Attrs& get_attrs(void) override { return next->get_attrs(); }
virtual int set_attrs(Attrs a) override { return next->set_attrs(a); }
- virtual int remove_bucket(const DoutPrefixProvider* dpp, bool delete_children,
- optional_yield y) override;
- virtual int remove_bucket_bypass_gc(int concurrent_max, bool
- keep_index_consistent,
- optional_yield y, const
- DoutPrefixProvider *dpp) override;
+ virtual int remove(const DoutPrefixProvider* dpp, bool delete_children,
+ optional_yield y) override;
+ virtual int remove_bypass_gc(int concurrent_max, bool
+ keep_index_consistent,
+ optional_yield y, const
+ DoutPrefixProvider *dpp) override;
virtual RGWAccessControlPolicy& get_acl(void) override { return next->get_acl(); }
virtual int set_acl(const DoutPrefixProvider* dpp, RGWAccessControlPolicy& acl,
optional_yield y) override;