Signed-off-by: Kefu Chai <kchai@redhat.com>
void PGMonitor::on_restart()
{
// clear leader state
- last_sent_pg_create.clear();
last_osd_report.clear();
}
read_pgmap_meta();
out:
- if (last_pg_scan != pg_map.last_pg_scan)
- last_sent_pg_create.clear(); // reset pg_create throttle timer
-
assert(version == pg_map.version);
update_logger();
}
con->send_message(m);
- last_sent_pg_create[osd] = ceph_clock_now();
// sub is current through last + 1
return last + 1;
bool preprocess_command(MonOpRequestRef op);
bool prepare_command(MonOpRequestRef op);
- map<int,utime_t> last_sent_pg_create; // per osd throttle
-
// when we last received PG stats from each osd
map<int,utime_t> last_osd_report;