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 766b27288a5b1772e2d0bde95f08da23cb0383fd..a8721734fa895929080b287ba90eaee09cd976c3 100644 (file)
--- 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();
 }