int RGWOrphanStore::init()
{
const char *log_pool = store->get_zone_params().log_pool.name.c_str();
- librados::Rados *rados = store->get_rados();
+ librados::Rados *rados = store->get_rados_handle();
int r = rados->ioctx_create(log_pool, ioctx);
if (r < 0) {
cerr << "ERROR: failed to open log pool (" << store->get_zone_params().log_pool.name << " ret=" << r << std::endl;
int RGWOrphanSearch::build_all_oids_index()
{
- librados::Rados *rados = store->get_rados();
+ librados::Rados *rados = store->get_rados_handle();
librados::IoCtx ioctx;
librados::IoCtx data_ioctx;
- librados::Rados *rados = store->get_rados();
+ librados::Rados *rados = store->get_rados_handle();
int ret = rados->ioctx_create(search_info.pool.c_str(), data_ioctx);
if (ret < 0) {
rest_master_conn(NULL),
meta_mgr(NULL), data_log(NULL) {}
- librados::Rados *get_rados() { return rados; }
-
uint64_t get_new_req_id() {
return max_req_id.inc();
}
return zone_public_config.log_meta;
}
+ librados::Rados* get_rados_handle();
+
private:
/**
* This is a helper method, it generates a list of bucket index objects with the given
uint64_t instance_id();
uint64_t next_bucket_id();
-
- librados::Rados* get_rados_handle();
};
class RGWStoreManager {