crimson/osd: wire MOSDPGPush{,Reply} with ECRecoveryBackend

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

diff --git a/src/crimson/osd/ec_recovery_backend.cc b/src/crimson/osd/ec_recovery_backend.cc
index eb70d27bbc9e54b9eff975ac60d20e4f2dca5194..57d897830b739fba4fb79326aadf131c0bc20feb 100644 (file)
--- a/src/crimson/osd/ec_recovery_backend.cc
+++ b/src/crimson/osd/ec_recovery_backend.cc
@@ -9,6 +9,8 @@
 #include "crimson/osd/ec_recovery_backend.h"
 #include "crimson/osd/pg.h"
 #include "crimson/osd/pg_backend.h"
+#include "messages/MOSDPGPush.h"
+#include "messages/MOSDPGPushReply.h"
 #include "msg/Message.h"
 #include "osd/osd_types_fmt.h"
 
@@ -33,6 +35,11 @@ ECRecoveryBackend::handle_recovery_op(
   crimson::net::ConnectionXcoreRef conn)
 {
   switch (m->get_header().type) {
+  case MSG_OSD_PG_PUSH:
+    return handle_push(boost::static_pointer_cast<MOSDPGPush>(m));
+  case MSG_OSD_PG_PUSH_REPLY:
+    return handle_push_reply(
+       boost::static_pointer_cast<MOSDPGPushReply>(m));
   default:
     // delegate to parent class for handling backend-agnostic recovery ops.
     return RecoveryBackend::handle_recovery_op(std::move(m), conn);

diff --git a/src/crimson/osd/ec_recovery_backend.h b/src/crimson/osd/ec_recovery_backend.h
index 2abac2ed03f1200bbcc87a044ea892acccaa9342..bb86c2eb80afcbd4616d6e168a9ea75cf908fbe2 100644 (file)
--- a/src/crimson/osd/ec_recovery_backend.h
+++ b/src/crimson/osd/ec_recovery_backend.h
@@ -16,6 +16,8 @@
 
 #include "messages/MOSDPGBackfill.h"
 #include "messages/MOSDPGBackfillRemove.h"
+#include "messages/MOSDPGPush.h"
+#include "messages/MOSDPGPushReply.h"
 #include "messages/MOSDPGScan.h"
 #include "osd/recovery_types.h"
 #include "osd/osd_types.h"
@@ -46,4 +48,10 @@ public:
   seastar::future<> on_stop() final {
     return seastar::now();
   }
+
+private:
+  interruptible_future<> handle_push(
+    Ref<MOSDPGPush> m);
+  interruptible_future<> handle_push_reply(
+    Ref<MOSDPGPushReply> m);
 };

diff --git a/src/crimson/osd/recovery_backend.cc b/src/crimson/osd/recovery_backend.cc
index 80fea74fe3fd454f0f1ada3fbb6452d2427bf624..462c9a31ad5460c4254c7e9fc41321f15dd98296 100644 (file)
--- a/src/crimson/osd/recovery_backend.cc
+++ b/src/crimson/osd/recovery_backend.cc
@@ -14,6 +14,8 @@
 #include "crimson/osd/osd_operations/background_recovery.h"
 
 #include "messages/MOSDFastDispatchOp.h"
+#include "messages/MOSDPGRecoveryDelete.h"
+#include "messages/MOSDPGRecoveryDeleteReply.h"
 #include "osd/osd_types.h"
 
 SET_SUBSYS(osd);