summaryrefslogtreecommitdiffstats
path: root/node-admin
diff options
context:
space:
mode:
authorHarald Musum <musum@yahoo-inc.com>2016-10-13 15:02:16 +0200
committerHarald Musum <musum@yahoo-inc.com>2016-10-13 15:02:16 +0200
commite173c6ba61e33ceb8b87c0c1172df01d5c5ec073 (patch)
tree6b64df48e3c3422b045682cc048f0adaff46efb1 /node-admin
parent4781e77d144f932913d0e37924ed931bbd880e13 (diff)
Add guard so that we do not update metrics unless container is running
Diffstat (limited to 'node-admin')
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java1
-rw-r--r--node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImplTest.java3
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);