From acb146b2f84164162d0b04b9a8a98c05945bcb05 Mon Sep 17 00:00:00 2001 From: Radoslaw Zarzynski Date: Tue, 26 Mar 2024 12:18:04 +0000 Subject: [PATCH] crimson/osd: wire up MOSDPGPush and MOSDPGPushReply in ECRecoveryBackend Signed-off-by: Radoslaw Zarzynski --- src/crimson/osd/ec_recovery_backend.cc | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/crimson/osd/ec_recovery_backend.cc b/src/crimson/osd/ec_recovery_backend.cc index 766b27288a5..a8721734fa8 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 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 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(); } -- 2.47.3