Signed-off-by: Sage Weil <sage@redhat.com>
osd->osdmap_subscribe(e, false);
}
+
class AgentTimeoutCB : public Context {
PGRef pg;
public:
goto out;
}
+ startup_time = ceph::mono_clock::now();
+
// load up "current" osdmap
assert_warn(!osdmap);
if (osdmap) {
Messenger *hb_back_server_messenger;
utime_t last_heartbeat_resample; ///< last time we chose random peers in waiting-for-healthy state
double daily_loadavg;
-
+ ceph::mono_time startup_time;
+
void _add_heartbeat_peer(int p);
void _remove_heartbeat_peer(int p);
bool heartbeat_reset(Connection *con);