diff options
author | gjoranv <gv@verizonmedia.com> | 2023-03-08 17:04:43 +0100 |
---|---|---|
committer | gjoranv <gv@verizonmedia.com> | 2023-03-09 10:24:16 +0100 |
commit | 7bca5731f1bcc5bc1c3fa64152f6997ca8c2bf25 (patch) | |
tree | 0be70cad405ced4c45cc2b268f9a49a083f51aac /node-admin/src | |
parent | fef0ff505f88e35b49a873be559d27bec876be3e (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.java | 7 |
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()) { |