From: Radoslaw Zarzynski <rzarzyns@redhat.com>
Date: Tue, 26 Mar 2024 12:18:04 +0000 (+0000)
Subject: crimson/osd: wire up MOSDPGPush and MOSDPGPushReply in ECRecoveryBackend
X-Git-Tag: v21.0.0~3^2~56
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=324a7abe2bc4f12f72faedc9199791275b8cd4e0;p=ceph.git

crimson/osd: wire up MOSDPGPush and MOSDPGPushReply in 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 766b27288a5b..a8721734fa89 100644
--- a/src/crimson/osd/ec_recovery_backend.cc
+++ b/src/crimson/osd/ec_recovery_backend.cc
@@ -56,6 +56,11 @@ ECRecoveryBackend::handle_push(
   Ref<MOSDPGPush> m)
 {
   logger().debug("{}: {}", __func__, *m);
+  RecoveryMessages rm;
+  for (const auto& push_op : m->pushes) {
+    handle_recovery_push(push_op, &rm, m->is_repair);
+  }
+  dispatch_recovery_messages(rm, m->get_priority());
   return seastar::now();
 }
 
@@ -64,6 +69,11 @@ ECRecoveryBackend::handle_push_reply(
   Ref<MOSDPGPushReply> m)
 {
   logger().debug("{}: {}", __func__, *m);
+  RecoveryMessages rm;
+  for (const auto& push_reply_op : m->replies) {
+    handle_recovery_push_reply(push_reply_op, m->from, &rm);
+  }
+  dispatch_recovery_messages(rm, m->get_priority());
   return seastar::now();
 }