diff --git a/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java b/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java
index ab6dc4e4246..616dc0d8e91 100644
--- a/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java
+++ b/jetty-server/src/main/java/org/eclipse/jetty/server/HttpConnection.java
@@ -498,6 +498,27 @@ public class HttpConnection extends AbstractConnection implements Runnable, Http
              */
         }
 
+        @Override
+        public void earlyEOF()
+        {
+            synchronized (lock())
+            {
+                _inputEOF=true;
+                _earlyEOF = true;
+                LOG.debug("{} early EOF", this);
+            }
+        }
+
+        @Override
+        public void shutdown()
+        {
+            synchronized (lock())
+            {
+                _inputEOF=true;
+                LOG.debug("{} shutdown", this);
+            }
+        }
+        
         @Override
         protected void onAllContentConsumed()
         {
diff --git a/jetty-server/src/main/java/org/eclipse/jetty/server/HttpInput.java b/jetty-server/src/main/java/org/eclipse/jetty/server/HttpInput.java
index f166e82b51a..7b3808d451e 100644
--- a/jetty-server/src/main/java/org/eclipse/jetty/server/HttpInput.java
+++ b/jetty-server/src/main/java/org/eclipse/jetty/server/HttpInput.java
@@ -43,8 +43,8 @@ public abstract class HttpInput<T> extends ServletInputStream
 {
     private final static Logger LOG = Log.getLogger(HttpInput.class);
     private final ArrayQueue<T> _inputQ = new ArrayQueue<>();
-    private boolean _earlyEOF;
-    private boolean _inputEOF;
+    protected boolean _earlyEOF;
+    protected boolean _inputEOF;
 
     public Object lock()
     {