WIP

scalecube · Jul 12, 2024 · a8de185 · a8de185
1 parent 3033ec5
commit a8de185
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/cluster2/src/main/java/io/scalecube/cluster2/gossip/GossipProtocol.java b/cluster2/src/main/java/io/scalecube/cluster2/gossip/GossipProtocol.java
@@ -304,21 +304,13 @@ void nextGossipMembers() {
 
       final int step = gossipFanout;
       final int limit = step * (size / step);
-      final int nextLimit;
 
       if (index >= limit) {
         index = 0;
-        nextLimit = step;
         shuffle();
-      } else {
-        nextLimit = index + step;
-        if (nextLimit > limit) {
-          index = 0;
-          shuffle();
-        }
       }
 
-      for (; index < nextLimit; index++) {
+      for (int n = index + step; index < n; index++) {
         gossipMembers.add(remoteMembers.get(index));
       }
     }