From: Radoslaw Zarzynski Date: Wed, 16 Jul 2025 11:57:12 +0000 (+0000) Subject: fixup: crimson/osd: bring ECRecoveryBackend, phase 0.1 X-Git-Tag: v21.0.0~3^2~20 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=ab789cad445a856b2319d3304c405357d4feb88b;p=ceph.git fixup: crimson/osd: bring ECRecoveryBackend, phase 0.1 Signed-off-by: Radoslaw Zarzynski --- diff --git a/src/crimson/osd/ec_recovery_backend.cc b/src/crimson/osd/ec_recovery_backend.cc index ee2cab7f2c3f..0aab51a970ae 100644 --- a/src/crimson/osd/ec_recovery_backend.cc +++ b/src/crimson/osd/ec_recovery_backend.cc @@ -21,12 +21,14 @@ namespace { } } +namespace crimson::osd { + ECRecoveryBackend::ECRecoveryBackend( crimson::osd::PG& pg, crimson::osd::ShardServices& shard_services, crimson::os::CollectionRef coll, ECBackend* backend) -: ::RecoveryBackend(pg, shard_services, coll, backend), +: ::crimson::osd::RecoveryBackend(pg, shard_services, coll, backend), ::ECCommon::RecoveryBackend( shard_services.get_cct(), coll->get_cid(), @@ -73,7 +75,7 @@ void ECRecoveryBackend::commit_txn_send_replies( std::map replies) { std::ignore = shard_services.get_store().do_transaction( - ::RecoveryBackend::coll, std::move(txn) + crimson::osd::RecoveryBackend::coll, std::move(txn) ).then([replies=std::move(replies), this]() mutable { if (auto msgit = replies.find(get_parent()->whoami_shard().osd); msgit != std::end(replies)) { @@ -189,6 +191,8 @@ ECRecoveryBackend::handle_recovery_op( boost::static_pointer_cast(m)); default: // delegate backfill messages to parent class - return handle_backfill_op(std::move(m), conn); + return ::crimson::osd::RecoveryBackend::handle_recovery_op(std::move(m), conn); } } + +} // namespace crimson::osd diff --git a/src/crimson/osd/ec_recovery_backend.h b/src/crimson/osd/ec_recovery_backend.h index 66fdd67deaf1..15fbf1be864d 100644 --- a/src/crimson/osd/ec_recovery_backend.h +++ b/src/crimson/osd/ec_recovery_backend.h @@ -23,13 +23,12 @@ #include "osd/recovery_types.h" #include "osd/osd_types.h" -namespace crimson::osd{ - class PG; -} - class PGBackend; -class ECRecoveryBackend : public RecoveryBackend, +namespace crimson::osd { +class PG; + +class ECRecoveryBackend : public crimson::osd::RecoveryBackend, private ECCommon::RecoveryBackend { public: ECRecoveryBackend(crimson::osd::PG& pg, @@ -64,3 +63,5 @@ private: interruptible_future<> handle_push_reply( Ref m); }; + +} // namespace crimson::osd