Bug fix: Correct the issue with connection state detection in Default…

…ManagedAsyncClientConnection#isOpen().
apache · Oct 17, 2024 · b45e981 · b45e981
1 parent d68f8b0
commit b45e981
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/...rc/main/java/org/apache/hc/client5/http/impl/nio/DefaultManagedAsyncClientConnection.java b/...rc/main/java/org/apache/hc/client5/http/impl/nio/DefaultManagedAsyncClientConnection.java
@@ -98,7 +98,20 @@ public void close() throws IOException {
 
     @Override
     public boolean isOpen() {
-        return ioSession.isOpen();
+        final IOSession ioSession = this.ioSession;
+        if (ioSession.isOpen()) {
+            final IOEventHandler handler = ioSession.getHandler();
+            if (handler instanceof HttpConnection) {
+                final HttpConnection conn = (HttpConnection) handler;
+                final ProtocolVersion protocolVersion = conn.getProtocolVersion();
+                if (protocolVersion != null && protocolVersion.greaterEquals(HttpVersion.HTTP_2)) {
+                    return conn.isOpen();
+                }
+            }
+            return true;
+        } else {
+            return false;
+        }
     }
 
     @Override