diff src/org/eclipse/jetty/server/AsyncHttpConnection.java @ 920:3268ddf919d4

remove AsyncContinuation.isAsyncStarted()
author Franklin Schmidt <fschmidt@gmail.com>
date Sun, 09 Oct 2016 03:51:31 -0600
parents 8e9db0bbf4f9
children 23a57aad34c0
line wrap: on
line diff
--- a/src/org/eclipse/jetty/server/AsyncHttpConnection.java	Sun Oct 09 03:45:31 2016 -0600
+++ b/src/org/eclipse/jetty/server/AsyncHttpConnection.java	Sun Oct 09 03:51:31 2016 -0600
@@ -83,7 +83,7 @@
                         progress=true;
 
                     // Generate more output
-                    if (_generator.isCommitted() && !_generator.isComplete() && !_endp.isOutputShutdown() && !_request.getAsyncContinuation().isAsyncStarted())
+                    if (_generator.isCommitted() && !_generator.isComplete() && !_endp.isOutputShutdown())
                         if (_generator.flushBuffer()>0)
                             progress=true;
 
@@ -145,14 +145,6 @@
                             LOG.debug("Disabled read interest while writing response {}", _endp);
                         }
                     }
-
-                    if (!complete && _request.getAsyncContinuation().isAsyncStarted())
-                    {
-                        // The request is suspended, so even though progress has been made,
-                        // exit the while loop by setting progress to false
-                        LOG.debug("suspended {}",this);
-                        progress=false;
-                    }
                 }
             }
         }
@@ -160,16 +152,12 @@
         {
             setCurrentConnection(null);
 
-            // If we are not suspended
-            if (!_request.getAsyncContinuation().isAsyncStarted())
-            {
-                // return buffers
-                _parser.returnBuffers();
-                _generator.returnBuffers();
+            // return buffers
+            _parser.returnBuffers();
+            _generator.returnBuffers();
 
-                // reenable idle checking unless request is suspended
-                _asyncEndp.setCheckForIdle(true);
-            }
+            // reenable idle checking unless request is suspended
+            _asyncEndp.setCheckForIdle(true);
 
             // Safety net to catch spinning
             if (some_progress)