aboutsummaryrefslogtreecommitdiffstats
path: root/node-admin
diff options
context:
space:
mode:
authorValerij Fredriksen <freva@users.noreply.github.com>2017-02-14 14:12:30 +0100
committerGitHub <noreply@github.com>2017-02-14 14:12:30 +0100
commit0e06ccad3ad728abff33b7f8b908a6ffa4b37f36 (patch)
tree8621c1316524fc6c51904802678e7432a5e28b74 /node-admin
parent9cc94877acbecd340fe48634d1878aac276da26d (diff)
Revert "Fix docker metrics"
Diffstat (limited to 'node-admin')
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java11
1 files changed, 5 insertions, 6 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
index fd8e200e673..f60ba83460d 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
@@ -102,6 +102,8 @@ public class NodeAgentImpl implements NodeAgent {
NodeRepositoryImpl.containerNameFromHostName(hostName));
this.metricReceiver = metricReceiver;
this.environment = environment;
+
+ container.map(Container::getCreatedAsInstant).ifPresent(created -> lastCpuMetric = new CpuUsageReporter(created));
}
@Override
@@ -160,13 +162,10 @@ public class NodeAgentImpl implements NodeAgent {
throw new RuntimeException("Can not restart a node agent.");
}
- // If the container is already running, initialize vespaVersion and lastCpuMetric
- dockerOperations.getContainer(hostname)
+ // If the container is already running, initialize vespaVersion
+ vespaVersion = dockerOperations.getContainer(hostname)
.filter(container -> container.state.isRunning())
- .ifPresent(container -> {
- vespaVersion = dockerOperations.getVespaVersion(container.name);
- lastCpuMetric = new CpuUsageReporter(container.getCreatedAsInstant());
- });
+ .flatMap(container -> dockerOperations.getVespaVersion(container.name));
loopThread = new Thread(this::loop);
loopThread.setName("loop-" + hostname);