Fix issues close exceptions

arturobernalg · arturobernalg · commit 3857494f5a7b · 2026-03-23T20:44:47.000+01:00
diff --git a/httpcore5-h2/src/main/java/org/apache/hc/core5/http2/nio/support/H2OverH2TunnelExchangeHandler.java b/httpcore5-h2/src/main/java/org/apache/hc/core5/http2/nio/support/H2OverH2TunnelExchangeHandler.java
@@ -254,9 +254,9 @@ public void streamEnd(final List<? extends Header> trailers) {
             tunnel.onRemoteStreamEnd();
         } else {
             closeTransport(CloseMode.GRACEFUL);
-        }
-        if (done.compareAndSet(false, true) && callback != null) {
-            callback.failed(new ConnectionClosedException("Tunnel stream closed"));
+            if (done.compareAndSet(false, true) && callback != null) {
+                callback.failed(new ConnectionClosedException("Tunnel stream closed before establishment"));
+            }
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -254,9 +254,9 @@ public void streamEnd(final List<? extends Header> trailers) {`
`254`	`254`	`tunnel.onRemoteStreamEnd();`
`255`	`255`	`} else {`
`256`	`256`	`closeTransport(CloseMode.GRACEFUL);`
`257`		`- }`
`258`		`- if (done.compareAndSet(false, true) && callback != null) {`
`259`		`- callback.failed(new ConnectionClosedException("Tunnel stream closed"));`
	`257`	`+ if (done.compareAndSet(false, true) && callback != null) {`
	`258`	`+ callback.failed(new ConnectionClosedException("Tunnel stream closed before establishment"));`
	`259`	`+ }`
`260`	`260`	`}`
`261`	`261`	`}`
`262`	`262`