From d0dd094291b43a69fdb1ad4131dad91cca40e9b0 Mon Sep 17 00:00:00 2001 From: Jon Bratseth Date: Wed, 15 Dec 2021 13:00:38 +0100 Subject: No functional changes --- container-core/src/main/java/com/yahoo/metrics/simple/Bucket.java | 2 +- .../src/main/java/com/yahoo/metrics/simple/MetricAggregator.java | 5 +++-- .../src/main/java/com/yahoo/metrics/simple/MetricManager.java | 8 +++++--- .../src/main/java/com/yahoo/metrics/simple/MetricReceiver.java | 4 +++- .../java/com/yahoo/metrics/simple/jdisc/SimpleMetricConsumer.java | 2 +- 5 files changed, 13 insertions(+), 8 deletions(-) (limited to 'container-core/src/main') diff --git a/container-core/src/main/java/com/yahoo/metrics/simple/Bucket.java b/container-core/src/main/java/com/yahoo/metrics/simple/Bucket.java index 9162571830d..90e0115736f 100644 --- a/container-core/src/main/java/com/yahoo/metrics/simple/Bucket.java +++ b/container-core/src/main/java/com/yahoo/metrics/simple/Bucket.java @@ -175,7 +175,7 @@ public class Bucket { @Override public String toString() { - return "Bucket [values=" + (values != null ? toString(values.entrySet(), 3) : null) + "]"; + return "Bucket [values=" + toString(values.entrySet(), 3) + "]"; } private String toString(Collection collection, int maxLen) { diff --git a/container-core/src/main/java/com/yahoo/metrics/simple/MetricAggregator.java b/container-core/src/main/java/com/yahoo/metrics/simple/MetricAggregator.java index 3839de28294..5fd9afa3e4c 100644 --- a/container-core/src/main/java/com/yahoo/metrics/simple/MetricAggregator.java +++ b/container-core/src/main/java/com/yahoo/metrics/simple/MetricAggregator.java @@ -23,8 +23,9 @@ class MetricAggregator implements Runnable { private long fromMillis; private final DimensionCache dimensions; - MetricAggregator(ThreadLocalDirectory metricsCollection, AtomicReference currentSnapshot, - ManagerConfig settings) { + MetricAggregator(ThreadLocalDirectory metricsCollection, + AtomicReference currentSnapshot, + ManagerConfig settings) { if (settings.reportPeriodSeconds() < 10) { throw new IllegalArgumentException("Do not use this metrics implementation" + " if report periods of less than 10 seconds is desired."); diff --git a/container-core/src/main/java/com/yahoo/metrics/simple/MetricManager.java b/container-core/src/main/java/com/yahoo/metrics/simple/MetricManager.java index 40242285486..99465a55a31 100644 --- a/container-core/src/main/java/com/yahoo/metrics/simple/MetricManager.java +++ b/container-core/src/main/java/com/yahoo/metrics/simple/MetricManager.java @@ -21,11 +21,11 @@ import java.util.logging.Level; */ public class MetricManager extends AbstractComponent implements Provider { - private static Logger log = Logger.getLogger(MetricManager.class.getName()); + private static final Logger log = Logger.getLogger(MetricManager.class.getName()); private final ScheduledThreadPoolExecutor executor; private final MetricReceiver receiver; - private ThreadLocalDirectory metricsCollection; + private final ThreadLocalDirectory metricsCollection; public MetricManager(ManagerConfig settings) { this(settings, new MetricUpdater()); @@ -42,7 +42,9 @@ public class MetricManager extends AbstractComponent implements Provider metricsCollection; + + // A reference to the current snapshot. The *reference* is shared with MetricsAggregator and updated from there :-/ private final AtomicReference currentSnapshot; // metricSettings is volatile for reading, the lock is for updates @@ -91,7 +93,7 @@ public class MetricReceiver { /** Gathers all data since last snapshot */ public Bucket getSnapshot() { - final Bucket merged = new Bucket(); + Bucket merged = new Bucket(); for (Bucket b : collection.fetch()) { merged.merge(b, true); } diff --git a/container-core/src/main/java/com/yahoo/metrics/simple/jdisc/SimpleMetricConsumer.java b/container-core/src/main/java/com/yahoo/metrics/simple/jdisc/SimpleMetricConsumer.java index 12f27e9b0ca..bea17bd91bc 100644 --- a/container-core/src/main/java/com/yahoo/metrics/simple/jdisc/SimpleMetricConsumer.java +++ b/container-core/src/main/java/com/yahoo/metrics/simple/jdisc/SimpleMetricConsumer.java @@ -14,7 +14,7 @@ import com.yahoo.metrics.simple.Sample; import com.yahoo.metrics.simple.UntypedMetric.AssumedType; /** - * The single user facing part of the JDisc interfaces of simple metrics. + * The metrics consumer in JDisc. * * @author Steinar Knutsen */ -- cgit v1.2.3