forked from I2P_Developers/i2p.i2p
fix clock.skew rates
This commit is contained in:
@ -97,7 +97,7 @@ public class Clock implements Timestamper.UpdateListener {
|
|||||||
getLog().info("Updating clock offset to " + offsetMs + "ms from " + _offset + "ms");
|
getLog().info("Updating clock offset to " + offsetMs + "ms from " + _offset + "ms");
|
||||||
|
|
||||||
if (!_statCreated) {
|
if (!_statCreated) {
|
||||||
_context.statManager().createRequiredRateStat("clock.skew", "Clock step adjustment (ms)", "Clock", new long[] { 10*60*1000, 3*60*60*1000, 24*60*60*60 });
|
_context.statManager().createRequiredRateStat("clock.skew", "Clock step adjustment (ms)", "Clock", new long[] { 10*60*1000, 3*60*60*1000, 24*60*60*1000 });
|
||||||
_statCreated = true;
|
_statCreated = true;
|
||||||
}
|
}
|
||||||
_context.statManager().addRateData("clock.skew", delta, 0);
|
_context.statManager().addRateData("clock.skew", delta, 0);
|
||||||
|
@ -161,7 +161,7 @@ public class RouterClock extends Clock {
|
|||||||
getLog().info("Updating target clock offset to " + offsetMs + "ms from " + _offset + "ms, Stratum " + stratum);
|
getLog().info("Updating target clock offset to " + offsetMs + "ms from " + _offset + "ms, Stratum " + stratum);
|
||||||
|
|
||||||
if (!_statCreated) {
|
if (!_statCreated) {
|
||||||
_context.statManager().createRequiredRateStat("clock.skew", "Clock step adjustment (ms)", "Clock", new long[] { 10*60*1000, 3*60*60*1000, 24*60*60*60 });
|
_context.statManager().createRequiredRateStat("clock.skew", "Clock step adjustment (ms)", "Clock", new long[] { 10*60*1000, 3*60*60*1000, 24*60*60*1000 });
|
||||||
_statCreated = true;
|
_statCreated = true;
|
||||||
}
|
}
|
||||||
_context.statManager().addRateData("clock.skew", delta);
|
_context.statManager().addRateData("clock.skew", delta);
|
||||||
|
Reference in New Issue
Block a user