virtual bool supports_omap() { return false; }
- virtual int omap_get(rgw_obj& obj, string& start_after, int max, bufferlist& header, std::map<string, bufferlist>& m) { return -ENOTSUP; }
+ virtual int omap_get_all(rgw_obj& obj, bufferlist& header, std::map<string, bufferlist>& m) { return -ENOTSUP; }
virtual int omap_set(rgw_obj& obj, std::string& key, bufferlist& bl) { return -ENOTSUP; }
virtual int omap_set(rgw_obj& obj, map<std::string, bufferlist>& m) { return -ENOTSUP; }
virtual int omap_del(rgw_obj& obj, std::string& key) { return -ENOTSUP; }
if (ret < 0)
return ret;
- string start_after;
- ret = rgwstore->omap_get(obj, start_after, -1, header, parts_map);
+ ret = rgwstore->omap_get_all(obj, header, parts_map);
if (ret < 0)
return ret;
string pool_name;
rgw_obj obj(pi_buckets_rados, avail_pools);
- string start_after;
- int ret = omap_get(obj, start_after, -1, header, m);
+ int ret = omap_get_all(obj, header, m);
if (ret < 0 || !m.size()) {
vector<string> names;
names.push_back(default_storage_pool);
string pool_name;
rgw_obj obj(pi_buckets_rados, avail_pools);
- string start_after;
- int ret = omap_get(obj, start_after, -1, header, m);
+ int ret = omap_get_all(obj, header, m);
if (ret < 0)
return ret;
return ret;
}
-int RGWRados::omap_get(rgw_obj& obj, string& start_after, int max, bufferlist& header, std::map<string, bufferlist>& m)
+int RGWRados::omap_get_all(rgw_obj& obj, bufferlist& header, std::map<string, bufferlist>& m)
{
bufferlist bl;
librados::IoCtx io_ctx;
io_ctx.locator_set_key(key);
- r = io_ctx.omap_get_vals(oid, start_after, max, &m);
+ string start_after;
+ r = io_ctx.omap_get_vals(oid, start_after, -1, &m);
if (r < 0)
return r;
virtual int obj_stat(void *ctx, rgw_obj& obj, uint64_t *psize, time_t *pmtime, map<string, bufferlist> *attrs, bufferlist *first_chunk);
virtual bool supports_omap() { return true; }
- virtual int omap_get(rgw_obj& obj, string& start_after, int max, bufferlist& header, std::map<string, bufferlist>& m);
+ virtual int omap_get_all(rgw_obj& obj, bufferlist& header, std::map<string, bufferlist>& m);
virtual int omap_set(rgw_obj& obj, std::string& key, bufferlist& bl);
virtual int omap_set(rgw_obj& obj, map<std::string, bufferlist>& m);
virtual int omap_del(rgw_obj& obj, std::string& key);
bufferlist header;
map<string,bufferlist> m;
- string start_after;
- ret = rgwstore->omap_get(obj, start_after, -1, header, m);
+ ret = rgwstore->omap_get_all(obj, header, m);
if (ret == -ENOENT)
ret = 0;