Mercurial Hosting > luan
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)