diff options
| author | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2018-07-06 12:22:56 +0200 |
|---|---|---|
| committer | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2018-07-06 12:22:56 +0200 |
| commit | 6a5c2167977fd99ed0502f732fff9e20cf3e0900 (patch) | |
| tree | d9ffcb7a95370ac3ee290324219344918b09b89c /controller-server | |
| parent | 95540cadc561a0d286d9439602d5ecb396e9f8db (diff) | |
Expand Node interface and check for pending re[boot|start|s
Diffstat (limited to 'controller-server')
| -rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/InternalStepRunner.java | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/InternalStepRunner.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/InternalStepRunner.java index e6f2263b8eb..77b6baa6bea 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/InternalStepRunner.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/InternalStepRunner.java @@ -261,12 +261,18 @@ public class InternalStepRunner implements StepRunner { List<Node> nodes = controller.configServer().nodeRepository().list(zone(type), id, Arrays.asList(active, reserved)); for (Node node : nodes) // TODO jvenstad: Add ALLOWED_TO_BE_DOWN and reboot and restart generation information as well. - logger.get().log(String.format("%70s: %s%s", + logger.get().log(String.format("%70s: %-12s%-25s%-32s%s", node.hostname(), - node.wantedVersion(), - node.currentVersion().equals(node.wantedVersion()) ? "" : " <-- " + node.currentVersion())); - - return nodes.stream().allMatch(node -> target.equals(node.currentVersion())); + node.serviceState(), + node.wantedVersion() + (node.currentVersion().equals(node.wantedVersion()) ? "" : " <-- " + node.currentVersion()), + node.restartGeneration() == node.wantedRestartGeneration() ? "" + : "restart pending (" + node.wantedRestartGeneration() + " <-- " + node.restartGeneration() + ")", + node.rebootGeneration() == node.wantedRebootGeneration() ? "" + : "reboot pending (" + node.wantedRebootGeneration() + " <-- " + node.rebootGeneration() + ")")); + + return nodes.stream().allMatch(node -> node.currentVersion().equals(target) + && node.restartGeneration() == node.wantedRestartGeneration() + && node.rebootGeneration() == node.wantedRebootGeneration()); } private boolean servicesConverged(ApplicationId id, JobType type) { |