diff options
author | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2017-10-17 16:41:10 +0200 |
---|---|---|
committer | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2017-10-17 16:41:10 +0200 |
commit | c9f988cec83eb79148dd6236911dc8013cb6b7e2 (patch) | |
tree | f75439772b0cbf3d1b24cbe5e4980d2e60ec6ead /controller-server/src | |
parent | 080389c6153107c7debeaa1ad197795afb9c7635 (diff) |
Cleaner code
Diffstat (limited to 'controller-server/src')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java | 23 |
1 files changed, 13 insertions, 10 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java index 7a771464957..7d645fa046e 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java @@ -9,6 +9,7 @@ import com.yahoo.vespa.hosted.controller.application.DeploymentMetrics; import java.io.UncheckedIOException; import java.time.Duration; +import java.util.logging.Level; import java.util.logging.Logger; /** @@ -36,22 +37,24 @@ public class DeploymentMetricsMaintainer extends Maintainer { DeploymentMetrics appMetrics = new DeploymentMetrics(metrics.queriesPerSecond(), metrics.writesPerSecond(), metrics.documentCount(), metrics.queryLatencyMillis(), metrics.writeLatencyMillis()); - // Avoid locking for a long time, due to slow YAMAS. try (Lock lock = controller().applications().lock(application.id())) { - // Deployment (or application) may have changed (or be gone) now: - controller().applications().get(application.id()).ifPresent(freshApplication -> { - Deployment freshDeployment = freshApplication.deployments().get(deployment.zone()); - if (freshDeployment != null) - controller().applications().store(freshApplication.with(freshDeployment.withMetrics(appMetrics)), lock); - }); + + // Deployment or application may have changed (or be gone) now: + application = controller().applications().require(application.id()); + if (application == null) + break; + + deployment = application.deployments().get(deployment.zone()); + if (deployment == null) + continue; + + controller().applications().store(application.with(deployment.withMetrics(appMetrics)), lock); } } catch (UncheckedIOException e) { - log.warning("Timed out talking to YAMAS; retrying in " + maintenanceInterval() + ":\n" + e); + log.log(Level.WARNING, "Timed out talking to YAMAS; retrying in " + maintenanceInterval() + ":\n", e); } - } - } } |