crimson/osd: split ClientRequest::PGPipeline into CommonPGPipeline.

This is another step towards the `InternalClientRequst`.

Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>

diff --git a/src/crimson/osd/osd_operations/client_request.h b/src/crimson/osd/osd_operations/client_request.h
index f361838bb3fa71102613a7e692c8a46f25dbd238..42bd36f86e6bb487e5d82633bf51267fe9232070 100644 (file)
--- a/src/crimson/osd/osd_operations/client_request.h
+++ b/src/crimson/osd/osd_operations/client_request.h
@@ -7,6 +7,7 @@
 #include "crimson/net/Connection.h"
 #include "crimson/osd/object_context.h"
 #include "crimson/osd/osd_operation.h"
+#include "crimson/osd/osd_operations/common/pg_pipeline.h"
 #include "crimson/common/type_helpers.h"
 #include "messages/MOSDOp.h"
 
@@ -31,22 +32,10 @@ public:
     };
     friend class ClientRequest;
   };
-  class PGPipeline {
+  class PGPipeline : public CommonPGPipeline {
     OrderedExclusivePhase await_map = {
       "ClientRequest::PGPipeline::await_map"
     };
-    OrderedExclusivePhase wait_for_active = {
-      "ClientRequest::PGPipeline::wait_for_active"
-    };
-    OrderedExclusivePhase recover_missing = {
-      "ClientRequest::PGPipeline::recover_missing"
-    };
-    OrderedExclusivePhase get_obc = {
-      "ClientRequest::PGPipeline::get_obc"
-    };
-    OrderedExclusivePhase process = {
-      "ClientRequest::PGPipeline::process"
-    };
     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
new file mode 100644 (file)
index 0000000..59c1058
--- /dev/null
+++ b/src/crimson/osd/osd_operations/common/pg_pipeline.h
@@ -0,0 +1,27 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#pragma once
+
+#include "osd/osd_op_util.h"
+#include "crimson/osd/osd_operation.h"
+
+namespace crimson::osd {
+
+class CommonPGPipeline {
+protected:
+  OrderedExclusivePhase wait_for_active = {
+    "CommonPGPipeline:::wait_for_active"
+  };
+  OrderedExclusivePhase recover_missing = {
+    "CommonPGPipeline::recover_missing"
+  };
+  OrderedExclusivePhase get_obc = {
+    "CommonPGPipeline::get_obc"
+  };
+  OrderedExclusivePhase process = {
+    "CommonPGPipeline::process"
+  };
+};
+
+} // namespace crimson::osd