From: Casey Bodley <cbodley@redhat.com>
Date: Wed, 22 May 2024 12:24:26 +0000 (-0400)
Subject: rgw/pubsub: Waiter unlocks before suspend
X-Git-Tag: v19.2.1~172^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F60133%2Fhead;p=ceph.git

rgw/pubsub: Waiter unlocks before suspend

Signed-off-by: Casey Bodley <cbodley@redhat.com>
(cherry picked from commit 629ad4562bdfce798090788236e6aa0b25476e9d)
---

diff --git a/src/rgw/driver/rados/rgw_pubsub_push.cc b/src/rgw/driver/rados/rgw_pubsub_push.cc
index 69eb5c9ff326..2d569d1b0c99 100644
--- a/src/rgw/driver/rados/rgw_pubsub_push.cc
+++ b/src/rgw/driver/rados/rgw_pubsub_push.cc
@@ -154,10 +154,10 @@ public:
       auto yield = y.get_yield_context();
       auto&& token = yield[ec];
       boost::asio::async_initiate<boost::asio::yield_context, Signature>(
-          [this] (auto handler, auto ex) {
+          [this, &l] (auto handler, auto ex) {
             completion = Completion::create(ex, std::move(handler));
+            l.unlock(); // unlock before suspend
           }, token, yield.get_executor());
-      l.unlock();
       return -ec.value();
     }
     cond.wait(l, [this]{return (done==true);});