Mercurial Hosting > luan
annotate src/org/eclipse/jetty/io/nio/SelectorManager.java @ 951:e542a9cc75ef
simplify SelectorManager
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Wed, 12 Oct 2016 18:12:12 -0600 |
parents | a778413aefc0 |
children | 669769bcdf5c |
rev | line source |
---|---|
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
1 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
2 // ======================================================================== |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
3 // Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd. |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
4 // ------------------------------------------------------------------------ |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
5 // All rights reserved. This program and the accompanying materials |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
6 // are made available under the terms of the Eclipse Public License v1.0 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
7 // and Apache License v2.0 which accompanies this distribution. |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
8 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
9 // The Eclipse Public License is available at |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
10 // http://www.eclipse.org/legal/epl-v10.html |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
11 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
12 // The Apache License v2.0 is available at |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
13 // http://www.opensource.org/licenses/apache2.0.php |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
14 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
15 // You may elect to redistribute this code under either of these licenses. |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
16 // ======================================================================== |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
17 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
18 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
19 package org.eclipse.jetty.io.nio; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
20 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
21 import java.io.IOException; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
22 import java.nio.channels.CancelledKeyException; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
23 import java.nio.channels.Channel; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
24 import java.nio.channels.ClosedSelectorException; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
25 import java.nio.channels.SelectableChannel; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
26 import java.nio.channels.SelectionKey; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
27 import java.nio.channels.ServerSocketChannel; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
28 import java.nio.channels.SocketChannel; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
29 import java.util.ArrayList; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
30 import java.util.List; |
944
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
31 import java.util.Collections; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
32 import java.util.Set; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
33 import java.util.concurrent.ConcurrentHashMap; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
34 import java.util.concurrent.ConcurrentLinkedQueue; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
35 import java.util.concurrent.ConcurrentMap; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
36 import java.util.concurrent.CountDownLatch; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
37 import java.util.concurrent.TimeUnit; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
38 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
39 import org.eclipse.jetty.io.AsyncEndPoint; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
40 import org.eclipse.jetty.io.ConnectedEndPoint; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
41 import org.eclipse.jetty.io.Connection; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
42 import org.eclipse.jetty.io.EndPoint; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
43 import org.eclipse.jetty.util.TypeUtil; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
44 import org.eclipse.jetty.util.component.AbstractLifeCycle; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
45 import org.eclipse.jetty.util.component.AggregateLifeCycle; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
46 import org.eclipse.jetty.util.component.Dumpable; |
820
8e9db0bbf4f9
remove org.eclipse.jetty.util.log and upgrade slf4j
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
47 import org.slf4j.Logger; |
8e9db0bbf4f9
remove org.eclipse.jetty.util.log and upgrade slf4j
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
48 import org.slf4j.LoggerFactory; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
49 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
50 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
51 /* ------------------------------------------------------------ */ |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
52 /** |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
53 * The Selector Manager manages and number of SelectSets to allow |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
54 * NIO scheduling to scale to large numbers of connections. |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
55 * <p> |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
56 */ |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
57 public abstract class SelectorManager extends AbstractLifeCycle implements Dumpable |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
58 { |
865 | 59 public static final Logger LOG=LoggerFactory.getLogger("org.eclipse.jetty.io.nio"); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
60 |
865 | 61 private int _maxIdleTime; |
62 private long _lowResourcesConnections; | |
63 private SelectSet[] _selectSet; | |
64 private int _selectSets=1; | |
65 private volatile int _set=0; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
66 |
865 | 67 /* ------------------------------------------------------------ */ |
68 /** | |
69 * @param maxIdleTime The maximum period in milli seconds that a connection may be idle before it is closed. | |
70 * @see #setLowResourcesMaxIdleTime(long) | |
71 */ | |
951
e542a9cc75ef
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
950
diff
changeset
|
72 public void setMaxIdleTime(int maxIdleTime) |
865 | 73 { |
951
e542a9cc75ef
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
950
diff
changeset
|
74 _maxIdleTime = maxIdleTime; |
865 | 75 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
76 |
865 | 77 /* ------------------------------------------------------------ */ |
78 /** | |
79 * @param selectSets number of select sets to create | |
80 */ | |
81 public void setSelectSets(int selectSets) | |
82 { | |
83 long lrc = _lowResourcesConnections * _selectSets; | |
84 _selectSets=selectSets; | |
85 _lowResourcesConnections=lrc/_selectSets; | |
86 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
87 |
865 | 88 /* ------------------------------------------------------------ */ |
89 /** Register a channel | |
90 * @param channel | |
91 */ | |
92 public void register(SocketChannel channel) | |
93 { | |
94 // The ++ increment here is not atomic, but it does not matter. | |
95 // so long as the value changes sometimes, then connections will | |
96 // be distributed over the available sets. | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
97 |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
98 int s = _set++; |
865 | 99 if (s<0) |
100 s=-s; | |
101 s=s%_selectSets; | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
102 SelectSet[] sets = _selectSet; |
865 | 103 if (sets!=null) |
104 { | |
105 SelectSet set=sets[s]; | |
106 set.addChange(channel); | |
107 } | |
108 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
109 |
865 | 110 /* ------------------------------------------------------------ */ |
111 /** | |
112 * @return the lowResourcesConnections | |
113 */ | |
114 public long getLowResourcesConnections() | |
115 { | |
116 return _lowResourcesConnections*_selectSets; | |
117 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
118 |
865 | 119 /* ------------------------------------------------------------ */ |
120 /** | |
121 * Set the number of connections, which if exceeded places this manager in low resources state. | |
122 * This is not an exact measure as the connection count is averaged over the select sets. | |
123 * @param lowResourcesConnections the number of connections | |
124 * @see #setLowResourcesMaxIdleTime(long) | |
125 */ | |
126 public void setLowResourcesConnections(long lowResourcesConnections) | |
127 { | |
128 _lowResourcesConnections=(lowResourcesConnections+_selectSets-1)/_selectSets; | |
129 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
130 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
131 |
865 | 132 public abstract void execute(Runnable task); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
133 |
865 | 134 /* ------------------------------------------------------------ */ |
135 /* (non-Javadoc) | |
136 * @see org.eclipse.component.AbstractLifeCycle#doStart() | |
137 */ | |
138 @Override | |
139 protected void doStart() throws Exception | |
140 { | |
141 _selectSet = new SelectSet[_selectSets]; | |
142 for (int i=0;i<_selectSet.length;i++) | |
143 _selectSet[i]= new SelectSet(i); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
144 |
865 | 145 super.doStart(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
146 |
865 | 147 // start a thread to Select |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
148 for (int i=0;i<_selectSets;i++) |
865 | 149 { |
150 final int id=i; | |
151 execute(new Runnable() | |
152 { | |
153 public void run() | |
154 { | |
155 String name=Thread.currentThread().getName(); | |
156 try | |
157 { | |
158 SelectSet[] sets=_selectSet; | |
159 if (sets==null) | |
160 return; | |
161 SelectSet set=sets[id]; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
162 |
865 | 163 Thread.currentThread().setName(name+" Selector"+id); |
164 LOG.debug("Starting {} on {}",Thread.currentThread(),this); | |
165 while (isRunning()) | |
166 { | |
167 try | |
168 { | |
169 set.doSelect(); | |
170 } | |
171 catch(IOException e) | |
172 { | |
173 LOG.trace("",e); | |
174 } | |
175 catch(Exception e) | |
176 { | |
177 LOG.warn("",e); | |
178 } | |
179 } | |
180 } | |
181 finally | |
182 { | |
183 LOG.debug("Stopped {} on {}",Thread.currentThread(),this); | |
184 Thread.currentThread().setName(name); | |
185 } | |
186 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
187 |
865 | 188 }); |
189 } | |
190 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
191 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
192 |
865 | 193 /* ------------------------------------------------------------------------------- */ |
194 @Override | |
195 protected void doStop() throws Exception | |
196 { | |
197 SelectSet[] sets= _selectSet; | |
198 _selectSet=null; | |
199 if (sets!=null) | |
200 { | |
201 for (SelectSet set : sets) | |
202 { | |
203 if (set!=null) | |
204 set.stop(); | |
205 } | |
206 } | |
207 super.doStop(); | |
208 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
209 |
865 | 210 public abstract AsyncConnection newConnection(SocketChannel channel, AsyncEndPoint endpoint, Object attachment); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
211 |
865 | 212 public String dump() |
213 { | |
214 return AggregateLifeCycle.dump(this); | |
215 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
216 |
865 | 217 public void dump(Appendable out, String indent) throws IOException |
218 { | |
219 AggregateLifeCycle.dumpObject(out,this); | |
220 AggregateLifeCycle.dump(out,indent,TypeUtil.asList(_selectSet)); | |
221 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
222 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
223 |
865 | 224 public class SelectSet implements Dumpable |
225 { | |
226 private final int _setID; | |
943 | 227 private volatile long _now = System.currentTimeMillis(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
228 |
950 | 229 private volatile SaneSelector _selector; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
230 |
865 | 231 private volatile Thread _selecting; |
232 private ConcurrentMap<SelectChannelEndPoint,Object> _endPoints = new ConcurrentHashMap<SelectChannelEndPoint, Object>(); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
233 |
865 | 234 SelectSet(int acceptorID) throws Exception |
235 { | |
236 _setID=acceptorID; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
237 |
865 | 238 // create a selector; |
950 | 239 _selector = new SaneSelector(); |
865 | 240 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
241 |
949
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
242 private void addChange(SocketChannel channel) |
865 | 243 { |
949
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
244 try { |
950 | 245 SelectionKey key = _selector.register(channel,SelectionKey.OP_READ,null); |
949
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
246 SelectChannelEndPoint endpoint = createEndPoint(channel,key); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
247 key.attach(endpoint); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
248 endpoint.schedule(); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
249 } catch(IOException e) { |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
250 LOG.warn("",e); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
251 try { |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
252 channel.close(); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
253 } catch(IOException e2) { |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
254 LOG.warn("",e2); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
255 } |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
256 } |
865 | 257 } |
258 /* ------------------------------------------------------------ */ | |
259 /** | |
260 * Select and dispatch tasks found from changes and the selector. | |
261 * | |
262 * @throws IOException | |
263 */ | |
264 public void doSelect() throws IOException | |
265 { | |
266 try | |
267 { | |
268 _selecting=Thread.currentThread(); | |
950 | 269 final SaneSelector selector = _selector; |
865 | 270 // Stopped concurrently ? |
271 if (selector == null) | |
272 return; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
273 |
951
e542a9cc75ef
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
950
diff
changeset
|
274 selector.select(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
275 |
865 | 276 // Look for things to do |
277 for (SelectionKey key: selector.selectedKeys()) | |
278 { | |
279 SocketChannel channel=null; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
280 |
865 | 281 try |
282 { | |
283 if (!key.isValid()) | |
284 { | |
285 key.cancel(); | |
286 SelectChannelEndPoint endpoint = (SelectChannelEndPoint)key.attachment(); | |
287 if (endpoint != null) | |
288 endpoint.doUpdateKey(); | |
289 continue; | |
290 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
291 |
865 | 292 Object att = key.attachment(); |
293 if (att instanceof SelectChannelEndPoint) | |
294 { | |
295 if (key.isReadable()||key.isWritable()) | |
296 ((SelectChannelEndPoint)att).schedule(); | |
297 } | |
298 else if (key.isConnectable()) | |
299 { | |
300 // Complete a connection of a registered channel | |
301 channel = (SocketChannel)key.channel(); | |
302 boolean connected=false; | |
303 try | |
304 { | |
305 connected=channel.finishConnect(); | |
306 } | |
307 catch(Exception e) | |
308 { | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
309 LOG.warn(e+","+channel+","+att); |
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
310 LOG.debug("",e); |
865 | 311 } |
312 finally | |
313 { | |
314 if (connected) | |
315 { | |
316 key.interestOps(SelectionKey.OP_READ); | |
317 SelectChannelEndPoint endpoint = createEndPoint(channel,key); | |
318 key.attach(endpoint); | |
319 endpoint.schedule(); | |
320 } | |
321 else | |
322 { | |
323 key.cancel(); | |
324 channel.close(); | |
325 } | |
326 } | |
327 } | |
328 else | |
329 { | |
330 // Wrap readable registered channel in an endpoint | |
331 channel = (SocketChannel)key.channel(); | |
332 SelectChannelEndPoint endpoint = createEndPoint(channel,key); | |
333 key.attach(endpoint); | |
334 if (key.isReadable()) | |
335 endpoint.schedule(); | |
336 } | |
337 key = null; | |
338 } | |
339 catch (CancelledKeyException e) | |
340 { | |
341 LOG.trace("",e); | |
342 } | |
343 catch (Exception e) | |
344 { | |
345 if (isRunning()) | |
346 LOG.warn("",e); | |
347 else | |
348 LOG.trace("",e); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
349 |
865 | 350 try |
351 { | |
352 if (channel!=null) | |
353 channel.close(); | |
354 } | |
355 catch(IOException e2) | |
356 { | |
357 LOG.debug("",e2); | |
358 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
359 |
865 | 360 if (key != null && !(key.channel() instanceof ServerSocketChannel) && key.isValid()) |
361 key.cancel(); | |
362 } | |
363 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
364 |
865 | 365 // Everything always handled |
366 selector.selectedKeys().clear(); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
367 |
943 | 368 _now = System.currentTimeMillis(); |
865 | 369 } |
370 catch (ClosedSelectorException e) | |
371 { | |
372 if (isRunning()) | |
373 LOG.warn("",e); | |
374 else | |
375 LOG.trace("",e); | |
376 } | |
377 catch (CancelledKeyException e) | |
378 { | |
379 LOG.trace("",e); | |
380 } | |
381 finally | |
382 { | |
383 _selecting=null; | |
384 } | |
385 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
386 |
865 | 387 public SelectorManager getManager() |
388 { | |
389 return SelectorManager.this; | |
390 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
391 |
865 | 392 public long getNow() |
393 { | |
943 | 394 return _now; |
865 | 395 } |
951
e542a9cc75ef
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
950
diff
changeset
|
396 |
865 | 397 private SelectChannelEndPoint createEndPoint(SocketChannel channel, SelectionKey sKey) throws IOException |
398 { | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
399 SelectChannelEndPoint endp = new SelectChannelEndPoint(channel,this,sKey, _maxIdleTime); |
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
400 endp.setConnection(getManager().newConnection(channel,endp, sKey.attachment())); |
865 | 401 LOG.debug("created {}",endp); |
402 _endPoints.put(endp,this); | |
403 return endp; | |
404 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
405 |
865 | 406 public void destroyEndPoint(SelectChannelEndPoint endp) |
407 { | |
408 LOG.debug("destroyEndPoint {}",endp); | |
409 _endPoints.remove(endp); | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
410 endp.getConnection().onClose(); |
865 | 411 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
412 |
950 | 413 SaneSelector getSelector() |
865 | 414 { |
415 return _selector; | |
416 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
417 |
865 | 418 void stop() throws Exception |
419 { | |
420 // Spin for a while waiting for selector to complete | |
421 // to avoid unneccessary closed channel exceptions | |
950 | 422 /* |
865 | 423 try |
424 { | |
425 for (int i=0;i<100 && _selecting!=null;i++) | |
426 { | |
950 | 427 _selector.wakeup(); |
865 | 428 Thread.sleep(10); |
429 } | |
430 } | |
431 catch(Exception e) | |
432 { | |
944
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
433 LOG.warn("",e); |
865 | 434 } |
950 | 435 */ |
865 | 436 // close endpoints and selector |
437 synchronized (this) | |
438 { | |
951
e542a9cc75ef
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
950
diff
changeset
|
439 for (SelectionKey key : _selector.keys()) |
865 | 440 { |
441 if (key==null) | |
442 continue; | |
443 Object att=key.attachment(); | |
444 if (att instanceof EndPoint) | |
445 { | |
446 EndPoint endpoint = (EndPoint)att; | |
447 try | |
448 { | |
449 endpoint.close(); | |
450 } | |
451 catch(IOException e) | |
452 { | |
453 LOG.trace("",e); | |
454 } | |
455 } | |
456 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
457 |
865 | 458 try |
459 { | |
951
e542a9cc75ef
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
950
diff
changeset
|
460 _selector.close(); |
865 | 461 } |
462 catch (IOException e) | |
463 { | |
464 LOG.trace("",e); | |
465 } | |
944
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
466 _selector = null; |
865 | 467 } |
468 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
469 |
865 | 470 public String dump() |
471 { | |
472 return AggregateLifeCycle.dump(this); | |
473 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
474 |
865 | 475 public void dump(Appendable out, String indent) throws IOException |
476 { | |
477 out.append(String.valueOf(this)).append(" id=").append(String.valueOf(_setID)).append("\n"); | |
944
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
478 AggregateLifeCycle.dump(out,indent,Collections.emptyList()); |
865 | 479 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
480 |
865 | 481 public String toString() |
482 { | |
950 | 483 SaneSelector selector=_selector; |
865 | 484 return String.format("%s keys=%d selected=%d", |
485 super.toString(), | |
486 selector != null && selector.isOpen() ? selector.keys().size() : -1, | |
487 selector != null && selector.isOpen() ? selector.selectedKeys().size() : -1); | |
488 } | |
489 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
490 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
491 } |