Merge #2140 into main

reactor · Apr 4, 2022 · 9ad339b · 9ad339b
2 parents cfa3aab + 34837af
commit 9ad339b
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/reactor-netty-http/src/main/java/reactor/netty/http/client/HttpClientConnect.java b/reactor-netty-http/src/main/java/reactor/netty/http/client/HttpClientConnect.java
@@ -39,6 +39,7 @@
 import io.netty.handler.codec.http.HttpMethod;
 import io.netty.handler.codec.http.HttpUtil;
 import io.netty.handler.codec.http.HttpVersion;
+import io.netty.handler.ssl.SslClosedEngineException;
 import io.netty.resolver.AddressResolverGroup;
 import io.netty.util.AsciiString;
 import io.netty.util.AttributeKey;
@@ -382,6 +383,16 @@ else if (handler.shouldRetry && AbortedException.isConnectionReset(error)) {
 					}
 				}
 			}
+			else if (error instanceof SslClosedEngineException) {
+				if (log.isWarnEnabled()) {
+					log.warn(format(connection.channel(), "The connection observed an error"), error);
+				}
+				HttpClientOperations ops = connection.as(HttpClientOperations.class);
+				if (ops != null) {
+					// javax.net.ssl.SSLEngine has been closed, do not return the connection to the pool
+					ops.markPersistent(false);
+				}
+			}
 			else if (log.isWarnEnabled()) {
 				log.warn(format(connection.channel(), "The connection observed an error"), error);
 			}