Mercurial Hosting > luan
annotate src/org/eclipse/jetty/io/nio/SelectorManager.java @ 950:a778413aefc0
add SaneSelector
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Wed, 12 Oct 2016 14:37:56 -0600 |
parents | e9088af3787f |
children | e542a9cc75ef |
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 static final int __MONITOR_PERIOD=Integer.getInteger("org.eclipse.jetty.io.nio.MONITOR_PERIOD",1000).intValue(); |
62 private static final int __MAX_SELECTS=Integer.getInteger("org.eclipse.jetty.io.nio.MAX_SELECTS",100000).intValue(); | |
63 private static final int __BUSY_PAUSE=Integer.getInteger("org.eclipse.jetty.io.nio.BUSY_PAUSE",50).intValue(); | |
64 private static final int __IDLE_TICK=Integer.getInteger("org.eclipse.jetty.io.nio.IDLE_TICK",400).intValue(); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
65 |
865 | 66 private int _maxIdleTime; |
67 private long _lowResourcesConnections; | |
68 private SelectSet[] _selectSet; | |
69 private int _selectSets=1; | |
70 private volatile int _set=0; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
71 |
865 | 72 /* ------------------------------------------------------------ */ |
73 /** | |
74 * @param maxIdleTime The maximum period in milli seconds that a connection may be idle before it is closed. | |
75 * @see #setLowResourcesMaxIdleTime(long) | |
76 */ | |
77 public void setMaxIdleTime(long maxIdleTime) | |
78 { | |
79 _maxIdleTime=(int)maxIdleTime; | |
80 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
81 |
865 | 82 /* ------------------------------------------------------------ */ |
83 /** | |
84 * @param selectSets number of select sets to create | |
85 */ | |
86 public void setSelectSets(int selectSets) | |
87 { | |
88 long lrc = _lowResourcesConnections * _selectSets; | |
89 _selectSets=selectSets; | |
90 _lowResourcesConnections=lrc/_selectSets; | |
91 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
92 |
865 | 93 /* ------------------------------------------------------------ */ |
94 /** Register a channel | |
95 * @param channel | |
96 */ | |
97 public void register(SocketChannel channel) | |
98 { | |
99 // The ++ increment here is not atomic, but it does not matter. | |
100 // so long as the value changes sometimes, then connections will | |
101 // be distributed over the available sets. | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
102 |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
103 int s = _set++; |
865 | 104 if (s<0) |
105 s=-s; | |
106 s=s%_selectSets; | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
107 SelectSet[] sets = _selectSet; |
865 | 108 if (sets!=null) |
109 { | |
110 SelectSet set=sets[s]; | |
111 set.addChange(channel); | |
112 } | |
113 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
114 |
865 | 115 /* ------------------------------------------------------------ */ |
116 /** | |
117 * @return the lowResourcesConnections | |
118 */ | |
119 public long getLowResourcesConnections() | |
120 { | |
121 return _lowResourcesConnections*_selectSets; | |
122 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
123 |
865 | 124 /* ------------------------------------------------------------ */ |
125 /** | |
126 * Set the number of connections, which if exceeded places this manager in low resources state. | |
127 * This is not an exact measure as the connection count is averaged over the select sets. | |
128 * @param lowResourcesConnections the number of connections | |
129 * @see #setLowResourcesMaxIdleTime(long) | |
130 */ | |
131 public void setLowResourcesConnections(long lowResourcesConnections) | |
132 { | |
133 _lowResourcesConnections=(lowResourcesConnections+_selectSets-1)/_selectSets; | |
134 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
135 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
136 |
865 | 137 public abstract void execute(Runnable task); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
138 |
865 | 139 /* ------------------------------------------------------------ */ |
140 /* (non-Javadoc) | |
141 * @see org.eclipse.component.AbstractLifeCycle#doStart() | |
142 */ | |
143 @Override | |
144 protected void doStart() throws Exception | |
145 { | |
146 _selectSet = new SelectSet[_selectSets]; | |
147 for (int i=0;i<_selectSet.length;i++) | |
148 _selectSet[i]= new SelectSet(i); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
149 |
865 | 150 super.doStart(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
151 |
865 | 152 // start a thread to Select |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
153 for (int i=0;i<_selectSets;i++) |
865 | 154 { |
155 final int id=i; | |
156 execute(new Runnable() | |
157 { | |
158 public void run() | |
159 { | |
160 String name=Thread.currentThread().getName(); | |
161 try | |
162 { | |
163 SelectSet[] sets=_selectSet; | |
164 if (sets==null) | |
165 return; | |
166 SelectSet set=sets[id]; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
167 |
865 | 168 Thread.currentThread().setName(name+" Selector"+id); |
169 LOG.debug("Starting {} on {}",Thread.currentThread(),this); | |
170 while (isRunning()) | |
171 { | |
172 try | |
173 { | |
174 set.doSelect(); | |
175 } | |
176 catch(IOException e) | |
177 { | |
178 LOG.trace("",e); | |
179 } | |
180 catch(Exception e) | |
181 { | |
182 LOG.warn("",e); | |
183 } | |
184 } | |
185 } | |
186 finally | |
187 { | |
188 LOG.debug("Stopped {} on {}",Thread.currentThread(),this); | |
189 Thread.currentThread().setName(name); | |
190 } | |
191 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
192 |
865 | 193 }); |
194 } | |
195 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
196 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
197 |
865 | 198 /* ------------------------------------------------------------------------------- */ |
199 @Override | |
200 protected void doStop() throws Exception | |
201 { | |
202 SelectSet[] sets= _selectSet; | |
203 _selectSet=null; | |
204 if (sets!=null) | |
205 { | |
206 for (SelectSet set : sets) | |
207 { | |
208 if (set!=null) | |
209 set.stop(); | |
210 } | |
211 } | |
212 super.doStop(); | |
213 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
214 |
865 | 215 /* ------------------------------------------------------------------------------- */ |
216 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
|
217 |
865 | 218 public String dump() |
219 { | |
220 return AggregateLifeCycle.dump(this); | |
221 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
222 |
865 | 223 public void dump(Appendable out, String indent) throws IOException |
224 { | |
225 AggregateLifeCycle.dumpObject(out,this); | |
226 AggregateLifeCycle.dump(out,indent,TypeUtil.asList(_selectSet)); | |
227 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
228 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
229 |
865 | 230 public class SelectSet implements Dumpable |
231 { | |
232 private final int _setID; | |
943 | 233 private volatile long _now = System.currentTimeMillis(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
234 |
950 | 235 private volatile SaneSelector _selector; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
236 |
865 | 237 private volatile Thread _selecting; |
238 private int _busySelects; | |
239 private long _monitorNext; | |
240 private boolean _pausing; | |
241 private boolean _paused; | |
242 private volatile long _idleTick; | |
243 private ConcurrentMap<SelectChannelEndPoint,Object> _endPoints = new ConcurrentHashMap<SelectChannelEndPoint, Object>(); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
244 |
865 | 245 SelectSet(int acceptorID) throws Exception |
246 { | |
247 _setID=acceptorID; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
248 |
865 | 249 _idleTick = System.currentTimeMillis(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
250 |
865 | 251 // create a selector; |
950 | 252 _selector = new SaneSelector(); |
865 | 253 _monitorNext=System.currentTimeMillis()+__MONITOR_PERIOD; |
254 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
255 |
949
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
256 private void addChange(SocketChannel channel) |
865 | 257 { |
949
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
258 try { |
950 | 259 SelectionKey key = _selector.register(channel,SelectionKey.OP_READ,null); |
949
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
260 SelectChannelEndPoint endpoint = createEndPoint(channel,key); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
261 key.attach(endpoint); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
262 endpoint.schedule(); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
263 } catch(IOException e) { |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
264 LOG.warn("",e); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
265 try { |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
266 channel.close(); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
267 } catch(IOException e2) { |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
268 LOG.warn("",e2); |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
269 } |
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
270 } |
865 | 271 } |
272 /* ------------------------------------------------------------ */ | |
273 /** | |
274 * Select and dispatch tasks found from changes and the selector. | |
275 * | |
276 * @throws IOException | |
277 */ | |
278 public void doSelect() throws IOException | |
279 { | |
280 try | |
281 { | |
282 _selecting=Thread.currentThread(); | |
950 | 283 final SaneSelector selector = _selector; |
865 | 284 // Stopped concurrently ? |
285 if (selector == null) | |
286 return; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
287 |
865 | 288 // Do and instant select to see if any connections can be handled. |
950 | 289 // int selected = selector.selectNow(); |
290 int selected = selector.select(); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
291 |
943 | 292 _now = System.currentTimeMillis(); |
950 | 293 /* |
865 | 294 // if no immediate things to do |
295 if (selected==0 && selector.selectedKeys().isEmpty()) | |
296 { | |
950 | 297 |
865 | 298 // If we are in pausing mode |
299 if (_pausing) | |
300 { | |
301 try | |
302 { | |
303 Thread.sleep(__BUSY_PAUSE); // pause to reduce impact of busy loop | |
304 } | |
305 catch(InterruptedException e) | |
306 { | |
307 LOG.trace("",e); | |
308 } | |
943 | 309 _now = System.currentTimeMillis(); |
865 | 310 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
311 |
865 | 312 // workout how long to wait in select |
949
e9088af3787f
remove SelectSet._changes
Franklin Schmidt <fschmidt@gmail.com>
parents:
948
diff
changeset
|
313 long wait = __IDLE_TICK; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
314 |
865 | 315 // If we should wait with a select |
316 if (wait>0) | |
317 { | |
943 | 318 long before = _now; |
865 | 319 selector.select(wait); |
950 | 320 // selector.select(10000L); |
943 | 321 _now = System.currentTimeMillis(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
322 |
865 | 323 // If we are monitoring for busy selector |
324 // and this select did not wait more than 1ms | |
943 | 325 if (__MONITOR_PERIOD>0 && _now-before <=1) |
865 | 326 { |
327 // count this as a busy select and if there have been too many this monitor cycle | |
328 if (++_busySelects>__MAX_SELECTS) | |
329 { | |
330 // Start injecting pauses | |
331 _pausing=true; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
332 |
865 | 333 // if this is the first pause |
334 if (!_paused) | |
335 { | |
336 // Log and dump some status | |
337 _paused=true; | |
338 LOG.warn("Selector {} is too busy, pausing!",this); | |
339 } | |
340 } | |
341 } | |
342 } | |
343 } | |
950 | 344 */ |
865 | 345 // have we been destroyed while sleeping |
346 if (_selector==null || !selector.isOpen()) | |
347 return; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
348 |
865 | 349 // Look for things to do |
350 for (SelectionKey key: selector.selectedKeys()) | |
351 { | |
352 SocketChannel channel=null; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
353 |
865 | 354 try |
355 { | |
356 if (!key.isValid()) | |
357 { | |
358 key.cancel(); | |
359 SelectChannelEndPoint endpoint = (SelectChannelEndPoint)key.attachment(); | |
360 if (endpoint != null) | |
361 endpoint.doUpdateKey(); | |
362 continue; | |
363 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
364 |
865 | 365 Object att = key.attachment(); |
366 if (att instanceof SelectChannelEndPoint) | |
367 { | |
368 if (key.isReadable()||key.isWritable()) | |
369 ((SelectChannelEndPoint)att).schedule(); | |
370 } | |
371 else if (key.isConnectable()) | |
372 { | |
373 // Complete a connection of a registered channel | |
374 channel = (SocketChannel)key.channel(); | |
375 boolean connected=false; | |
376 try | |
377 { | |
378 connected=channel.finishConnect(); | |
379 } | |
380 catch(Exception e) | |
381 { | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
382 LOG.warn(e+","+channel+","+att); |
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
383 LOG.debug("",e); |
865 | 384 } |
385 finally | |
386 { | |
387 if (connected) | |
388 { | |
389 key.interestOps(SelectionKey.OP_READ); | |
390 SelectChannelEndPoint endpoint = createEndPoint(channel,key); | |
391 key.attach(endpoint); | |
392 endpoint.schedule(); | |
393 } | |
394 else | |
395 { | |
396 key.cancel(); | |
397 channel.close(); | |
398 } | |
399 } | |
400 } | |
401 else | |
402 { | |
403 // Wrap readable registered channel in an endpoint | |
404 channel = (SocketChannel)key.channel(); | |
405 SelectChannelEndPoint endpoint = createEndPoint(channel,key); | |
406 key.attach(endpoint); | |
407 if (key.isReadable()) | |
408 endpoint.schedule(); | |
409 } | |
410 key = null; | |
411 } | |
412 catch (CancelledKeyException e) | |
413 { | |
414 LOG.trace("",e); | |
415 } | |
416 catch (Exception e) | |
417 { | |
418 if (isRunning()) | |
419 LOG.warn("",e); | |
420 else | |
421 LOG.trace("",e); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
422 |
865 | 423 try |
424 { | |
425 if (channel!=null) | |
426 channel.close(); | |
427 } | |
428 catch(IOException e2) | |
429 { | |
430 LOG.debug("",e2); | |
431 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
432 |
865 | 433 if (key != null && !(key.channel() instanceof ServerSocketChannel) && key.isValid()) |
434 key.cancel(); | |
435 } | |
436 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
437 |
865 | 438 // Everything always handled |
439 selector.selectedKeys().clear(); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
440 |
943 | 441 _now = System.currentTimeMillis(); |
950 | 442 /* |
865 | 443 // Idle tick |
943 | 444 if (_now-_idleTick>__IDLE_TICK) |
865 | 445 { |
943 | 446 _idleTick = _now; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
447 |
865 | 448 final long idle_now=((_lowResourcesConnections>0 && selector.keys().size()>_lowResourcesConnections)) |
943 | 449 ?(_now+_maxIdleTime) |
450 :_now; | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
451 |
865 | 452 execute(new Runnable() |
453 { | |
454 public void run() | |
455 { | |
456 for (SelectChannelEndPoint endp:_endPoints.keySet()) | |
457 { | |
458 endp.checkIdleTimestamp(idle_now); | |
459 } | |
460 } | |
461 public String toString() {return "Idle-"+super.toString();} | |
462 }); | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
463 |
865 | 464 } |
950 | 465 */ |
865 | 466 // Reset busy select monitor counts |
943 | 467 if (__MONITOR_PERIOD>0 && _now>_monitorNext) |
865 | 468 { |
469 _busySelects=0; | |
470 _pausing=false; | |
943 | 471 _monitorNext=_now+__MONITOR_PERIOD; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
472 |
865 | 473 } |
474 } | |
475 catch (ClosedSelectorException e) | |
476 { | |
477 if (isRunning()) | |
478 LOG.warn("",e); | |
479 else | |
480 LOG.trace("",e); | |
481 } | |
482 catch (CancelledKeyException e) | |
483 { | |
484 LOG.trace("",e); | |
485 } | |
486 finally | |
487 { | |
488 _selecting=null; | |
489 } | |
490 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
491 |
865 | 492 public SelectorManager getManager() |
493 { | |
494 return SelectorManager.this; | |
495 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
496 |
865 | 497 public long getNow() |
498 { | |
943 | 499 return _now; |
865 | 500 } |
950 | 501 /* |
865 | 502 public void wakeup() |
503 { | |
950 | 504 SaneSelector selector = _selector; |
944
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
505 if (selector!=null) |
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
506 selector.wakeup(); |
865 | 507 } |
950 | 508 */ |
865 | 509 private SelectChannelEndPoint createEndPoint(SocketChannel channel, SelectionKey sKey) throws IOException |
510 { | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
511 SelectChannelEndPoint endp = new SelectChannelEndPoint(channel,this,sKey, _maxIdleTime); |
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
512 endp.setConnection(getManager().newConnection(channel,endp, sKey.attachment())); |
865 | 513 LOG.debug("created {}",endp); |
514 _endPoints.put(endp,this); | |
515 return endp; | |
516 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
517 |
865 | 518 public void destroyEndPoint(SelectChannelEndPoint endp) |
519 { | |
520 LOG.debug("destroyEndPoint {}",endp); | |
521 _endPoints.remove(endp); | |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
944
diff
changeset
|
522 endp.getConnection().onClose(); |
865 | 523 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
524 |
950 | 525 SaneSelector getSelector() |
865 | 526 { |
527 return _selector; | |
528 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
529 |
865 | 530 void stop() throws Exception |
531 { | |
532 // Spin for a while waiting for selector to complete | |
533 // to avoid unneccessary closed channel exceptions | |
950 | 534 /* |
865 | 535 try |
536 { | |
537 for (int i=0;i<100 && _selecting!=null;i++) | |
538 { | |
950 | 539 _selector.wakeup(); |
865 | 540 Thread.sleep(10); |
541 } | |
542 } | |
543 catch(Exception e) | |
544 { | |
944
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
545 LOG.warn("",e); |
865 | 546 } |
950 | 547 */ |
865 | 548 // close endpoints and selector |
549 synchronized (this) | |
550 { | |
950 | 551 SaneSelector selector=_selector; |
865 | 552 for (SelectionKey key:selector.keys()) |
553 { | |
554 if (key==null) | |
555 continue; | |
556 Object att=key.attachment(); | |
557 if (att instanceof EndPoint) | |
558 { | |
559 EndPoint endpoint = (EndPoint)att; | |
560 try | |
561 { | |
562 endpoint.close(); | |
563 } | |
564 catch(IOException e) | |
565 { | |
566 LOG.trace("",e); | |
567 } | |
568 } | |
569 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
570 |
865 | 571 try |
572 { | |
573 selector=_selector; | |
574 if (selector != null) | |
575 selector.close(); | |
576 } | |
577 catch (IOException e) | |
578 { | |
579 LOG.trace("",e); | |
580 } | |
944
1d24b6e422fa
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
943
diff
changeset
|
581 _selector = null; |
865 | 582 } |
583 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
584 |
865 | 585 public String dump() |
586 { | |
587 return AggregateLifeCycle.dump(this); | |
588 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
589 |
865 | 590 public void dump(Appendable out, String indent) throws IOException |
591 { | |
592 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
|
593 AggregateLifeCycle.dump(out,indent,Collections.emptyList()); |
865 | 594 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
595 |
865 | 596 public String toString() |
597 { | |
950 | 598 SaneSelector selector=_selector; |
865 | 599 return String.format("%s keys=%d selected=%d", |
600 super.toString(), | |
601 selector != null && selector.isOpen() ? selector.keys().size() : -1, | |
602 selector != null && selector.isOpen() ? selector.selectedKeys().size() : -1); | |
603 } | |
604 } | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
605 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
606 } |