]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd: switch return type of PG::get_dpp to unify with ECListener
authorRadoslaw Zarzynski <rzarzyns@redhat.com>
Wed, 21 May 2025 14:42:20 +0000 (14:42 +0000)
committerRadoslaw Zarzynski <rzarzyns@redhat.com>
Tue, 24 Mar 2026 16:06:24 +0000 (16:06 +0000)
Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
src/crimson/osd/pg.h
src/crimson/osd/pg_recovery.cc
src/crimson/osd/pg_recovery_listener.h

index 4bcff9a4fd69b525b18ce63cf27ce5e1a9601266..64e0d9f98caf2bf2f2f98da266a5e980225bbbba 100644 (file)
@@ -179,9 +179,6 @@ public:
   const PGLog &get_log() const override {
     return peering_state.get_pg_log();
   }
-  DoutPrefixProvider *get_dpp() override {
-    return this;
-  }
   void add_temp_obj(const hobject_t &oid) override {
     get_backend().add_temp_obj(oid);
   }
@@ -931,8 +928,8 @@ public:
   ShardServices& get_shard_services() final {
     return shard_services;
   }
-  DoutPrefixProvider& get_dpp() final {
-    return *this;
+  DoutPrefixProvider* get_dpp() final {
+    return this;
   }
   seastar::future<> stop();
 private:
index 09ae3c204ddc2104fab1c4a5286eb4e8f32043b9..89db49d1c91220c1d44212b152ef1d658a92656a 100644 (file)
@@ -517,13 +517,13 @@ PGRecovery::recover_object_with_throttle(
   eversion_t need)
 {
   LOG_PREFIX(PGRecovery::recover_object_with_throttle);
-  DEBUGDPP("{} {}", pg->get_dpp(), soid, need);
+  DEBUGDPP("{} {}", *pg->get_dpp(), soid, need);
   auto releaser = co_await interruptor::make_interruptible(
     pg->get_shard_services().get_throttle(
       crimson::osd::scheduler::params_t{
        1, 0, 0, SchedulerClass::background_best_effort
       }));
-  DEBUGDPP("got throttle: {} {}", pg->get_dpp(), soid, need);
+  DEBUGDPP("got throttle: {} {}", *pg->get_dpp(), soid, need);
   co_await pg->get_recovery_backend()->recover_object(soid, need);
   co_return;
 }
index 97aca3c8c7259f2bd2efdd3883370519168ac4cd..875f5d9c13915ec0402f988468bd5df9d448ad0f 100644 (file)
@@ -18,7 +18,7 @@ class PGRecovery;
 class PGRecoveryListener {
 public:
   virtual crimson::osd::ShardServices& get_shard_services() = 0;
-  virtual DoutPrefixProvider& get_dpp() = 0;
+  virtual DoutPrefixProvider* get_dpp() = 0;
   virtual PGRecovery* get_recovery_handler() = 0;
   virtual epoch_t get_osdmap_epoch() const = 0;
   virtual bool is_primary() const = 0;