Lines Matching defs:selector
44 private Selector selector;
59 selector = Selector.open();
69 selector.close();
80 assertNotNull(selector);
87 assertTrue(selector.isOpen());
88 selector.close();
89 assertFalse(selector.isOpen());
97 assertNotNull(selector.provider());
98 assertSame(SelectorProvider.provider(), selector.provider());
105 SelectionKey key = ssc.register(selector, SelectionKey.OP_ACCEPT);
107 Set<SelectionKey> keySet = selector.keys();
108 Set<SelectionKey> keySet2 = selector.keys();
118 SelectionKey key3 = sc.register(selector, SelectionKey.OP_READ);
138 selector.close();
140 selector.keys();
152 ssc.register(selector, SelectionKey.OP_ACCEPT);
158 Set<SelectionKey> selectedKeys = selector.selectedKeys();
159 Set<SelectionKey> selectedKeys2 = selector.selectedKeys();
163 assertEquals(ssc.keyFor(selector), selectedKeys.iterator().next());
166 selectedKeys.add(ssc.keyFor(selector));
175 Set<SelectionKey> selectedKeys3 = selector.selectedKeys();
178 ssc.keyFor(selector).cancel();
180 selector.close();
182 selector.selectedKeys();
211 selector.selectNow();
251 selector = Selector.open();
260 selector.select(-1);
268 selector.select(WAIT_TIME);
274 // time if keys.size() == 0 (initial state of selector).
279 selector.select(SELECT_TIMEOUT_MS);
294 selector.wakeup();
296 selector.wakeup();
309 selector.wakeup();
324 selector.wakeup();
331 Set<SelectionKey> keys = selector.keys();
333 SelectionKey key1 = ssc.register(selector, SelectionKey.OP_ACCEPT);
339 SelectionKey key2 = sc.register(selector, SelectionKey.OP_READ);
347 selector.selectNow();
363 final SelectionKey key = pipe.source().register(selector, SelectionKey.OP_READ);
384 assertEquals(0, selector.select(5000)); // blocks
385 assertEquals(0, selector.selectedKeys().size());
396 sc.register(selector, SelectionKey.OP_CONNECT);
401 Set<SelectionKey> selectedKeys = selector.selectedKeys();
404 assertEquals(sc.keyFor(selector), key);
410 assertSame(selectedKeys, selector.selectedKeys());
413 // same selector, but op is changed
414 SelectionKey key1 = sc.register(selector, SelectionKey.OP_WRITE);
418 selectedKeys = selector.selectedKeys();
444 Selector selector = Selector.open();
445 channel.register(selector, SelectionKey.OP_CONNECT);
448 selector.select();
449 assertEquals(0, selector.selectedKeys().size());
457 // selector is closed
458 selector.close();
472 ssc.register(selector, SelectionKey.OP_ACCEPT);
476 Set<SelectionKey> selectedKeys = selector.selectedKeys();
479 assertEquals(ssc.keyFor(selector), key);
485 assertSame(selectedKeys, selector.selectedKeys());
498 ssc.keyFor(selector).cancel();
505 sc.register(selector, SelectionKey.OP_CONNECT);
510 Set<SelectionKey> selectedKeys = selector.selectedKeys();
513 assertEquals(sc.keyFor(selector), key);
519 assertSame(selectedKeys, selector.selectedKeys());
548 sc.register(selector, SelectionKey.OP_READ);
554 sc2.register(selector, SelectionKey.OP_READ);
560 Set<SelectionKey> selectedKeys = selector.selectedKeys();
563 assertEquals(sc.keyFor(selector), key);
569 assertSame(selectedKeys, selector.selectedKeys());
579 selectedKeys = selector.selectedKeys();
619 sc.register(selector, SelectionKey.OP_WRITE);
622 Set<SelectionKey> selectedKeys = selector.selectedKeys();
625 assertEquals(sc.keyFor(selector), key);
631 assertSame(selectedKeys, selector.selectedKeys());
664 ret = selector.select();
667 ret = selector.select(timeout);
670 ret = selector.selectNow();