X-Git-Url: https://git.proxmox.com/?p=ceph.git;a=blobdiff_plain;f=ceph%2Fsrc%2Frgw%2Frgw_cr_rados.cc;h=5fd8403178ada70e662ad09fd75a57cc620e4958;hp=edffa8061180c32092a940e9ae79c6d1b4d73f04;hb=28e407b858acd3bddc89f68583571f771bb42e46;hpb=dfcb7b53b2e4fcd2a5af0240d4975adc711ab96e diff --git a/ceph/src/rgw/rgw_cr_rados.cc b/ceph/src/rgw/rgw_cr_rados.cc index edffa8061..5fd840317 100644 --- a/ceph/src/rgw/rgw_cr_rados.cc +++ b/ceph/src/rgw/rgw_cr_rados.cc @@ -249,10 +249,10 @@ int RGWRadosSetOmapKeysCR::request_complete() RGWRadosGetOmapKeysCR::RGWRadosGetOmapKeysCR(RGWRados *_store, const rgw_raw_obj& _obj, const string& _marker, - map *_entries, int _max_entries) : RGWSimpleCoroutine(_store->ctx()), + std::set *_entries, int _max_entries) : RGWSimpleCoroutine(_store->ctx()), store(_store), marker(_marker), - entries(_entries), max_entries(_max_entries), rval(0), + entries(_entries), max_entries(_max_entries), obj(_obj), cn(NULL) { set_description() << "set omap keys dest=" << obj << " marker=" << marker; @@ -268,12 +268,21 @@ int RGWRadosGetOmapKeysCR::send_request() { set_status() << "send request"; librados::ObjectReadOperation op; - op.omap_get_vals2(marker, max_entries, entries, nullptr, &rval); + op.omap_get_keys2(marker, max_entries, entries, nullptr, nullptr); cn = stack->create_completion_notifier(); return ref.ioctx.aio_operate(ref.oid, cn->completion(), &op, NULL); } +int RGWRadosGetOmapKeysCR::request_complete() +{ + int r = cn->completion()->get_return_value(); + + set_status() << "request complete; ret=" << r; + + return r; +} + RGWRadosRemoveOmapKeysCR::RGWRadosRemoveOmapKeysCR(RGWRados *_store, const rgw_raw_obj& _obj, const set& _keys) : RGWSimpleCoroutine(_store->ctx()),