Mark HTTP/1.1 async connection as not open (non-reusable) as soon as it becomes closed by the opposite endpoint

Author: ok2c

httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/AbstractHttp1StreamDuplexer.java

@@ -105,6 +105,7 @@ private enum ConnectionState { READY, ACTIVE, GRACEFUL_SHUTDOWN, SHUTDOWN}
 
     private volatile ProtocolVersion version;
     private volatile EndpointDetails endpointDetails;
+    private volatile boolean endOfStream;
 
     AbstractHttp1StreamDuplexer(
             final ProtocolIOSession ioSession,
@@ -277,13 +278,14 @@ public final void onInput(final ByteBuffer src) throws HttpException, IOExceptio
             return;
         }
 
-        boolean endOfStream = false;
         if (incomingMessage == null) {
             final int bytesRead = inbuf.fill(ioSession);
             if (bytesRead > 0) {
                 inTransportMetrics.incrementBytesTransferred(bytesRead);
             }
-            endOfStream = bytesRead == -1;
+            if (bytesRead == -1) {
+                endOfStream = true;
+            }
         }
 
         do {
@@ -561,7 +563,7 @@ public void close(final CloseMode closeMode) {
 
     @Override
     public boolean isOpen() {
-        return connState.compareTo(ConnectionState.ACTIVE) <= 0;
+        return connState.compareTo(ConnectionState.ACTIVE) <= 0 && !endOfStream;
     }
 
     @Override