From 6f9a4772bc929da0f4d26470311a6a4c5b98eca0 Mon Sep 17 00:00:00 2001 From: Casey Bodley Date: Tue, 6 Oct 2020 17:59:26 -0400 Subject: [PATCH] rgw: add exclusive flag to RGWSimpleRadosWriteCR Signed-off-by: Casey Bodley --- src/rgw/rgw_cr_rados.h | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/src/rgw/rgw_cr_rados.h b/src/rgw/rgw_cr_rados.h index 36239518c8a0f..f07eedbc3bf44 100644 --- a/src/rgw/rgw_cr_rados.h +++ b/src/rgw/rgw_cr_rados.h @@ -526,15 +526,17 @@ class RGWSimpleRadosWriteCR : public RGWSimpleCoroutine { bufferlist bl; rgw_raw_obj obj; RGWObjVersionTracker *objv_tracker; + bool exclusive; RGWAsyncPutSystemObj *req{nullptr}; public: RGWSimpleRadosWriteCR(const DoutPrefixProvider *_dpp, - RGWAsyncRadosProcessor *_async_rados, RGWSI_SysObj *_svc, - const rgw_raw_obj& _obj, - const T& _data, RGWObjVersionTracker *objv_tracker = nullptr) + RGWAsyncRadosProcessor *_async_rados, RGWSI_SysObj *_svc, + const rgw_raw_obj& _obj, const T& _data, + RGWObjVersionTracker *objv_tracker = nullptr, + bool exclusive = false) : RGWSimpleCoroutine(_svc->ctx()), dpp(_dpp), async_rados(_async_rados), - svc(_svc), obj(_obj), objv_tracker(objv_tracker) { + svc(_svc), obj(_obj), objv_tracker(objv_tracker), exclusive(exclusive) { encode(_data, bl); } @@ -551,7 +553,7 @@ public: int send_request(const DoutPrefixProvider *dpp) override { req = new RGWAsyncPutSystemObj(dpp, this, stack->create_completion_notifier(), - svc, objv_tracker, obj, false, std::move(bl)); + svc, objv_tracker, obj, exclusive, std::move(bl)); async_rados->queue(req); return 0; } -- 2.39.5