From: Radosław Zarzyński <rzarzyns@redhat.com>
Date: Sun, 3 Apr 2022 11:23:53 +0000 (+0200)
Subject: crimson/osd: switch all ClientRequest-related pipeline stages to the new infra
X-Git-Tag: v18.0.0~947^2~43
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=5c83589ae51cd3138b9fa3f7c0c539f013392d3d;p=ceph.git

crimson/osd: switch all ClientRequest-related pipeline stages to the new infra

Signed-off-by: Radosław Zarzyński <rzarzyns@redhat.com>
---

diff --git a/src/crimson/osd/osd_operations/client_request.h b/src/crimson/osd/osd_operations/client_request.h
index db99fd85e9f4..5777bd451842 100644
--- a/src/crimson/osd/osd_operations/client_request.h
+++ b/src/crimson/osd/osd_operations/client_request.h
@@ -26,24 +26,29 @@ class ClientRequest final : public OperationT<ClientRequest>,
 
 public:
   class ConnectionPipeline {
-    OrderedExclusivePhase await_map = {
-      "ClientRequest::ConnectionPipeline::await_map"
-    };
-    OrderedExclusivePhase get_pg = {
-      "ClientRequest::ConnectionPipeline::get_pg"
-    };
+    struct AwaitMap : OrderedExclusivePhaseT<AwaitMap> {
+      static constexpr auto type_name =
+        "ClientRequest::ConnectionPipeline::await_map";
+    } await_map;
+
+    struct GetPG : OrderedExclusivePhaseT<GetPG> {
+      static constexpr auto type_name =
+        "ClientRequest::ConnectionPipeline::get_pg";
+    } get_pg;
+
     friend class ClientRequest;
   };
+
   class PGPipeline : public CommonPGPipeline {
-    OrderedExclusivePhase await_map = {
-      "ClientRequest::PGPipeline::await_map"
-    };
-    OrderedConcurrentPhase wait_repop = {
-      "ClientRequest::PGPipeline::wait_repop"
-    };
-    OrderedExclusivePhase send_reply = {
-      "ClientRequest::PGPipeline::send_reply"
-    };
+    struct AwaitMap : OrderedExclusivePhaseT<AwaitMap> {
+      static constexpr auto type_name = "ClientRequest::PGPipeline::await_map";
+    } await_map;
+    struct WaitRepop : OrderedConcurrentPhaseT<WaitRepop> {
+      static constexpr auto type_name = "ClientRequest::PGPipeline::wait_repop";
+    } wait_repop;
+    struct SendReply : OrderedExclusivePhaseT<SendReply> {
+      static constexpr auto type_name = "ClientRequest::PGPipeline::send_reply";
+    } send_reply;
     friend class ClientRequest;
   };
 
diff --git a/src/crimson/osd/osd_operations/common/pg_pipeline.h b/src/crimson/osd/osd_operations/common/pg_pipeline.h
index ed9ab25cc48a..20417d027747 100644
--- a/src/crimson/osd/osd_operations/common/pg_pipeline.h
+++ b/src/crimson/osd/osd_operations/common/pg_pipeline.h
@@ -12,18 +12,18 @@ class CommonPGPipeline {
 protected:
   friend class InternalClientRequest;
 
-  OrderedExclusivePhase wait_for_active = {
-    "CommonPGPipeline:::wait_for_active"
-  };
-  OrderedExclusivePhase recover_missing = {
-    "CommonPGPipeline::recover_missing"
-  };
-  OrderedExclusivePhase get_obc = {
-    "CommonPGPipeline::get_obc"
-  };
-  OrderedExclusivePhase process = {
-    "CommonPGPipeline::process"
-  };
+  struct WaitForActive : OrderedExclusivePhaseT<WaitForActive> {
+    static constexpr auto type_name = "CommonPGPipeline:::wait_for_active";
+  } wait_for_active;
+  struct RecoverMissing : OrderedExclusivePhaseT<RecoverMissing> {
+    static constexpr auto type_name = "CommonPGPipeline::recover_missing";
+  } recover_missing;
+  struct GetOBC : OrderedExclusivePhaseT<GetOBC> {
+    static constexpr auto type_name = "CommonPGPipeline::get_obc";
+  } get_obc;
+  struct Process : OrderedExclusivePhaseT<Process> {
+    static constexpr auto type_name = "CommonPGPipeline::process";
+  } process;
 };
 
 } // namespace crimson::osd