summaryrefslogtreecommitdiffstats
path: root/container-disc/src/main/java/com/yahoo/container/jdisc/metric/MetricUpdater.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-disc/src/main/java/com/yahoo/container/jdisc/metric/MetricUpdater.java')
-rw-r--r--container-disc/src/main/java/com/yahoo/container/jdisc/metric/MetricUpdater.java14
1 files changed, 9 insertions, 5 deletions
diff --git a/container-disc/src/main/java/com/yahoo/container/jdisc/metric/MetricUpdater.java b/container-disc/src/main/java/com/yahoo/container/jdisc/metric/MetricUpdater.java
index 3d026172c86..22b049c9ab7 100644
--- a/container-disc/src/main/java/com/yahoo/container/jdisc/metric/MetricUpdater.java
+++ b/container-disc/src/main/java/com/yahoo/container/jdisc/metric/MetricUpdater.java
@@ -4,6 +4,7 @@ package com.yahoo.container.jdisc.metric;
import com.google.inject.Inject;
import com.yahoo.component.AbstractComponent;
import com.yahoo.jdisc.Metric;
+import com.yahoo.jdisc.statistics.ContainerWatchdogMetrics;
import java.nio.file.DirectoryStream;
import java.nio.file.Files;
@@ -34,13 +35,13 @@ public class MetricUpdater extends AbstractComponent {
private final Scheduler scheduler;
@Inject
- public MetricUpdater(Metric metric) {
- this(new TimerScheduler(), metric);
+ public MetricUpdater(Metric metric, ContainerWatchdogMetrics containerWatchdogMetrics) {
+ this(new TimerScheduler(), metric, containerWatchdogMetrics);
}
- MetricUpdater(Scheduler scheduler, Metric metric) {
+ MetricUpdater(Scheduler scheduler, Metric metric, ContainerWatchdogMetrics containerWatchdogMetrics) {
this.scheduler = scheduler;
- scheduler.schedule(new UpdaterTask(metric), Duration.ofSeconds(10));
+ scheduler.schedule(new UpdaterTask(metric, containerWatchdogMetrics), Duration.ofSeconds(10));
}
@Override
@@ -87,9 +88,11 @@ public class MetricUpdater extends AbstractComponent {
private final Runtime runtime = Runtime.getRuntime();
private final Metric metric;
+ private final ContainerWatchdogMetrics containerWatchdogMetrics;
- public UpdaterTask(Metric metric) {
+ public UpdaterTask(Metric metric, ContainerWatchdogMetrics containerWatchdogMetrics) {
this.metric = metric;
+ this.containerWatchdogMetrics = containerWatchdogMetrics;
}
@SuppressWarnings("deprecation")
@@ -106,6 +109,7 @@ public class MetricUpdater extends AbstractComponent {
metric.set(TOTAL_MEMORY_BYTES, totalMemory, null);
metric.set(MEMORY_MAPPINGS_COUNT, count_mappings(), null);
metric.set(OPEN_FILE_DESCRIPTORS, count_open_files(), null);
+ containerWatchdogMetrics.emitMetrics(metric);
}
}