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