Spread maintainer interval boundaries based on class name hash

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;
     }