From: Samuel Just Date: Fri, 3 Jan 2025 22:54:49 +0000 (+0000) Subject: crimson: clarify RecoveryBackend::handle_backfill_op X-Git-Tag: v20.0.0~282^2~13 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=ecda6780c93db66865533a27dab5b0beb052f5fa;p=ceph.git crimson: clarify RecoveryBackend::handle_backfill_op Should make it a bit easier to find the two kinds of message handlers. Signed-off-by: Samuel Just --- diff --git a/src/crimson/osd/recovery_backend.cc b/src/crimson/osd/recovery_backend.cc index aa13b9594c77..e390d51ed06b 100644 --- a/src/crimson/osd/recovery_backend.cc +++ b/src/crimson/osd/recovery_backend.cc @@ -360,7 +360,7 @@ RecoveryBackend::handle_scan( } RecoveryBackend::interruptible_future<> -RecoveryBackend::handle_recovery_op( +RecoveryBackend::handle_backfill_op( Ref m, crimson::net::ConnectionXcoreRef conn) { diff --git a/src/crimson/osd/recovery_backend.h b/src/crimson/osd/recovery_backend.h index 21154cb71067..2d755d54789f 100644 --- a/src/crimson/osd/recovery_backend.h +++ b/src/crimson/osd/recovery_backend.h @@ -77,7 +77,7 @@ public: virtual interruptible_future<> handle_recovery_op( Ref m, - crimson::net::ConnectionXcoreRef conn); + crimson::net::ConnectionXcoreRef conn) = 0; virtual interruptible_future<> recover_object( const hobject_t& soid, @@ -268,6 +268,10 @@ protected: void clean_up(ceph::os::Transaction& t, interrupt_cause_t why); virtual seastar::future<> on_stop() = 0; + + virtual interruptible_future<> handle_backfill_op( + Ref m, + crimson::net::ConnectionXcoreRef conn); private: void handle_backfill_finish( MOSDPGBackfill& m, diff --git a/src/crimson/osd/replicated_recovery_backend.cc b/src/crimson/osd/replicated_recovery_backend.cc index 0d6c9d382366..feb19a12675a 100644 --- a/src/crimson/osd/replicated_recovery_backend.cc +++ b/src/crimson/osd/replicated_recovery_backend.cc @@ -1356,8 +1356,8 @@ ReplicatedRecoveryBackend::handle_recovery_op( return handle_recovery_delete_reply( boost::static_pointer_cast(m)); default: - // delegate to parent class for handling backend-agnostic recovery ops. - return RecoveryBackend::handle_recovery_op(std::move(m), conn); + // delegate backfill messages to parent class + return handle_backfill_op(std::move(m), conn); } }