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;