From 741d2bb82d87987442aa48d2601889bc1f193a74 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 | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/rgw/rgw_cr_rados.h b/src/rgw/rgw_cr_rados.h index fa737d07a461b..8d5c9f8ac60bd 100644 --- a/src/rgw/rgw_cr_rados.h +++ b/src/rgw/rgw_cr_rados.h @@ -505,14 +505,16 @@ class RGWSimpleRadosWriteCR : public RGWSimpleCoroutine { bufferlist bl; rgw_raw_obj obj; RGWObjVersionTracker *objv_tracker; + bool exclusive; RGWAsyncPutSystemObj *req{nullptr}; public: RGWSimpleRadosWriteCR(RGWAsyncRadosProcessor *_async_rados, RGWSI_SysObj *_svc, - const rgw_raw_obj& _obj, - const T& _data, RGWObjVersionTracker *objv_tracker = nullptr) + const rgw_raw_obj& _obj, const T& _data, + RGWObjVersionTracker *objv_tracker = nullptr, + bool exclusive = false) : RGWSimpleCoroutine(_svc->ctx()), 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); } @@ -529,7 +531,7 @@ public: int send_request() override { req = new RGWAsyncPutSystemObj(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