diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-06-15 13:26:01 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-06-15 13:26:01 +0200 |
commit | c2db1d26ebc3b48cc08aaae914c1aa6aec75d215 (patch) | |
tree | 3d76076345cc501c810783f6fb62dce7903e4dbb /configserver/src | |
parent | a07a39e196801307f38373f5a4ad9052fd7ec9b4 (diff) | |
parent | b6392266ccee8cb3e0d3e526ce9291e659c9f73f (diff) |
Merge pull request #18266 from vespa-engine/hmusum/log-more-at-bootstrap
Make sure to always log when all apps have redeployed
Diffstat (limited to 'configserver/src')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/ConfigServerBootstrap.java | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/ConfigServerBootstrap.java b/configserver/src/main/java/com/yahoo/vespa/config/server/ConfigServerBootstrap.java index 772c2bf5125..4c2aa33a886 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/ConfigServerBootstrap.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/ConfigServerBootstrap.java @@ -270,15 +270,20 @@ public class ConfigServerBootstrap extends AbstractComponent implements Runnable } }); if ( ! Duration.between(lastLogged, Instant.now()).minus(Duration.ofSeconds(10)).isNegative()) { - log.log(Level.INFO, () -> finishedDeployments.size() + " of " + applicationCount + " apps redeployed " + - "(" + failedDeployments.size() + " failed)"); + logProgress(applicationCount, failedDeployments, finishedDeployments); lastLogged = Instant.now(); } } while (failedDeployments.size() + finishedDeployments.size() < applicationCount); + logProgress(applicationCount, failedDeployments, finishedDeployments); return new ArrayList<>(failedDeployments); } + private void logProgress(int applicationCount, Set<ApplicationId> failedDeployments, Set<ApplicationId> finishedDeployments) { + log.log(Level.INFO, () -> finishedDeployments.size() + " of " + applicationCount + " apps redeployed " + + "(" + failedDeployments.size() + " failed)"); + } + private DeploymentStatus getDeploymentStatus(ApplicationId applicationId, Future<?> future) { try { future.get(1, TimeUnit.MILLISECONDS); |