Merge pull request #841 from cfredri4/fix-infinite-loop-in-tcp-use_acks

JGRP-2838 Fix infinite loop in TCP when using use_acks
belaban · Oct 1, 2024 · 0154970 · 0154970
2 parents 97e0425 + 53d1e5d
commit 0154970
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/org/jgroups/blocks/cs/BaseServer.java b/src/org/jgroups/blocks/cs/BaseServer.java
@@ -17,6 +17,7 @@
 import java.io.DataInput;
 import java.io.IOException;
 import java.net.ConnectException;
+import java.net.SocketTimeoutException;
 import java.net.InetAddress;
 import java.nio.ByteBuffer;
 import java.util.*;
@@ -302,11 +303,12 @@ public Connection getConnection(Address dest, boolean retry) throws Exception {
             try {
                 conn=getConnection(dest);
             }
-            catch(ConnectException | SSLException ex) {
+            catch(ConnectException | SocketTimeoutException | SSLException ex) {
                 throw ex;
             }
             catch(Exception ise) {
                 Util.sleepRandom(1, 100);
+                log.trace("%s: retrying connection to %s", local_addr, dest);
             }
         }
         while(!connected(conn));