Mercurial Hosting > luan

comparison src/org/eclipse/jetty/server/nio/BlockingChannelConnector.java @ 968:0d20943cfea2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove ConnectedEndPoint
author Franklin Schmidt <fschmidt@gmail.com>
date Fri, 14 Oct 2016 02:37:53 -0600
parents 8a8dc0b1742f
children 5ee36654b383
comparison
equal deleted inserted replaced
967:8a8dc0b1742f 968:0d20943cfea2
29 import java.util.concurrent.ConcurrentHashMap; 29 import java.util.concurrent.ConcurrentHashMap;
30 import java.util.concurrent.RejectedExecutionException; 30 import java.util.concurrent.RejectedExecutionException;
31 31
32 import org.eclipse.jetty.http.HttpException; 32 import org.eclipse.jetty.http.HttpException;
33 import org.eclipse.jetty.io.Buffer; 33 import org.eclipse.jetty.io.Buffer;
34 import org.eclipse.jetty.io.ConnectedEndPoint;
35 import org.eclipse.jetty.io.Connection; 34 import org.eclipse.jetty.io.Connection;
36 import org.eclipse.jetty.io.EndPoint; 35 import org.eclipse.jetty.io.EndPoint;
37 import org.eclipse.jetty.io.EofException; 36 import org.eclipse.jetty.io.EofException;
38 import org.eclipse.jetty.io.nio.ChannelEndPoint; 37 import org.eclipse.jetty.io.nio.ChannelEndPoint;
39 import org.eclipse.jetty.server.BlockingHttpConnection; 38 import org.eclipse.jetty.server.BlockingHttpConnection;
137 endpoint.setMaxIdleTime(_maxIdleTime); 136 endpoint.setMaxIdleTime(_maxIdleTime);
138 configure(((SocketChannel)endpoint.getTransport()).socket()); 137 configure(((SocketChannel)endpoint.getTransport()).socket());
139 } 138 }
140 139
141 140
142 private class BlockingChannelEndPoint extends ChannelEndPoint implements Runnable, ConnectedEndPoint 141 private class BlockingChannelEndPoint extends ChannelEndPoint implements Runnable
143 { 142 {
144 private Connection _connection; 143 private Connection _connection;
145 private int _timeout; 144 private int _timeout;
146 private volatile long _idleTimestamp; 145 private volatile long _idleTimestamp;
147 146