Searched refs:SelectChannelEndPoint (Results 1 – 12 of 12) sorted by relevance
340 protected abstract void endPointClosed(SelectChannelEndPoint endpoint); in endPointClosed()346 protected abstract void endPointOpened(SelectChannelEndPoint endpoint); in endPointOpened()363 …protected abstract SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectorManager.Select… in newEndPoint()404 …private ConcurrentMap<SelectChannelEndPoint,Object> _endPoints = new ConcurrentHashMap<SelectChann…466 SelectChannelEndPoint endpoint = (SelectChannelEndPoint)change; in doSelect()481 … SelectChannelEndPoint endpoint = createEndPoint((SocketChannel)channel,key); in doSelect()496 SelectChannelEndPoint endpoint = createEndPoint(channel,key); in doSelect()609 … SelectChannelEndPoint endpoint = (SelectChannelEndPoint)key.attachment(); in doSelect()616 if (att instanceof SelectChannelEndPoint) in doSelect()619 ((SelectChannelEndPoint)att).schedule(); in doSelect()[all …]
32 public class NetworkTrafficSelectChannelEndPoint extends SelectChannelEndPoint
43 public class SelectChannelEndPoint extends ChannelEndPoint implements AsyncEndPoint, ConnectedEndPo… class96 …public SelectChannelEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey key, int max… in SelectChannelEndPoint() method in SelectChannelEndPoint
34 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;269 …protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionK… in newEndPoint()271 …SelectChannelEndPoint endp= new SelectChannelEndPoint(channel,selectSet,key, SelectChannelConnecto… in newEndPoint()277 protected void endPointClosed(SelectChannelEndPoint endpoint) in endPointClosed()304 protected void endPointClosed(final SelectChannelEndPoint endpoint) in endPointClosed()310 protected void endPointOpened(SelectChannelEndPoint endpoint) in endPointOpened()329 …protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionK… in newEndPoint()
30 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;59 …protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectorManager.SelectSet selec… in newEndPoint()68 protected void endPointClosed(SelectChannelEndPoint endpoint) in endPointClosed()
35 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;119 protected void endPointOpened(SelectChannelEndPoint endpoint) in endPointOpened()124 protected void endPointClosed(SelectChannelEndPoint endpoint) in endPointClosed()140 …protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionK… in newEndPoint()152 …SelectChannelEndPoint scep = new SelectChannelEndPoint(channel, selectSet, key, (int)_httpClient.g… in newEndPoint()
29 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;185 if (_endp instanceof SelectChannelEndPoint) in handle()186 ((SelectChannelEndPoint)_endp).getChannel().close(); in handle()
46 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;284 …protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, final Sele… in newEndPoint()290 … SelectChannelEndPoint result = new SelectChannelEndPoint(channel, selectSet, key, maxIdleTime); in newEndPoint()316 protected void endPointOpened(SelectChannelEndPoint endpoint) in endPointOpened()328 protected void endPointClosed(SelectChannelEndPoint endpoint) in endPointClosed()
46 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;479 …protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionK… in newEndPoint()481 …SelectChannelEndPoint endp = new SelectChannelEndPoint(channel, selectSet, key, channel.socket().g… in newEndPoint()497 protected void endPointOpened(SelectChannelEndPoint endpoint) in endPointOpened()510 protected void endPointClosed(SelectChannelEndPoint endpoint) in endPointClosed()
META-INF/ META-INF/MANIFEST.MF org/ org/mortbay/ org/ ...
META-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF ...
1310 + 335836 Race when updating SelectChannelEndPoint._dispatched1413 + 321730 SelectChannelEndPoint prints to System.err