RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-04-01 23:02:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

cls/rgw: expose cls_rgw_bucket_list_op for single shard

Browse Source 
Signed-off-by: Casey Bodley <cbodley@redhat.com>
This commit is contained in:
Casey Bodley 2019-04-19 18:37:35 -04:00
parent 6fe5907081
commit cd1fc96c5c
2 changed files with 25 additions and 7 deletions

25
src/cls/rgw/cls_rgw_client.cc
View File

@ -209,12 +209,13 @@ void cls_rgw_bucket_complete_op(ObjectWriteOperation& o, RGWModifyOp op, string&
o.exec(RGW_CLASS, RGW_BUCKET_COMPLETE_OP, in);
}
static bool issue_bucket_list_op(librados::IoCtx& io_ctx, const string& oid,
const cls_rgw_obj_key& start_obj,
const string& filter_prefix,
uint32_t num_entries, bool list_versions,
BucketIndexAioManager *manager,
rgw_cls_list_ret *pdata) {
void cls_rgw_bucket_list_op(librados::ObjectReadOperation& op,
const cls_rgw_obj_key& start_obj,
const std::string& filter_prefix,
uint32_t num_entries,
bool list_versions,
rgw_cls_list_ret* result)
{
bufferlist in;
rgw_cls_list_op call;
call.start_obj = start_obj;
@ -223,8 +224,18 @@ static bool issue_bucket_list_op(librados::IoCtx& io_ctx, const string& oid,
call.list_versions = list_versions;
encode(call, in);
op.exec(RGW_CLASS, RGW_BUCKET_LIST, in, new ClsBucketIndexOpCtx<rgw_cls_list_ret>(result, NULL));
}
static bool issue_bucket_list_op(librados::IoCtx& io_ctx, const string& oid,
const cls_rgw_obj_key& start_obj,
const string& filter_prefix,
uint32_t num_entries, bool list_versions,
BucketIndexAioManager *manager,
rgw_cls_list_ret *pdata) {
librados::ObjectReadOperation op;
op.exec(RGW_CLASS, RGW_BUCKET_LIST, in, new ClsBucketIndexOpCtx<rgw_cls_list_ret>(pdata, NULL));
cls_rgw_bucket_list_op(op, start_obj, filter_prefix,
num_entries, list_versions, pdata);
return manager->aio_operate(io_ctx, oid, &op);
}

7
src/cls/rgw/cls_rgw_client.h
View File

@ -422,6 +422,13 @@ public:
start_obj(_start_obj), filter_prefix(_filter_prefix), num_entries(_num_entries), list_versions(_list_versions), result(list_results) {}
};
void cls_rgw_bucket_list_op(librados::ObjectReadOperation& op,
const cls_rgw_obj_key& start_obj,
const std::string& filter_prefix,
uint32_t num_entries,
bool list_versions,
rgw_cls_list_ret* result);
class CLSRGWIssueBILogList : public CLSRGWConcurrentIO {
map<int, cls_rgw_bi_log_list_ret>& result;
BucketIndexShardsManager& marker_mgr;