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 } |