fix

leixm · leixm · commit a8c60c78c92f · 2025-09-26T19:02:57.000+08:00
diff --git a/ratis-common/src/main/java/org/apache/ratis/util/IOUtils.java b/ratis-common/src/main/java/org/apache/ratis/util/IOUtils.java
@@ -101,12 +101,14 @@ static <T> T getFromFuture(CompletableFuture<T> future, Supplier<Object> name, T
   }
 
   static boolean shouldReconnect(Throwable e) {
-    if (e == null) return false;
-    if (ReflectionUtils.isInstance(e, NETWORK_EXCEPTIONS)) {
-      return true;
+    for (; e != null; e = e.getCause()) {
+      if (ReflectionUtils.isInstance(e,
+          SocketException.class, SocketTimeoutException.class, ClosedChannelException.class, EOFException.class,
+          AlreadyClosedException.class, TimeoutIOException.class)) {
+        return true;
+      }
     }
-    return e.getCause() != null &&
-        ReflectionUtils.isInstance(e.getCause(), NETWORK_EXCEPTIONS);
+    return false;
   }
 
   static void readFully(InputStream in, int buffSize) throws IOException {

Original file line number	Diff line number	Diff line change
`@@ -101,12 +101,14 @@ static <T> T getFromFuture(CompletableFuture<T> future, Supplier<Object> name, T`
`101`	`101`	`}`
`102`	`102`
`103`	`103`	`static boolean shouldReconnect(Throwable e) {`
`104`		`- if (e == null) return false;`
`105`		`- if (ReflectionUtils.isInstance(e, NETWORK_EXCEPTIONS)) {`
`106`		`- return true;`
	`104`	`+ for (; e != null; e = e.getCause()) {`
	`105`	`+ if (ReflectionUtils.isInstance(e,`
	`106`	`+ SocketException.class, SocketTimeoutException.class, ClosedChannelException.class, EOFException.class,`
	`107`	`+ AlreadyClosedException.class, TimeoutIOException.class)) {`
	`108`	`+ return true;`
	`109`	`+ }`
`107`	`110`	`}`
`108`		`- return e.getCause() != null &&`
`109`		`- ReflectionUtils.isInstance(e.getCause(), NETWORK_EXCEPTIONS);`
	`111`	`+ return false;`
`110`	`112`	`}`
`111`	`113`
`112`	`114`	`static void readFully(InputStream in, int buffSize) throws IOException {`