if (g_conf()->subsys.should_gather<ceph_subsys_osd, 20>()) {
dout(20) << "scrub scheduling (@tick) starts" << dendl;
- auto all_jobs = list_registered_jobs();
+ auto all_jobs = m_queue.list_registered_jobs();
for (const auto& sj : all_jobs) {
dout(20) << fmt::format("\tscrub-queue jobs: {}", *sj) << dendl;
}
{
m_queue.clear_reserving_now();
}
-
-bool OsdScrub::is_reserving_now() const
-{
- return m_queue.is_reserving_now();
-}
-
-Scrub::ScrubQContainer OsdScrub::list_registered_jobs() const
-{
- return m_queue.list_registered_jobs();
-}
/// the queue of PGs waiting to be scrubbed
ScrubQueue m_queue;
- public:
- // for this transitory commit only - to be moved elsewhere
- /**
- * @return the list (not std::set!) of all scrub jobs registered
- * (apart from PGs in the process of being removed)
- */
- Scrub::ScrubQContainer list_registered_jobs() const;
-
- /// one of this OSD's PGs is trying to acquire replica resources
- bool is_reserving_now() const;
-
- private:
const std::string m_log_prefix{};
/// number of PGs stuck while scrubbing, waiting for objects