From: Casey Bodley <cbodley@redhat.com>
Date: Thu, 15 Feb 2024 03:42:10 +0000 (-0500)
Subject: rgw/pubsub: Waiter uses async_initiate
X-Git-Tag: v20.0.0~1890^2~6
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=3618271b30b6b48de98c37cdc51de9b7475ed8a0;p=ceph.git

rgw/pubsub: Waiter uses async_initiate

Signed-off-by: Casey Bodley <cbodley@redhat.com>
---

diff --git a/src/rgw/driver/rados/rgw_pubsub_push.cc b/src/rgw/driver/rados/rgw_pubsub_push.cc
index 16937ef23ec..8906d2e6cb9 100644
--- a/src/rgw/driver/rados/rgw_pubsub_push.cc
+++ b/src/rgw/driver/rados/rgw_pubsub_push.cc
@@ -136,7 +136,6 @@ namespace {
 class Waiter {
   using Signature = void(boost::system::error_code);
   using Completion = ceph::async::Completion<Signature>;
-  using CompletionInit = boost::asio::async_completion<spawn::yield_context, Signature>;
   std::unique_ptr<Completion> completion = nullptr;
   int ret;
 
@@ -152,12 +151,13 @@ public:
     }
     if (y) {
       boost::system::error_code ec;
-      auto&& token = y.get_yield_context()[ec];
-      CompletionInit init(token);
-      completion = Completion::create(y.get_io_context().get_executor(),
-          std::move(init.completion_handler));
+      auto yield = y.get_yield_context();
+      auto&& token = yield[ec];
+      boost::asio::async_initiate<spawn::yield_context, Signature>(
+          [this] (auto handler, auto ex) {
+            completion = Completion::create(ex, std::move(handler));
+          }, token, yield.get_executor());
       l.unlock();
-      init.result.get();
       return -ec.value();
     }
     cond.wait(l, [this]{return (done==true);});