Repository: cassandra Updated Branches: refs/heads/trunk f32521808 -> 9ba3185b6
add ns timeunit marker to logger output Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9ba3185b Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9ba3185b Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9ba3185b Branch: refs/heads/trunk Commit: 9ba3185b60fa9cbd4fd8effe55b0935f1736fc2f Parents: f325218 Author: Dave Brosius <dbros...@mebigfatguy.com> Authored: Wed Mar 1 19:24:02 2017 -0500 Committer: Dave Brosius <dbros...@mebigfatguy.com> Committed: Wed Mar 1 19:24:02 2017 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/gms/FailureDetector.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/9ba3185b/src/java/org/apache/cassandra/gms/FailureDetector.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/gms/FailureDetector.java b/src/java/org/apache/cassandra/gms/FailureDetector.java index c73cc07..e5a29d6 100644 --- a/src/java/org/apache/cassandra/gms/FailureDetector.java +++ b/src/java/org/apache/cassandra/gms/FailureDetector.java @@ -270,7 +270,7 @@ public class FailureDetector implements IFailureDetector, FailureDetectorMBean } if (logger.isTraceEnabled() && heartbeatWindow != null) - logger.trace("Average for {} is {}", ep, heartbeatWindow.mean()); + logger.trace("Average for {} is {}ns", ep, heartbeatWindow.mean()); } public void interpret(InetAddress ep) @@ -285,7 +285,7 @@ public class FailureDetector implements IFailureDetector, FailureDetectorMBean lastInterpret = now; if (diff > MAX_LOCAL_PAUSE_IN_NANOS) { - logger.warn("Not marking nodes down due to local pause of {} > {}", diff, MAX_LOCAL_PAUSE_IN_NANOS); + logger.warn("Not marking nodes down due to local pause of {}ns > {}ns", diff, MAX_LOCAL_PAUSE_IN_NANOS); lastPause = now; return; } @@ -301,7 +301,7 @@ public class FailureDetector implements IFailureDetector, FailureDetectorMBean if (PHI_FACTOR * phi > getPhiConvictThreshold()) { if (logger.isTraceEnabled()) - logger.trace("Node {} phi {} > {}; intervals: {} mean: {}", new Object[]{ep, PHI_FACTOR * phi, getPhiConvictThreshold(), hbWnd, hbWnd.mean()}); + logger.trace("Node {} phi {} > {}; intervals: {} mean: {}ns", new Object[]{ep, PHI_FACTOR * phi, getPhiConvictThreshold(), hbWnd, hbWnd.mean()}); for (IFailureDetectionEventListener listener : fdEvntListeners) { listener.convict(ep, phi); @@ -314,7 +314,7 @@ public class FailureDetector implements IFailureDetector, FailureDetectorMBean else if (logger.isTraceEnabled()) { logger.trace("PHI for {} : {}", ep, phi); - logger.trace("mean for {} : {}", ep, hbWnd.mean()); + logger.trace("mean for {} : {}ns", ep, hbWnd.mean()); } } @@ -450,11 +450,11 @@ class ArrivalWindow if (interArrivalTime <= MAX_INTERVAL_IN_NANO) { arrivalIntervals.add(interArrivalTime); - logger.trace("Reporting interval time of {} for {}", interArrivalTime, ep); + logger.trace("Reporting interval time of {}ns for {}", interArrivalTime, ep); } else { - logger.debug("Ignoring interval time of {} for {}", interArrivalTime, ep); + logger.debug("Ignoring interval time of {}ns for {}", interArrivalTime, ep); } } else
