diff options
author | Harald Musum <musum@yahooinc.com> | 2023-03-28 19:33:41 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2023-03-28 19:33:41 +0200 |
commit | 198bdb42cc17e8948da7479939012372be13c8dc (patch) | |
tree | b0fd4f7213109ba18d4f3560122e01485614eba7 /vdslib | |
parent | a9646ed0608bf59ed831617eec559a10723fe7fa (diff) |
Don't use record, fails when running system tests
Diffstat (limited to 'vdslib')
-rw-r--r-- | vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java | 24 |
1 files changed, 21 insertions, 3 deletions
diff --git a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java index 9eb88661002..9a451ac56ec 100644 --- a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java +++ b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java @@ -26,7 +26,15 @@ import java.util.concurrent.atomic.AtomicReference; public class Distribution { - private record Config(Group nodeGraph, int redundancy) { } + private static class Config { + Config(Group nodeGraph, int redundancy) { + this.nodeGraph = nodeGraph; + this.redundancy = redundancy; + } + + private final Group nodeGraph; + private final int redundancy; + } private ConfigSubscriber configSub; private final AtomicReference<Config> config = new AtomicReference<>(new Config(null, 1)); @@ -201,10 +209,20 @@ public class Distribution { } } - private record ScoredNode(int index, double score) { + private static class ScoredNode { + final double score; + final int index; + + ScoredNode(int index, double score) { + this.score = score; + this.index = index; + } boolean valid() { return index != -1; } - static ScoredNode makeInvalid() { return new ScoredNode(-1, 0.0); } + + static ScoredNode makeInvalid() { + return new ScoredNode(-1, 0.0); + } } private static boolean allDistributorsDown(Group g, ClusterState clusterState) { |