WIP

scalecube · Jun 24, 2024 · 7f18be2 · 7f18be2
1 parent 4e9bf91
commit 7f18be2
Showing 1 changed file with 6 additions and 2 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
@@ -81,16 +81,20 @@ protected void onTick() {
       return;
     }
 
+    // Spread gossips
+
     nextGossipMembers();
 
     for (int i = 0, n = gossipMembers.size(); i < n; i++) {
       spreadGossipsTo(period, gossipMembers.get(i));
     }
 
+    // Sweep gossips
+
     nextGossipsToRemove(period);
 
-    for (String gossipId : gossipsToRemove) {
-      gossips.remove(gossipId);
+    for (int i = 0, n = gossipsToRemove.size(); i < n; i++) {
+      gossips.remove(gossipsToRemove.get(i));
     }
   }