]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson: clarify RecoveryBackend::handle_backfill_op
authorSamuel Just <sjust@redhat.com>
Fri, 3 Jan 2025 22:54:49 +0000 (22:54 +0000)
committerSamuel Just <sjust@redhat.com>
Wed, 22 Jan 2025 04:05:11 +0000 (20:05 -0800)
Should make it a bit easier to find the two kinds of
message handlers.

Signed-off-by: Samuel Just <sjust@redhat.com>
src/crimson/osd/recovery_backend.cc
src/crimson/osd/recovery_backend.h
src/crimson/osd/replicated_recovery_backend.cc

index aa13b9594c77f88a449be86ff1d7cea38f6f5f73..e390d51ed06b8b2c02a021eae7c9b346b9304934 100644 (file)
@@ -360,7 +360,7 @@ RecoveryBackend::handle_scan(
 }
 
 RecoveryBackend::interruptible_future<>
-RecoveryBackend::handle_recovery_op(
+RecoveryBackend::handle_backfill_op(
   Ref<MOSDFastDispatchOp> m,
   crimson::net::ConnectionXcoreRef conn)
 {
index 21154cb710679f5ba329db5056eede8bc56b8241..2d755d54789feb89eca724aaea126af099fa6a48 100644 (file)
@@ -77,7 +77,7 @@ public:
 
   virtual interruptible_future<> handle_recovery_op(
     Ref<MOSDFastDispatchOp> 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<MOSDFastDispatchOp> m,
+    crimson::net::ConnectionXcoreRef conn);
 private:
   void handle_backfill_finish(
     MOSDPGBackfill& m,
index 0d6c9d3823665b2dfece230d4237ae8366b69f08..feb19a12675af9860ccdf206382038c7f02fabd4 100644 (file)
@@ -1356,8 +1356,8 @@ ReplicatedRecoveryBackend::handle_recovery_op(
     return handle_recovery_delete_reply(
        boost::static_pointer_cast<MOSDPGRecoveryDeleteReply>(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);
   }
 }