diff options
author | Valerij Fredriksen <freva@users.noreply.github.com> | 2017-02-14 14:12:30 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-02-14 14:12:30 +0100 |
commit | 0e06ccad3ad728abff33b7f8b908a6ffa4b37f36 (patch) | |
tree | 8621c1316524fc6c51904802678e7432a5e28b74 /node-admin | |
parent | 9cc94877acbecd340fe48634d1878aac276da26d (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.java | 11 |
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); |