summaryrefslogtreecommitdiffstats
path: root/node-admin/src
diff options
context:
space:
mode:
authorgjoranv <gv@verizonmedia.com>2023-03-08 17:04:43 +0100
committergjoranv <gv@verizonmedia.com>2023-03-09 10:24:16 +0100
commit7bca5731f1bcc5bc1c3fa64152f6997ca8c2bf25 (patch)
tree0be70cad405ced4c45cc2b268f9a49a083f51aac /node-admin/src
parentfef0ff505f88e35b49a873be559d27bec876be3e (diff)
Run wireguard tasks if container has been restarted.
Diffstat (limited to 'node-admin/src')
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java7
1 files changed, 4 insertions, 3 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 7143874114d..20359410321 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
@@ -484,10 +484,10 @@ public class NodeAgentImpl implements NodeAgent {
storageMaintainer.handleCoreDumpsForContainer(context, container, false);
// TODO: this is a workaround for restarting wireguard as early as possible after host-admin has been down.
- var wireguardTasksRun = false;
+ var runOrdinaryWireguardTasks = true;
if (container.isPresent() && container.get().state().isRunning()) {
wireguardTasks.forEach(task -> task.converge(context));
- wireguardTasksRun = true;
+ runOrdinaryWireguardTasks = false;
}
if (downloadImageIfNeeded(context, container)) {
@@ -500,12 +500,13 @@ public class NodeAgentImpl implements NodeAgent {
containerState = STARTING;
container = Optional.of(startContainer(context));
containerState = UNKNOWN;
+ runOrdinaryWireguardTasks = true;
} else {
container = Optional.of(updateContainerIfNeeded(context, container.get()));
}
aclMaintainer.ifPresent(maintainer -> maintainer.converge(context));
- if (! wireguardTasksRun) wireguardTasks.forEach(task -> task.converge(context));
+ if (runOrdinaryWireguardTasks) wireguardTasks.forEach(task -> task.converge(context));
startServicesIfNeeded(context);
resumeNodeIfNeeded(context);
if (healthChecker.isPresent()) {