Searched refs:SelectionKey (Results 1 – 13 of 13) sorted by relevance
233 …private Map<NioEndpoint,SelectionKey> endpointKeys = new ConcurrentHashMap<NioEndpoint,SelectionKe…255 serverChannel.register(selector, SelectionKey.OP_ACCEPT); in connect()293 for( Map.Entry<NioEndpoint,SelectionKey> e : endpointKeys.entrySet() ) { in setupSelectorOptions()295 e.getValue().interestOps(SelectionKey.OP_WRITE); in setupSelectorOptions()300 protected void accept( SelectionKey key ) throws IOException in accept()316 SelectionKey endKey = remoteChan.register( selector, SelectionKey.OP_READ ); in accept()326 SelectionKey key = endpointKeys.remove(p); in cancel()344 protected void cancel( SelectionKey key, SocketChannel c ) throws IOException in cancel()357 protected void read( SelectionKey key ) throws IOException in read()383 protected void write( SelectionKey key ) throws IOException in write()[all …]
25 import java.nio.channels.SelectionKey;50 private SelectionKey _key;96 …public SelectChannelEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey key, int max… in SelectChannelEndPoint()112 public SelectionKey getSelectionKey() in getSelectionKey()184 … ((_key.readyOps() & SelectionKey.OP_WRITE) == SelectionKey.OP_WRITE && (_key.interestOps() & Sele… in schedule()187 _interestOps = _key.interestOps() & ~SelectionKey.OP_WRITE; in schedule()589 ((!_socket.isInputShutdown() && read_interest ) ? SelectionKey.OP_READ : 0) in updateKey()590 | ((!_socket.isOutputShutdown()&& write_interest) ? SelectionKey.OP_WRITE : 0); in updateKey()784 SelectionKey key = _key; in close()815 SelectionKey key = _key; in toString()
26 import java.nio.channels.SelectionKey;363 …wEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey sKey) throws IO… in newEndPoint()459 SelectionKey key=null; in doSelect()480 key = channel.register(selector,SelectionKey.OP_READ,att); in doSelect()487 key = channel.register(selector,SelectionKey.OP_CONNECT,att); in doSelect()495 key = channel.register(selector,SelectionKey.OP_READ,null); in doSelect()600 for (SelectionKey key: selector.selectedKeys()) in doSelect()638 key.interestOps(SelectionKey.OP_READ); in doSelect()761 for (SelectionKey k: selector.keys()) in renewSelector()840 …private SelectChannelEndPoint createEndPoint(SocketChannel channel, SelectionKey sKey) throws IOEx… in createEndPoint()[all …]
23 import java.nio.channels.SelectionKey;38 …lEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey key, int maxIdl… in NetworkTrafficSelectChannelEndPoint()
185 int SelectionKey; member187 int SelectionKey) in COFFSectionKey()189 SelectionKey(SelectionKey) {} in COFFSectionKey()195 return SelectionKey < Other.SelectionKey;
22 import java.nio.channels.SelectionKey;59 …wEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey key) throws IOE… in newEndPoint()
24 import java.nio.channels.SelectionKey;269 …annelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey key) throws IOE… in newEndPoint()329 …annelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey sKey) throws IO… in newEndPoint()
25 import java.nio.channels.SelectionKey;
23 import java.nio.channels.SelectionKey;80 public static void close(SelectionKey key) { in close()
23 import java.nio.channels.SelectionKey;140 …annelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey key) throws IOE… in newEndPoint()
24 import java.nio.channels.SelectionKey;284 …ndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, final SelectionKey key) throws IOE… in newEndPoint()
26 import java.nio.channels.SelectionKey;479 …annelEndPoint newEndPoint(SocketChannel channel, SelectSet selectSet, SelectionKey key) throws IOE… in newEndPoint()
META-INF/ META-INF/MANIFEST.MF com/ com/android/ com/ ...