diff options
author | jonmv <venstad@gmail.com> | 2023-08-28 15:30:37 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-08-28 15:30:37 +0200 |
commit | a8e2f22f3b722543c1116f1a29845ef1093dcfe8 (patch) | |
tree | 1b4f8d19d28d85bbeae9d9f60f0c8066fa4d5039 /vespajlib/src/test/java/com/yahoo | |
parent | 308ee70e0b33057ac9ba5852d7226c731dd52bf8 (diff) |
Spread maintainer interval boundaries based on class name hash
Diffstat (limited to 'vespajlib/src/test/java/com/yahoo')
-rw-r--r-- | vespajlib/src/test/java/com/yahoo/concurrent/maintenance/MaintainerTest.java | 27 | ||||
-rw-r--r-- | vespajlib/src/test/java/com/yahoo/concurrent/maintenance/TestMaintainer.java | 8 |
2 files changed, 21 insertions, 14 deletions
diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/MaintainerTest.java b/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/MaintainerTest.java index cdb5e36a455..01e23c81971 100644 --- a/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/MaintainerTest.java +++ b/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/MaintainerTest.java @@ -24,21 +24,28 @@ public class MaintainerTest { List<String> cluster = List.of("cfg1", "cfg2", "cfg3"); Duration interval = Duration.ofMillis(300); Instant now = Instant.ofEpochMilli(1000); - assertEquals(200, Maintainer.staggeredDelay(interval, now, "cfg1", cluster).toMillis()); - assertEquals(0, Maintainer.staggeredDelay(interval, now, "cfg2", cluster).toMillis()); - assertEquals(100, Maintainer.staggeredDelay(interval, now, "cfg3", cluster).toMillis()); + // ∠( ᐛ 」∠)_ + class MaintainerWithBestHashE extends TestMaintainer { MaintainerWithBestHashE() { super(null, jobControl, new TestJobMetrics()); } } + class MaintainerWithBestHashF extends TestMaintainer { MaintainerWithBestHashF() { super(null, jobControl, new TestJobMetrics()); } } + class MaintainerWithBestHashG extends TestMaintainer { MaintainerWithBestHashG() { super(null, jobControl, new TestJobMetrics()); } } + Maintainer maintainer = new MaintainerWithBestHashF(); + assertEquals(200, maintainer.staggeredDelay(interval, now, "cfg1", cluster).toMillis()); + assertEquals(299, new MaintainerWithBestHashE().staggeredDelay(interval, now, "cfg2", cluster).toMillis()); + assertEquals(0, maintainer.staggeredDelay(interval, now, "cfg2", cluster).toMillis()); + assertEquals(1, new MaintainerWithBestHashG().staggeredDelay(interval, now, "cfg2", cluster).toMillis()); + assertEquals(100, maintainer.staggeredDelay(interval, now, "cfg3", cluster).toMillis()); now = Instant.ofEpochMilli(1001); - assertEquals(199, Maintainer.staggeredDelay(interval, now, "cfg1", cluster).toMillis()); - assertEquals(299, Maintainer.staggeredDelay(interval, now, "cfg2", cluster).toMillis()); - assertEquals(99, Maintainer.staggeredDelay(interval, now, "cfg3", cluster).toMillis()); + assertEquals(199, maintainer.staggeredDelay(interval, now, "cfg1", cluster).toMillis()); + assertEquals(299, maintainer.staggeredDelay(interval, now, "cfg2", cluster).toMillis()); + assertEquals(99, maintainer.staggeredDelay(interval, now, "cfg3", cluster).toMillis()); now = Instant.ofEpochMilli(1101); - assertEquals(99, Maintainer.staggeredDelay(interval, now, "cfg1", cluster).toMillis()); - assertEquals(199, Maintainer.staggeredDelay(interval, now, "cfg2", cluster).toMillis()); - assertEquals(299, Maintainer.staggeredDelay(interval, now, "cfg3", cluster).toMillis()); + assertEquals(99, maintainer.staggeredDelay(interval, now, "cfg1", cluster).toMillis()); + assertEquals(199, maintainer.staggeredDelay(interval, now, "cfg2", cluster).toMillis()); + assertEquals(299, maintainer.staggeredDelay(interval, now, "cfg3", cluster).toMillis()); - assertEquals(300, Maintainer.staggeredDelay(interval, now, "cfg0", cluster).toMillis()); + assertEquals(300, maintainer.staggeredDelay(interval, now, "cfg0", cluster).toMillis()); } @Test diff --git a/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/TestMaintainer.java b/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/TestMaintainer.java index d8191b98a51..9e994312738 100644 --- a/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/TestMaintainer.java +++ b/vespajlib/src/test/java/com/yahoo/concurrent/maintenance/TestMaintainer.java @@ -15,20 +15,20 @@ class TestMaintainer extends Maintainer { private double success = 1.0; private RuntimeException exceptionToThrow = null; - public TestMaintainer(String name, JobControl jobControl, JobMetrics jobMetrics) { + TestMaintainer(String name, JobControl jobControl, JobMetrics jobMetrics) { super(name, Duration.ofDays(1), Clock.systemUTC(), jobControl, jobMetrics, List.of(), false); } - public int totalRuns() { + int totalRuns() { return totalRuns; } - public TestMaintainer successOnNextRun(double success) { + TestMaintainer successOnNextRun(double success) { this.success = success; return this; } - public TestMaintainer throwOnNextRun(RuntimeException e) { + TestMaintainer throwOnNextRun(RuntimeException e) { this.exceptionToThrow = e; return this; } |