diff options
author | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2018-01-03 15:24:53 +0100 |
---|---|---|
committer | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2018-01-03 15:24:53 +0100 |
commit | 9565f8df80a0764878fe879c31865c29e7f69a76 (patch) | |
tree | cc79d2e0086a12507c9c0ccb1bc7d00a5497b176 /controller-server/src | |
parent | f9321adb9c847dc5d412d99aad12f64a002c2776 (diff) |
Remove redundant condition (and parameters) for ApplicationList filter
Diffstat (limited to 'controller-server/src')
4 files changed, 8 insertions, 10 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/ApplicationList.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/ApplicationList.java index 4d1a009806f..340bafb8926 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/ApplicationList.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/ApplicationList.java @@ -122,8 +122,8 @@ public class ApplicationList { } /** Returns the subset of applications which started failing after the given instant */ - public ApplicationList startedFailingOnVersionAfter(Version version, Instant instant) { - return listOf(list.stream().filter(application -> JobList.from(application).firstFailing().on(version).firstFailing().after(instant).anyMatch())); + public ApplicationList startedFailingOnVersionAfter(Version version) { + return listOf(list.stream().filter(application -> JobList.from(application).firstFailing().on(version).anyMatch())); } /** Returns the subset of applications which has the given upgrade policy */ diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java index 6f895c32be7..647000aebab 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VersionStatus.java @@ -184,11 +184,11 @@ public class VersionStatus { VespaVersion.Confidence confidence; // Always compute confidence for system version if (isSystemVersion) { - confidence = VespaVersion.confidenceFrom(statistics, controller, releasedAt); + confidence = VespaVersion.confidenceFrom(statistics, controller); } else { // Keep existing confidence for non-system versions if already computed confidence = confidenceFor(statistics.version(), controller) - .orElse(VespaVersion.confidenceFrom(statistics, controller, releasedAt)); + .orElse(VespaVersion.confidenceFrom(statistics, controller)); } return new VespaVersion(statistics, gitSha.sha, releasedAt, diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VespaVersion.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VespaVersion.java index 3b06fbf8615..04ee176c9a4 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VespaVersion.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/versions/VespaVersion.java @@ -42,8 +42,7 @@ public class VespaVersion implements Comparable<VespaVersion> { this.confidence = confidence; } - public static Confidence confidenceFrom(DeploymentStatistics statistics, Controller controller, - Instant releasedAt) { + public static Confidence confidenceFrom(DeploymentStatistics statistics, Controller controller) { // 'production on this': All deployment jobs upgrading to this version have completed without failure ApplicationList productionOnThis = ApplicationList.from(statistics.production(), controller.applications()) .notUpgradingTo(statistics.version()) @@ -58,7 +57,7 @@ public class VespaVersion implements Comparable<VespaVersion> { return Confidence.broken; // 'broken' if 4 non-canary was broken by this, and that is at least 10% of all - if (nonCanaryApplicationsBroken(statistics.version(), failingOnThis, productionOnThis, releasedAt, controller.curator())) + if (nonCanaryApplicationsBroken(statistics.version(), failingOnThis, productionOnThis, controller.curator())) return Confidence.broken; // 'low' unless all canary applications are upgraded @@ -145,9 +144,8 @@ public class VespaVersion implements Comparable<VespaVersion> { private static boolean nonCanaryApplicationsBroken(Version version, ApplicationList failingOnThis, ApplicationList productionOnThis, - Instant releasedAt, CuratorDb curator) { - ApplicationList failingNonCanaries = failingOnThis.without(UpgradePolicy.canary).startedFailingOnVersionAfter(version, releasedAt); + ApplicationList failingNonCanaries = failingOnThis.without(UpgradePolicy.canary).startedFailingOnVersionAfter(version); ApplicationList productionNonCanaries = productionOnThis.without(UpgradePolicy.canary); if (productionNonCanaries.size() + failingNonCanaries.size() == 0 || curator.readIgnoreConfidence()) return false; diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/deployment/DeploymentApiTest.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/deployment/DeploymentApiTest.java index 7b689923138..c3ce5c95dcd 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/deployment/DeploymentApiTest.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/deployment/DeploymentApiTest.java @@ -85,7 +85,7 @@ public class DeploymentApiTest extends ControllerContainerTest { version.releasedAt(), version.isCurrentSystemVersion(), ImmutableSet.of("config1.test", "config2.test"), - VespaVersion.confidenceFrom(version.statistics(), controller, version.releasedAt()) + VespaVersion.confidenceFrom(version.statistics(), controller) ); censored.add(version); } |