return (*bucket)->load_bucket(dpp, y);
}
-int DaosStore::load_bucket(const DoutPrefixProvider* dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y) {
- ldpp_dout(dpp, 20) << "get_bucket" << dendl;
- rgw_bucket b;
-
- b.tenant = tenant;
- b.name = name;
-
- return load_bucket(dpp, u, b, bucket, y);
-}
-
bool DaosStore::is_meta_master() { return true; }
int DaosStore::forward_request_to_master(const DoutPrefixProvider* dpp,
int load_bucket(const DoutPrefixProvider* dpp, User* u,
const rgw_bucket& b, std::unique_ptr<Bucket>* bucket,
optional_yield y) override;
- int load_bucket(const DoutPrefixProvider* dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket,
- optional_yield y) override;
virtual bool is_meta_master() override;
virtual int forward_request_to_master(const DoutPrefixProvider* dpp,
User* user, obj_version* objv,
return (*bucket)->load_bucket(dpp, y);
}
-int MotrStore::load_bucket(const DoutPrefixProvider *dpp, User* u, const std::string& tenant, const std::string& name, std::unique_ptr<Bucket>* bucket, optional_yield y)
-{
- rgw_bucket b;
-
- b.tenant = tenant;
- b.name = name;
-
- return load_bucket(dpp, u, b, bucket, y);
-}
-
bool MotrStore::is_meta_master()
{
return true;
std::unique_ptr<Bucket> get_bucket(User* u, const RGWBucketInfo& i) override;
int load_bucket(const DoutPrefixProvider *dpp, User* u, const rgw_bucket& b,
std::unique_ptr<Bucket>* bucket, optional_yield y) override;
- int load_bucket(const DoutPrefixProvider *dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y) override;
virtual bool is_meta_master() override;
virtual int forward_request_to_master(const DoutPrefixProvider *dpp, User* user, obj_version* objv,
bufferlist& in_data, JSONParser *jp, req_info& info,
return std::make_unique<POSIXBucket>(this, root_fd, i, u);
}
-int POSIXDriver::load_bucket(const DoutPrefixProvider* dpp, User* u, const std::string& tenant, const std::string& name, std::unique_ptr<Bucket>* bucket, optional_yield y)
-{
- rgw_bucket b;
-
- b.tenant = tenant;
- b.name = name;
-
- return load_bucket(dpp, u, b, bucket, y);
-}
-
std::string POSIXDriver::zone_unique_trans_id(const uint64_t unique_num)
{
char buf[41]; /* 2 + 21 + 1 + 16 (timestamp can consume up to 16) + 1 */
virtual int load_bucket(const DoutPrefixProvider* dpp, User* u, const
rgw_bucket& b, std::unique_ptr<Bucket>* bucket,
optional_yield y) override;
- virtual int load_bucket(const DoutPrefixProvider* dpp, User* u, const
- std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y) override;
virtual std::string zone_unique_trans_id(const uint64_t unique_num) override;
virtual std::unique_ptr<Writer> get_append_writer(const DoutPrefixProvider *dpp,
return (*bucket)->load_bucket(dpp, y);
}
-int RadosStore::load_bucket(const DoutPrefixProvider* dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y)
-{
- rgw_bucket b;
-
- b.tenant = tenant;
- b.name = name;
-
- return load_bucket(dpp, u, b, bucket, y);
-}
-
bool RadosStore::is_meta_master()
{
return svc()->zone->is_meta_master();
std::unique_ptr<Bucket> get_bucket(User* u, const RGWBucketInfo& i) override;
int load_bucket(const DoutPrefixProvider* dpp, User* u, const rgw_bucket& b,
std::unique_ptr<Bucket>* bucket, optional_yield y) override;
- int load_bucket(const DoutPrefixProvider* dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y) override;
virtual bool is_meta_master() override;
virtual int forward_request_to_master(const DoutPrefixProvider *dpp, User* user, obj_version* objv,
bufferlist& in_data, JSONParser* jp, req_info& info,
* bucket must still be allocated to support bucket->create(). */
virtual int load_bucket(const DoutPrefixProvider* dpp, User* u, const rgw_bucket& b,
std::unique_ptr<Bucket>* bucket, optional_yield y) = 0;
- /** Load a Bucket by name. Queries driver for bucket info. */
- virtual int load_bucket(const DoutPrefixProvider* dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y) = 0;
/** For multisite, this driver is the zone's master */
virtual bool is_meta_master() = 0;
/** For multisite, forward an OP to the zone's master */
return (*bucket)->load_bucket(dpp, y);
}
- int DBStore::load_bucket(const DoutPrefixProvider *dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y)
- {
- rgw_bucket b;
-
- b.tenant = tenant;
- b.name = name;
-
- return load_bucket(dpp, u, b, bucket, y);
- }
-
bool DBStore::is_meta_master()
{
return true;
std::unique_ptr<Bucket> get_bucket(User* u, const RGWBucketInfo& i) override;
int load_bucket(const DoutPrefixProvider *dpp, User* u, const rgw_bucket& b,
std::unique_ptr<Bucket>* bucket, optional_yield y) override;
- int load_bucket(const DoutPrefixProvider *dpp, User* u,
- const std::string& tenant, const std::string&name,
- std::unique_ptr<Bucket>* bucket, optional_yield y) override;
virtual bool is_meta_master() override;
virtual int forward_request_to_master(const DoutPrefixProvider *dpp, User* user, obj_version* objv,
bufferlist& in_data, JSONParser *jp, req_info& info,
return ret;
}
-int FilterDriver::load_bucket(const DoutPrefixProvider* dpp, User* u,
- const std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y)
-{
- std::unique_ptr<Bucket> nb;
- const int ret = next->load_bucket(dpp, nextUser(u), tenant, name, &nb, y);
- *bucket = std::make_unique<FilterBucket>(std::move(nb), u);
- return ret;
-}
-
bool FilterDriver::is_meta_master()
{
return next->is_meta_master();
std::unique_ptr<User>* user) override;
virtual std::unique_ptr<Object> get_object(const rgw_obj_key& k) override;
std::unique_ptr<Bucket> get_bucket(User* u, const RGWBucketInfo& i) override;
- int load_bucket(const DoutPrefixProvider* dpp, User* u, const
- rgw_bucket& b, std::unique_ptr<Bucket>* bucket,
+ int load_bucket(const DoutPrefixProvider* dpp, User* u,
+ const rgw_bucket& b, std::unique_ptr<Bucket>* bucket,
optional_yield y) override;
- int load_bucket(const DoutPrefixProvider* dpp, User* u, const
- std::string& tenant, const std::string& name,
- std::unique_ptr<Bucket>* bucket, optional_yield y) override;
virtual bool is_meta_master() override;
virtual int forward_request_to_master(const DoutPrefixProvider *dpp, User* user,
obj_version* objv, bufferlist& in_data,