PeeringState: pass dump_recovery_info through to pl for recovery state

Signed-off-by: Samuel Just <sjust@redhat.com>

diff --git a/src/osd/PG.h b/src/osd/PG.h
index a4b57ef4586a977c77fed85f91fa3e9c5e9aa7ae..ecc2a3ad80055b2807e2fa368156dda7e2313c52 100644 (file)
--- a/src/osd/PG.h
+++ b/src/osd/PG.h
@@ -999,7 +999,6 @@ protected:
   }
 
   bool all_unfound_are_queried_or_lost(const OSDMapRef osdmap) const;
-  virtual void dump_recovery_info(Formatter *f) const = 0;
 
   void calc_min_last_complete_ondisk() {
     eversion_t min = last_complete_ondisk;

diff --git a/src/osd/PeeringState.cc b/src/osd/PeeringState.cc
index b466443d71417581084f77ee6e98ef5a154c3667..c45da33c537ce03a02624bfe331e925314a810ae 100644 (file)
--- a/src/osd/PeeringState.cc
+++ b/src/osd/PeeringState.cc
@@ -4116,7 +4116,12 @@ boost::statechart::result PeeringState::Active::react(const QueryState& q)
   }
   {
     q.f->open_object_section("recovery_progress");
-    pg->dump_recovery_info(q.f);
+    q.f->open_array_section("backfill_targets");
+    for (set<pg_shard_t>::const_iterator p = ps->backfill_targets.begin();
+        p != ps->backfill_targets.end(); ++p)
+      q.f->dump_stream("replica") << *p;
+    q.f->close_section();
+    pl->dump_recovery_info(q.f);
     q.f->close_section();
   }
 

diff --git a/src/osd/PeeringState.h b/src/osd/PeeringState.h
index a8e637c94ea23f58beefc62a27eb11d0db5f73b5..f24139b2d2961ad26fc14a9ba8cc28a127e10558 100644 (file)
--- a/src/osd/PeeringState.h
+++ b/src/osd/PeeringState.h
@@ -152,6 +152,8 @@ public:
     virtual PGLog::LogEntryHandlerRef get_log_handler(
       ObjectStore::Transaction *t) = 0;
 
+    virtual void dump_recovery_info(Formatter *f) const = 0;
+
     virtual epoch_t oldest_stored_osdmap() = 0;
     virtual LogChannel &get_clog() = 0;
 

diff --git a/src/osd/PrimaryLogPG.h b/src/osd/PrimaryLogPG.h
index bf1eb300cb6ade33ff0fb248efd3681747fdb2da..a55d224d058a93d24d8b2a93ef9ea6d27c3ae868 100644 (file)
--- a/src/osd/PrimaryLogPG.h
+++ b/src/osd/PrimaryLogPG.h
@@ -1062,11 +1062,6 @@ protected:
   map<hobject_t, pg_stat_t> pending_backfill_updates;
 
   void dump_recovery_info(Formatter *f) const override {
-    f->open_array_section("backfill_targets");
-    for (set<pg_shard_t>::const_iterator p = backfill_targets.begin();
-        p != backfill_targets.end(); ++p)
-      f->dump_stream("replica") << *p;
-    f->close_section();
     f->open_array_section("waiting_on_backfill");
     for (set<pg_shard_t>::const_iterator p = waiting_on_backfill.begin();
         p != waiting_on_backfill.end(); ++p)