diff src/org/eclipse/jetty/server/nio/BlockingChannelConnector.java @ 1001:39154cfa58e4

minor
author Franklin Schmidt <fschmidt@gmail.com>
date Sat, 22 Oct 2016 20:56:41 -0600
parents d9cfec64899c
children 3fa54d9d19cd
line wrap: on
line diff
--- a/src/org/eclipse/jetty/server/nio/BlockingChannelConnector.java	Wed Oct 19 04:22:51 2016 -0600
+++ b/src/org/eclipse/jetty/server/nio/BlockingChannelConnector.java	Sat Oct 22 20:56:41 2016 -0600
@@ -38,6 +38,7 @@
 import org.eclipse.jetty.server.Connector;
 import org.eclipse.jetty.server.Request;
 import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.server.AbstractHttpConnection;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -123,21 +124,21 @@
 		Socket socket = channel.socket();
 		configure(socket);
 
-		BlockingChannelEndPoint connection = new BlockingChannelEndPoint(channel);
+		BlockingChannelEndPoint endp = new BlockingChannelEndPoint(channel);
 		try {
-			server.threadPool.execute(connection);
+			server.threadPool.execute(endp);
 		} catch(RejectedExecutionException e) {
-			LOG.warn("dispatch failed for  {}",connection._connection);
-			connection.close();
+			LOG.warn("dispatch failed for  {}",endp._connection);
+			endp.close();
 		}
 	}
 
 	@Override
-	public void customize(EndPoint endpoint, Request request)
+	public void customize(AbstractHttpConnection con)
 		throws IOException
 	{
-		endpoint.setMaxIdleTime(_maxIdleTime);
-		configure(endpoint.getChannel().socket());
+		con._endp.setMaxIdleTime(_maxIdleTime);
+		configure(con._endp.getChannel().socket());
 	}
 
 
@@ -202,7 +203,6 @@
 				{
 					_idleTimestamp = System.currentTimeMillis();
 					_connection.handle();
-
 				}
 			}
 			catch (EofException e)