Mercurial Hosting > luan
comparison src/org/eclipse/jetty/server/nio/SelectChannelConnector.java @ 948:f5aefdc4a81a
simplify SelectChannelConnector
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 11 Oct 2016 22:16:29 -0600 |
parents | 0541b6034003 |
children | a778413aefc0 |
comparison
equal
deleted
inserted
replaced
947:64f3d8dae31d | 948:f5aefdc4a81a |
---|---|
98 | 98 |
99 @Override | 99 @Override |
100 protected synchronized void doStart() throws Exception | 100 protected synchronized void doStart() throws Exception |
101 { | 101 { |
102 _manager.setSelectSets(getAcceptors()); | 102 _manager.setSelectSets(getAcceptors()); |
103 _manager.setMaxIdleTime(getMaxIdleTime()); | 103 // _manager.setMaxIdleTime(getMaxIdleTime()); |
104 _manager.setLowResourcesConnections(0); | 104 _manager.setLowResourcesConnections(0); |
105 | 105 |
106 if (_acceptChannel == null) | 106 if (_acceptChannel == null) |
107 { | 107 { |
108 // Create a new server socket | 108 // Create a new server socket |
119 } | 119 } |
120 | 120 |
121 super.doStart(); | 121 super.doStart(); |
122 } | 122 } |
123 | 123 |
124 protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey key) throws IOException | |
125 { | |
126 SelectChannelEndPoint endp= new SelectChannelEndPoint(channel,selectSet,key, SelectChannelConnector.this._maxIdleTime); | |
127 endp.setConnection(selectSet.getManager().newConnection(channel,endp, key.attachment())); | |
128 return endp; | |
129 } | |
130 | |
131 protected void endPointClosed(SelectChannelEndPoint endpoint) | |
132 { | |
133 endpoint.getConnection().onClose(); | |
134 } | |
135 | |
136 protected AsyncConnection newConnection(SocketChannel channel,final AsyncEndPoint endpoint) | 124 protected AsyncConnection newConnection(SocketChannel channel,final AsyncEndPoint endpoint) |
137 { | 125 { |
138 return new AsyncHttpConnection(SelectChannelConnector.this,endpoint,server); | 126 return new AsyncHttpConnection(SelectChannelConnector.this,endpoint,server); |
139 } | 127 } |
140 | 128 |
146 { | 134 { |
147 server.threadPool.execute(task); | 135 server.threadPool.execute(task); |
148 } | 136 } |
149 | 137 |
150 @Override | 138 @Override |
151 protected void endPointClosed(final SelectChannelEndPoint endpoint) | |
152 { | |
153 SelectChannelConnector.this.endPointClosed(endpoint); | |
154 } | |
155 | |
156 @Override | |
157 public AsyncConnection newConnection(SocketChannel channel,AsyncEndPoint endpoint, Object attachment) | 139 public AsyncConnection newConnection(SocketChannel channel,AsyncEndPoint endpoint, Object attachment) |
158 { | 140 { |
159 return SelectChannelConnector.this.newConnection(channel,endpoint); | 141 return SelectChannelConnector.this.newConnection(channel,endpoint); |
160 } | 142 } |
161 | |
162 @Override | |
163 protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey sKey) throws IOException | |
164 { | |
165 return SelectChannelConnector.this.newEndPoint(channel,selectSet,sKey); | |
166 } | |
167 } | 143 } |
168 } | 144 } |