From: Yingxin Cheng <yingxin.cheng@intel.com>
Date: Thu, 25 Jan 2024 08:47:38 +0000 (+0800)
Subject: crimson/.../client_request: introduce instance_handle_t::enter_stage_sync()
X-Git-Tag: v19.1.1~236^2~4
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=9d790117f9c40633089f14b8185ac729bb95ae3a;p=ceph.git

crimson/.../client_request: introduce instance_handle_t::enter_stage_sync()

Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
(cherry picked from commit 4f532cfd8fdf9b7ac11aa327baca355062dabcb1)
---

diff --git a/src/crimson/osd/osd_operations/client_request.h b/src/crimson/osd/osd_operations/client_request.h
index eb27f91296499..c6ee364db5996 100644
--- a/src/crimson/osd/osd_operations/client_request.h
+++ b/src/crimson/osd/osd_operations/client_request.h
@@ -113,12 +113,15 @@ public:
       CompletionEvent
       > pg_tracking_events;
 
+    template <class BlockingEventT>
+    typename BlockingEventT::template Trigger<ClientRequest>
+    get_trigger(ClientRequest &op) {
+      return {std::get<BlockingEventT>(pg_tracking_events), op};
+    }
+
     template <typename BlockingEventT, typename InterruptorT=void, typename F>
     auto with_blocking_event(F &&f, ClientRequest &op) {
-      auto ret = std::forward<F>(f)(
-	typename BlockingEventT::template Trigger<ClientRequest>{
-	  std::get<BlockingEventT>(pg_tracking_events), op
-	});
+      auto ret = std::forward<F>(f)(get_trigger<BlockingEventT>(op));
       if constexpr (std::is_same_v<InterruptorT, void>) {
 	return ret;
       } else {
@@ -138,6 +141,12 @@ public:
 	  }, op);
     }
 
+    template <typename StageT>
+    void enter_stage_sync(StageT &stage, ClientRequest &op) {
+      handle.template enter_sync<ClientRequest>(
+          stage, get_trigger<typename StageT::BlockingEvent>(op));
+    }
+
     template <
       typename InterruptorT=void, typename BlockingObj, typename Method,
       typename... Args>