Mercurial Hosting > luan
diff src/org/eclipse/jetty/server/AsyncContinuation.java @ 938:a088981f9cd4
remove more async code
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Sun, 09 Oct 2016 23:48:32 -0600 |
parents | 0541b6034003 |
children |
line wrap: on
line diff
--- a/src/org/eclipse/jetty/server/AsyncContinuation.java Sun Oct 09 21:41:28 2016 -0600 +++ b/src/org/eclipse/jetty/server/AsyncContinuation.java Sun Oct 09 23:48:32 2016 -0600 @@ -18,7 +18,6 @@ package org.eclipse.jetty.server; -import org.eclipse.jetty.io.EndPoint; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -26,8 +25,6 @@ public final class AsyncContinuation { private static final Logger LOG = LoggerFactory.getLogger(AsyncContinuation.class); - - private final static long DEFAULT_TIMEOUT=30000L; // STATES: // handling() suspend() unhandle() resume() complete() doComplete() @@ -47,10 +44,6 @@ private static final int __UNCOMPLETED=8; // Request is completable private static final int __COMPLETED=9; // Request is complete - /* ------------------------------------------------------------ */ - protected AbstractHttpConnection _connection; - - /* ------------------------------------------------------------ */ private int _state; AsyncContinuation() @@ -58,12 +51,6 @@ _state=__IDLE; } - protected synchronized void setConnection(final AbstractHttpConnection connection) - { - _connection=connection; - } - - @Override public synchronized String toString() { @@ -137,21 +124,8 @@ default: _state=__IDLE; } - cancelTimeout(); } - private void cancelTimeout() - { - EndPoint endp=_connection.getEndPoint(); - if (endp.isBlocking()) - { - synchronized(this) - { - this.notifyAll(); - } - } - } - synchronized boolean isUncompleted() { return _state==__UNCOMPLETED;