void clear_want_pg_temp() final {
shard_services.remove_want_pg_temp(pgid.pgid);
}
- void publish_stats_to_osd() final;
- void clear_publish_stats() final {
- // Not needed yet
- }
void check_recovery_sources(const OSDMapRef& newmap) final {
// Not needed yet
}
bool is_backfilling() const final {
return peering_state.is_backfilling();
}
- pg_stat_t get_stats();
bool get_need_up_thru() const {
return peering_state.get_need_up_thru();
}
return shard_services;
}
seastar::future<> stop();
-
private:
std::unique_ptr<PGBackend> backend;
std::unique_ptr<RecoveryBackend> recovery_backend;
PeeringState peering_state;
eversion_t projected_last_update;
+public:
+ // PeeringListener
+ void publish_stats_to_osd() final;
+ void clear_publish_stats() final {
+ // Not needed yet
+ }
+ pg_stat_t get_stats();
public:
RecoveryBackend* get_recovery_backend() final {
return recovery_backend.get();