diff options
author | valerijf <valerijf@yahoo-inc.com> | 2017-05-30 11:45:37 +0200 |
---|---|---|
committer | valerijf <valerijf@yahoo-inc.com> | 2017-05-30 11:50:46 +0200 |
commit | efb7bccc10495dbb980bcabe75fabf9658382f6c (patch) | |
tree | e5b47745271f7ee4a17cbf121bc158019069c84a | |
parent | eafee523715af6137523fb084977c8d51fafe51d (diff) |
Write configs on container start as well
-rw-r--r-- | node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java | 14 |
1 files changed, 10 insertions, 4 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 4efa74dbd8e..b160b4ac364 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 @@ -239,6 +239,8 @@ public class NodeAgentImpl implements NodeAgent { dockerOperations.startContainer(containerName, nodeSpec); lastCpuMetric = new CpuUsageReporter(clock.instant()); + writeConfigs(nodeSpec); + addDebugMessage("startContainerIfNeeded: containerState " + containerState + " -> " + RUNNING_HOWEVER_RESUME_SCRIPT_NOT_RUN); containerState = RUNNING_HOWEVER_RESUME_SCRIPT_NOT_RUN; @@ -410,10 +412,7 @@ public class NodeAgentImpl implements NodeAgent { // TODO: Should be retried if writing fails metricReceiver.unsetMetricsForContainer(hostname); if (container.isPresent()) { - storageMaintainer.ifPresent(maintainer -> { - maintainer.writeMetricsConfig(containerName, nodeSpec); - maintainer.writeFilebeatConfig(containerName, nodeSpec); - }); + writeConfigs(nodeSpec); } } @@ -606,6 +605,13 @@ public class NodeAgentImpl implements NodeAgent { } } + private void writeConfigs(ContainerNodeSpec nodeSpec) { + storageMaintainer.ifPresent(maintainer -> { + maintainer.writeMetricsConfig(containerName, nodeSpec); + maintainer.writeFilebeatConfig(containerName, nodeSpec); + }); + } + private Optional<Container> getContainer() { if (containerState == ABSENT) return Optional.empty(); return dockerOperations.getContainer(containerName); |