void PG::reschedule_scrub()
{
- dout(20) << __func__ << " for a " << (is_primary() ? "Primary" : "non-primary") <<dendl;
+ dout(20) << fmt::format(
+ "{} for a {}", __func__,
+ (is_primary() ? "Primary" : "non-primary"))
+ << dendl;
// we are assuming no change in primary status
if (is_primary()) {
if (is_primary() && m_scrub_job) {
ceph_assert(m_pg->is_locked());
auto suggested = m_osds->get_scrub_services().determine_scrub_time(
- request_flags, m_pg->info, m_pg->get_pgpool().info.opts);
+ request_flags, m_pg->info, m_pg->get_pgpool().info.opts);
m_osds->get_scrub_services().update_job(m_scrub_job, suggested);
m_pg->publish_stats_to_osd();
}
// note that only applicable to the Replica:
void PgScrubber::advance_token()
{
- dout(10) << __func__ << " was: " << m_current_token << dendl;
+ dout(10) << fmt::format("{}: prev. token:{}", __func__, m_current_token)
+ << dendl;
+
m_current_token++;
// when advance_token() is called, it is assumed that no scrubbing takes
, m_conf{conf}
{
epoch_t epoch = m_pg->get_osdmap_epoch();
- m_timeout = conf.get_val<std::chrono::milliseconds>(
- "osd_scrub_slow_reservation_response");
m_log_msg_prefix = fmt::format(
- "osd.{} ep: {} scrubber::ReplicaReservations pg[{}]: ", m_osds->whoami,
- epoch, pg->pg_id);
+ "osd.{} ep: {} scrubber::ReplicaReservations pg[{}]: ", m_osds->whoami,
+ epoch, pg->pg_id);
+
+ m_timeout = conf.get_val<std::chrono::milliseconds>(
+ "osd_scrub_slow_reservation_response");
if (m_pending <= 0) {
// A special case of no replicas.
std::string_view caller,
const requested_scrub_t& request_flags) final;
- void scrub_requested(scrub_level_t scrub_level,
- scrub_type_t scrub_type,
- requested_scrub_t& req_flags) final;
+ void scrub_requested(
+ scrub_level_t scrub_level,
+ scrub_type_t scrub_type,
+ requested_scrub_t& req_flags) final;
/**
* Reserve local scrub resources (managed by the OSD)
std::string param,
Formatter* f,
std::stringstream& ss) override;
+
int m_debug_blockrange{0};
// --------------------------------------------------------------------------