diff options
author | Harald Musum <musum@yahoo-inc.com> | 2016-10-13 15:02:16 +0200 |
---|---|---|
committer | Harald Musum <musum@yahoo-inc.com> | 2016-10-13 15:02:16 +0200 |
commit | e173c6ba61e33ceb8b87c0c1172df01d5c5ec073 (patch) | |
tree | 6b64df48e3c3422b045682cc048f0adaff46efb1 /node-admin | |
parent | 4781e77d144f932913d0e37924ed931bbd880e13 (diff) |
Add guard so that we do not update metrics unless container is running
Diffstat (limited to 'node-admin')
2 files changed, 4 insertions, 0 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 2bceeba2863..067e3ad6739 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 @@ -460,6 +460,7 @@ public class NodeAgentImpl implements NodeAgent { } if (nodeSpec == null || nodeSpec.nodeState != Node.State.active) return; + if ( ! dockerOperations.getContainer(nodeSpec.hostname).isPresent()) return; Docker.ContainerStats stats = dockerOperations.getContainerStats(nodeSpec.containerName); Dimensions.Builder dimensionsBuilder = new Dimensions.Builder() diff --git a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImplTest.java b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImplTest.java index ddda3fe13e3..0c9d6881a0d 100644 --- a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImplTest.java +++ b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImplTest.java @@ -419,6 +419,9 @@ public class NodeAgentImplTest { final ContainerName containerName = new ContainerName("cont-name"); when(dockerOperations.getContainerStats(eq(containerName))).thenReturn(stats); + when(dockerOperations.getContainer(eq(hostName))) + .thenReturn(Optional.of(new Container(hostName, new DockerImage("wantedDockerImage"), containerName, true))); + Optional<String> version = Optional.of("1.2.3"); ContainerNodeSpec.Owner owner = new ContainerNodeSpec.Owner("tester", "testapp", "testinstance"); ContainerNodeSpec.Membership membership = new ContainerNodeSpec.Membership("clustType", "clustId", "grp", 3, false); |