RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-21 09:57:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

mon: add clock sync backoff to handle_lease_ack

Browse Source
This commit is contained in:
Greg Farnum 2010-08-24 11:54:49 -07:00
parent 6998372a8f
commit c4ab621ed6
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/mon/Paxos.cc
View File

@ -574,9 +574,8 @@ void Paxos::handle_lease(MMonPaxos *lease)
allowed_time.set_from_double(g_clock.now() + g_conf.mon_clock_drift_allowed);
if (lease->sent_timestamp > allowed_time) {
utime_t warn_diff = g_clock.now() - last_clock_drift_warn;
if ((last_clock_drift_warn == utime_t()) ||
(warn_diff >
pow(g_conf.mon_clock_drift_warn_backoff, clock_drift_warned))) {
if (warn_diff >
pow(g_conf.mon_clock_drift_warn_backoff, clock_drift_warned)) {
stringstream ss;
ss << "lease_expire from mon" << lease->get_source().num()
<< " was sent from future time " << lease->sent_timestamp
@ -653,12 +652,18 @@ void Paxos::handle_lease_ack(MMonPaxos *ack)
utime_t allowed_time;
allowed_time.set_from_double(g_clock.now() + g_conf.mon_clock_drift_allowed);
if (ack->sent_timestamp > allowed_time) {
stringstream ss;
ss << "lease_ack from mon" << from
<< " was sent from future time " << ack->sent_timestamp
<< " with allowed time <=" << allowed_time
<< ", clocks not synchronized." << std::endl;
mon->get_logclient()->log(LOG_WARN, ss);
utime_t warn_diff = g_clock.now() - last_clock_drift_warn;
if (warn_diff >
pow(g_conf.mon_clock_drift_warn_backoff, clock_drift_warned)) {
stringstream ss;
ss << "lease_ack from mon" << from
<< " was sent from future time " << ack->sent_timestamp
<< " with allowed time <=" << allowed_time
<< ", clocks not synchronized." << std::endl;
mon->get_logclient()->log(LOG_WARN, ss);
last_clock_drift_warn = g_clock.now();
++clock_drift_warned;
}
}
ack->put();
}