Mercurial Hosting > luan

comparison src/org/eclipse/jetty/server/nio/SelectChannelConnector.java @ 970:d82eb99e8df6

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove ConnectorSelectorManager
author Franklin Schmidt <fschmidt@gmail.com>
date Fri, 14 Oct 2016 05:24:18 -0600
parents 0d20943cfea2
children f997df37cec1
comparison
equal deleted inserted replaced
969:0650077fcd6c 970:d82eb99e8df6
51 * 51 *
52 * @org.apache.xbean.XBean element="nioConnector" description="Creates an NIO based socket connector" 52 * @org.apache.xbean.XBean element="nioConnector" description="Creates an NIO based socket connector"
53 */ 53 */
54 public class SelectChannelConnector extends Connector 54 public class SelectChannelConnector extends Connector
55 { 55 {
56 private final SelectorManager _manager = new ConnectorSelectorManager(); 56 private final SelectorManager _manager = new SelectorManager(this);
57 57
58 public SelectChannelConnector(Server server,int port) 58 public SelectChannelConnector(Server server,int port)
59 { 59 {
60 super(server,port); 60 super(server,port);
61 addBean(_manager,true); 61 addBean(_manager,true);
105 } 105 }
106 106
107 super.doStart(); 107 super.doStart();
108 } 108 }
109 109
110 protected AsyncConnection newConnection(SocketChannel channel,AsyncEndPoint endpoint) 110 public AsyncConnection newConnection(SocketChannel channel,AsyncEndPoint endpoint)
111 { 111 {
112 return new AsyncHttpConnection(SelectChannelConnector.this,endpoint,server); 112 return new AsyncHttpConnection(SelectChannelConnector.this,endpoint,server);
113 } 113 }
114
115
116 private final class ConnectorSelectorManager extends SelectorManager
117 {
118 ConnectorSelectorManager() {
119 super(_maxIdleTime);
120 }
121
122 @Override
123 public void execute(Runnable task)
124 {
125 server.threadPool.execute(task);
126 }
127
128 @Override
129 public AsyncConnection newConnection(SocketChannel channel,SelectChannelEndPoint endpoint)
130 {
131 return SelectChannelConnector.this.newConnection(channel,endpoint);
132 }
133 }
134 } 114 }