| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/async/ |
| D | TAsyncClientManager.java | 67 private final Selector selector; field in TAsyncClientManager.SelectThread
73 this.selector = SelectorProvider.provider().openSelector(); in SelectThread()
82 return selector; in getSelector()
87 selector.wakeup(); in finish()
96 selector.select(); in run()
104 selector.select(selectTime); in run()
107 selector.selectNow(); in run()
122 selector.close(); in run()
131 Iterator<SelectionKey> keys = selector.selectedKeys().iterator(); in transitionMethods()
182 methodCall.start(selector); in startPendingMethods()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/ |
| D | TNonblockingServer.java | 124 serverTransport.registerSelector(selector); in SelectAcceptThread()
146 for (SelectionKey selectionKey : selector.keys()) { in run()
153 selector.close(); in run()
170 selector.select(); in select()
173 Iterator<SelectionKey> selectedKeys = selector.selectedKeys().iterator(); in select()
220 clientKey = client.registerSelector(selector, SelectionKey.OP_READ); in handleAccept()
|
| D | TThreadedSelectorServer.java | 512 selector.wakeup(); in addAcceptedConnection()
527 for (SelectionKey selectionKey : selector.keys()) { in run()
534 selector.close(); in run()
555 Iterator<SelectionKey> selectedKeys = selector.selectedKeys().iterator(); in select()
587 int selectedNums = selector.select(); in doSelect()
603 selector.selectNow(); in doSelect()
613 final Selector oldSelector = selector; in rebuildSelector()
641 selector = newSelector; in rebuildSelector()
674 clientKey = accepted.registerSelector(selector, SelectionKey.OP_READ); in registerAccepted()
|
| D | AbstractNonblockingServer.java | 141 protected Selector selector; field in AbstractNonblockingServer.AbstractSelectThread
147 this.selector = SelectorProvider.provider().openSelector(); in AbstractSelectThread()
152 selector.wakeup(); in wakeupSelector()
165 selector.wakeup(); in requestSelectInterestChange()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/ |
| D | TNonblockingMultiFetchClient.java | 181 private Selector selector; field in TNonblockingMultiFetchClient.MultiFetch
207 selector = Selector.open(); in run()
228 key = s.register(selector, s.validOps()); in run()
258 selector.select(); in run()
264 Iterator<SelectionKey> it = selector.selectedKeys().iterator(); in run()
362 if (selector.isOpen()) { in close()
363 for (SelectionKey selKey : selector.keys()) { in close()
367 selector.close(); in close()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
| D | TNonblockingServerTransport.java | 27 public abstract void registerSelector(Selector selector); in registerSelector() argument
|
| D | TNonblockingTransport.java | 48 public abstract SelectionKey registerSelector(Selector selector, int interests) in registerSelector() argument
|
| D | TNonblockingServerSocket.java | 144 public void registerSelector(Selector selector) { in registerSelector() argument
148 serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); in registerSelector()
|
| D | TNonblockingSocket.java | 102 public SelectionKey registerSelector(Selector selector, int interests) throws IOException { in registerSelector() argument
103 return socketChannel_.register(selector, interests); in registerSelector()
|
| /thrift-3.4.0/compiler/cpp/tests/catch/ |
| D | catch.hpp | 3323 performOptionalSelector( obj, @selector(setUp) ); in invoke()
3325 performOptionalSelector( obj, @selector(tearDown) ); in invoke()
3364 SEL selector = method_getName(methods[m]); in registerTestMethods() local
3365 std::string methodName = sel_getName(selector); in registerTestMethods()
3372 …getMutableRegistryHub().registerTest( makeTestCase( new OcMethod( cls, selector ), className, name… in registerTestMethods()
|
| /thrift-3.4.0/ |
| D | CHANGES.md | 3457 …king and HsHa server should make sure to close all their socket connections when the selector exits
|
