Mercurial Hosting > luan

comparison src/org/eclipse/jetty/server/nio/BlockingChannelConnector.java @ 978:bdb6eb0fbf93

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
simplify ChannelEndPoint
author Franklin Schmidt <fschmidt@gmail.com>
date Sun, 16 Oct 2016 14:53:43 -0600
parents 53b3f7d9714c
children d9cfec64899c
comparison
equal deleted inserted replaced
977:d35b0a3a7a4a 978:bdb6eb0fbf93
136 public void customize(EndPoint endpoint, Request request) 136 public void customize(EndPoint endpoint, Request request)
137 throws IOException 137 throws IOException
138 { 138 {
139 super.customize(endpoint, request); 139 super.customize(endpoint, request);
140 endpoint.setMaxIdleTime(_maxIdleTime); 140 endpoint.setMaxIdleTime(_maxIdleTime);
141 configure(((SocketChannel)endpoint.getTransport()).socket()); 141 configure(endpoint.getChannel().socket());
142 } 142 }
143 143
144 144
145 private class BlockingChannelEndPoint extends ChannelEndPoint implements Runnable 145 private class BlockingChannelEndPoint extends ChannelEndPoint implements Runnable
146 { 146 {
147 private final BlockingHttpConnection _connection; 147 private final BlockingHttpConnection _connection;
148 private int _timeout; 148 private int _timeout;
149 private volatile long _idleTimestamp; 149 private volatile long _idleTimestamp;
150 150
151 BlockingChannelEndPoint(ByteChannel channel) 151 BlockingChannelEndPoint(SocketChannel channel)
152 throws IOException 152 throws IOException
153 { 153 {
154 super(channel,BlockingChannelConnector.this._maxIdleTime); 154 super(channel,BlockingChannelConnector.this._maxIdleTime);
155 _connection = new BlockingHttpConnection(BlockingChannelConnector.this,this); 155 _connection = new BlockingHttpConnection(BlockingChannelConnector.this,this);
156 } 156 }