summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorYehuda Sadeh <yehuda@inktank.com>2013-03-06 19:32:21 -0800
committerYehuda Sadeh <yehuda@inktank.com>2013-03-07 09:47:56 -0800
commit9a09634d91b146586948c8d07160505b8d957ebb (patch)
tree7d4631614ce45cf84047fb8f850ecced65bcbbbb
parentaf6b6eddae073315c70bba4712511125360a0aad (diff)
downloadceph-wip-4363-next.tar.gz
rgw: don't iteraste through all objects when in namespacewip-4363-next
Fixes: #4363 Backport: argnaut, bobtail When listing objects in namespace don't iterate through all the objects, only go though the ones that starts with the namespace prefix Signed-off-by: Yehuda Sadeh <yehuda@inktank.com>
-rw-r--r--src/rgw/rgw_rados.cc22
1 files changed, 21 insertions, 1 deletions
diff --git a/src/rgw/rgw_rados.cc b/src/rgw/rgw_rados.cc
index 9675a75b63b..f413066c125 100644
--- a/src/rgw/rgw_rados.cc
+++ b/src/rgw/rgw_rados.cc
@@ -689,11 +689,22 @@ int RGWRados::list_objects(rgw_bucket& bucket, int max, string& prefix, string&
int count = 0;
string cur_marker = marker;
bool truncated;
+ string ns_prefix;
if (bucket_is_system(bucket)) {
return -EINVAL;
}
result.clear();
+ if (!ns.empty()) {
+ ns_prefix = "_";
+ ns_prefix += ns + "_";
+ if (cur_marker < ns_prefix) {
+ cur_marker = ns_prefix;
+ } else if (cur_marker.substr(0, ns.size()) > ns_prefix) {
+ truncated = false;
+ goto done;
+ }
+ }
do {
std::map<string, RGWObjEnt> ent_map;
@@ -707,8 +718,16 @@ int RGWRados::list_objects(rgw_bucket& bucket, int max, string& prefix, string&
string obj = eiter->first;
string key = obj;
- if (!rgw_obj::translate_raw_obj_to_obj_in_ns(obj, ns))
+ if (!rgw_obj::translate_raw_obj_to_obj_in_ns(obj, ns)) {
+ if (!ns.empty()) {
+ /* we're not under the namespace anymore, we're done */
+ truncated = false;
+ goto done;
+ }
+
+ /* we're not under the namespace this object is in, next! */
continue;
+ }
if (filter && !filter->filter(obj, key))
continue;
@@ -732,6 +751,7 @@ int RGWRados::list_objects(rgw_bucket& bucket, int max, string& prefix, string&
}
} while (truncated && count < max);
+done:
if (is_truncated)
*is_truncated = truncated;