summaryrefslogtreecommitdiffstats
path: root/src/rgw/rgw_pubsub.h
diff options
context:
space:
mode:
authorCasey Bodley <cbodley@redhat.com>2022-07-13 16:22:09 +0200
committerCasey Bodley <cbodley@redhat.com>2022-07-13 20:24:30 +0200
commit3aee2a07975d425332f0746907e87d5f550ccb6b (patch)
tree24227932002759c0fb14c46b0625a08c59bc6ad6 /src/rgw/rgw_pubsub.h
parentrgw: remove unused sysobj ctx args (diff)
downloadceph-3aee2a07975d425332f0746907e87d5f550ccb6b.tar.xz
ceph-3aee2a07975d425332f0746907e87d5f550ccb6b.zip
rgw: remove RGWSysObjectCtx entirely
Signed-off-by: Casey Bodley <cbodley@redhat.com>
Diffstat (limited to 'src/rgw/rgw_pubsub.h')
-rw-r--r--src/rgw/rgw_pubsub.h15
1 files changed, 4 insertions, 11 deletions
diff --git a/src/rgw/rgw_pubsub.h b/src/rgw/rgw_pubsub.h
index f11b40b14b9..6335a5cb67a 100644
--- a/src/rgw/rgw_pubsub.h
+++ b/src/rgw/rgw_pubsub.h
@@ -601,7 +601,7 @@ class RGWPubSub
rgw::sal::RadosStore* store;
const std::string tenant;
- RGWSysObjectCtx obj_ctx;
+ RGWSI_SysObj* svc_sysobj;
rgw_raw_obj meta_obj;
@@ -785,7 +785,7 @@ template <class T>
int RGWPubSub::read(const rgw_raw_obj& obj, T* result, RGWObjVersionTracker* objv_tracker)
{
bufferlist bl;
- int ret = rgw_get_system_obj(obj_ctx,
+ int ret = rgw_get_system_obj(svc_sysobj,
obj.pool, obj.oid,
bl,
objv_tracker,
@@ -811,15 +811,8 @@ int RGWPubSub::write(const DoutPrefixProvider *dpp, const rgw_raw_obj& obj, cons
bufferlist bl;
encode(info, bl);
- int ret = rgw_put_system_obj(dpp, obj_ctx, obj.pool, obj.oid,
- bl, false, objv_tracker,
- real_time(), y);
- if (ret < 0) {
- return ret;
- }
-
- obj_ctx.invalidate(obj);
- return 0;
+ return rgw_put_system_obj(dpp, svc_sysobj, obj.pool, obj.oid,
+ bl, false, objv_tracker, real_time(), y);
}
#endif