Cosmetic changes

scalecube · Jun 26, 2024 · 9064abc · 9064abc
1 parent 0cbac52
commit 9064abc
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/cluster2/src/main/java/io/scalecube/cluster2/AbstractAgent.java b/cluster2/src/main/java/io/scalecube/cluster2/AbstractAgent.java
@@ -109,7 +109,7 @@ private int processExpiredCalls() {
       }
     }
 
-    for (int n = expiredCalls.size() - 1, i = n; i >= 0; i--) {
+    for (int n = expiredCalls.size(), i = n - 1; i >= 0; i--) {
       invokeCallback(expiredCalls.fastUnorderedRemove(i), null);
     }
 

diff --git a/cluster2/src/main/java/io/scalecube/cluster2/fdetector/FailureDetector.java b/cluster2/src/main/java/io/scalecube/cluster2/fdetector/FailureDetector.java
@@ -119,7 +119,7 @@ private void nextPingReqMembers(Member pingMember) {
   }
 
   private void doPingRequest(Member pingMember) {
-    for (int n = pingReqMembers.size() - 1, i = n; i >= 0; i--) {
+    for (int n = pingReqMembers.size(), i = n - 1; i >= 0; i--) {
       final Member member = pingReqMembers.get(i);
       ArrayListUtil.fastUnorderedRemove(pingReqMembers, i);
 

diff --git a/cluster2/src/main/java/io/scalecube/cluster2/gossip/GossipProtocol.java b/cluster2/src/main/java/io/scalecube/cluster2/gossip/GossipProtocol.java
@@ -88,7 +88,7 @@ protected void onTick() {
 
     nextGossipMembers();
 
-    for (int n = gossipMembers.size() - 1, i = n; i >= 0; i--) {
+    for (int n = gossipMembers.size(), i = n - 1; i >= 0; i--) {
       final Member member = gossipMembers.get(i);
       ArrayListUtil.fastUnorderedRemove(gossipMembers, i);
       spreadGossips(period, member);
@@ -98,7 +98,7 @@ protected void onTick() {
 
     nextGossipsToRemove(period);
 
-    for (int n = gossipsToRemove.size() - 1, i = n; i >= 0; i--) {
+    for (int n = gossipsToRemove.size(), i = n - 1; i >= 0; i--) {
       final int index = gossipsToRemove.fastUnorderedRemove(i);
       ArrayListUtil.fastUnorderedRemove(gossips, index);
     }
@@ -155,7 +155,7 @@ private void spreadGossips(long period, Member member) {
     final String address = member.address();
     final UUID from = localMember.id();
 
-    for (int n = gossipsToSend.size() - 1, i = n; i >= 0; i--) {
+    for (int n = gossipsToSend.size(), i = n - 1; i >= 0; i--) {
       final Gossip gossip = gossips.get(gossipsToSend.fastUnorderedRemove(i));
       transport.send(
           address, gossipRequestCodec.encode(from, gossip), 0, gossipRequestCodec.encodedLength());