Signed-off-by: Sage Weil <sage@redhat.com>
if (reset)
monc->reopen_session();
- else if (report)
- do_mon_report();
+ else if (report) {
+ last_mon_report = now;
+
+ // do any pending reports
+ send_alive();
+ service.send_pg_temp();
+ send_failures();
+ send_pg_stats(now);
+ }
map_lock.put_read();
}
}
// =========================================
-void OSD::do_mon_report()
-{
- dout(7) << "do_mon_report" << dendl;
-
- utime_t now(ceph_clock_now(cct));
- last_mon_report = now;
-
- // do any pending reports
- send_alive();
- service.send_pg_temp();
- send_failures();
- send_pg_stats(now);
-}
-
void OSD::ms_handle_connect(Connection *con)
{
if (con->get_peer_type() == CEPH_ENTITY_TYPE_MON) {
float stats_ack_timeout;
int outstanding_pg_stats; // how many stat updates haven't been acked yet
- void do_mon_report();
-
// -- boot --
void start_boot();
void _maybe_boot(epoch_t oldest, epoch_t newest);