/openjdk10/jdk/test/java/nio/channels/Selector/ |
H A D | CloseInvalidatesKeys.java | 38 Selector sel = Selector.open(); 39 SelectionKey key = ch.register(sel, SelectionKey.OP_WRITE); 40 sel.close();
|
H A D | WakeupEmpty.java | 38 final Selector sel = Selector.open(); 46 sel.wakeup(); 50 if (sel.select() != 0)
|
H A D | KeySets.java | 54 final Selector sel = Selector.open(); 55 sel.keys(); 56 sel.selectedKeys(); 57 sel.close(); 61 sel.keys(); 66 sel.selectedKeys(); 121 static SelectionKey reg(Selector sel) throws IOException { argument 124 return dc.register(sel, SelectionKey.OP_WRITE); 129 final Selector sel = Selector.open(); 133 testNoRemoval(sel [all...] |
H A D | SelectWrite.java | 42 try (Selector sel = Selector.open()) { 44 sc.register(sel, SelectionKey.OP_WRITE); 45 sel.select(); 46 sel.selectedKeys().clear(); 47 if (sel.select() == 0) {
|
H A D | WakeupNow.java | 42 Selector sel = Selector.open(); 45 p.source().register(sel, SelectionKey.OP_READ); 46 sel.wakeup(); 49 sel.selectNow(); 51 int n = sel.select(2000); 55 sel.close(); 64 Selector sel = Selector.open(); 67 sel.wakeup(); 70 sel.selectNow(); 72 int n = sel [all...] |
H A D | Wakeup.java | 62 Selector sel; field in class:Wakeup.Sleeper 64 Sleeper(Selector sel, boolean wantInterrupt, boolean interruptBeforeSelect) { argument 66 this.sel = sel; 79 sel.select(); 115 static Sleeper createSleeper(Selector sel, boolean wantInterrupt, argument 121 Sleeper sleeper = new Sleeper(sel, wantInterrupt, interruptBeforeSelect); 143 static Sleeper newSleeper(Selector sel) throws Exception { argument 144 return Sleeper.createSleeper(sel, false, false); 147 static Sleeper newSleeperWantInterrupt(Selector sel) throw argument 151 newSleeperWantInterruptBeforeSelect(Selector sel) argument [all...] |
H A D | OutOfBand.java | 43 Selector sel = null; 53 sel = Selector.open(); 55 sc.register(sel, SelectionKey.OP_READ); 60 test(s, false, 0, 0, sel); 61 test(s, false, 512, 0, sel); 62 test(s, false, 0, 512, sel); 63 test(s, false, 512, 512, sel); 69 test(s, true, 0, 0, sel); 70 test(s, true, 512, 0, sel); 71 test(s, true, 0, 512, sel); 82 test(Socket s, boolean urgentExpected, int bytesBefore, int bytesAfter, Selector sel) argument [all...] |
H A D | CloseThenRegister.java | 35 Selector sel = Selector.open(); 36 sel.close(); 41 ssc.register(sel, SelectionKey.OP_ACCEPT);
|
H A D | WakeupAfterClose.java | 36 final Selector sel = Selector.open(); 41 sel.select(); 60 sel.close(); 61 sel.wakeup();
|
H A D | SelectAfterRead.java | 49 try (Selector sel = Selector.open()) { 52 sc.register(sel, SelectionKey.OP_READ); 55 if (sel.selectNow() != 0) 68 try (Selector sel = Selector.open()) { 70 sc.register(sel, SelectionKey.OP_READ); 71 if (sel.select(TIMEOUT) != 1) 73 sel.selectedKeys().clear(); 75 if (sel.selectNow() != 1) 84 if (sel.selectNow() != 0)
|
H A D | RacyDeregister.java | 74 final Selector sel = Selector.open(); 75 SelectionKey key2 = accepted2.register(sel, SelectionKey.OP_READ); 77 accepted.register(sel, SelectionKey.OP_READ)}; 89 sel.wakeup(); 115 sel.wakeup(); 124 sel.wakeup(); 129 sel.wakeup(); 134 // main thread will be doing registering/deregistering with the sel 136 sel.select(); 139 sel [all...] |
H A D | CloseWhenKeyIdle.java | 43 private Selector sel; field in class:CloseWhenKeyIdle.Waker 46 Waker(Selector sel, long delay) { argument 47 this.sel = sel; 55 sel.wakeup(); 94 Selector sel = Selector.open(); 97 SelectionKey k = sc1.register(sel, 0); 98 sel.selectNow(); 107 Thread t = new Thread(new Waker(sel, 5000)); 116 int n = sel [all...] |
H A D | LotsOfChannels.java | 48 Selector sel = Selector.open(); 50 source.register(sel, SelectionKey.OP_READ); 56 sc.register(sel, SelectionKey.OP_READ); 59 sc2.register(sel, SelectionKey.OP_WRITE); 64 int x = sel.selectNow(); 65 sel.selectedKeys().clear(); 75 sel.close();
|
H A D | HelperSlowToDie.java | 45 Selector sel = Selector.open(); 52 sc.register(sel, SelectionKey.OP_CONNECT); 55 sel.selectNow(); 72 sc.register(sel, SelectionKey.OP_CONNECT); 73 sel.selectNow(); // cause helper to spin up 75 sel.selectNow(); // cause helper to retire 85 sel.close();
|
H A D | ReadAfterConnect.java | 41 try (Selector sel = Selector.open()) { 43 sc.register(sel, SelectionKey.OP_READ); 45 if (sel.selectNow() != 0)
|
H A D | LotsOfUpdates.java | 31 Selector sel = Selector.open(); 34 SelectionKey key = sc.register(sel, 0); 38 sel.selectNow();
|
H A D | ChangingInterests.java | 89 Selector sel = key.selector(); 90 assertTrue(sel.keys().size() == 1, "Only one channel should be registered"); 94 sel.selectNow(); 95 sel.selectedKeys().clear(); 100 int selected = sel.selectNow(); 107 for (SelectionKey k: sel.selectedKeys()) { 128 sel.selectedKeys().clear(); 135 static void testForSpin(Selector sel) throws IOException { argument 140 int selected = sel.select(1000); 166 try (Selector sel [all...] |
/openjdk10/jdk/src/java.desktop/unix/classes/sun/awt/X11/ |
H A D | XMSelectionListener.java | 39 public void ownerChanged(int screen, XMSelection sel, long newOwner, long data, long timestamp); argument 44 public void ownerDeath(int screen, XMSelection sel, long deadOwner); argument 53 public void selectionChanged(int screen, XMSelection sel, long owner, XPropertyEvent event); argument
|
/openjdk10/jdk/src/java.base/share/classes/sun/security/provider/certpath/ |
H A D | CertPathHelper.java | 57 protected abstract void implSetPathToNames(X509CertSelector sel, argument 60 protected abstract void implSetDateAndTime(X509CRLSelector sel, Date date, long skew); argument 62 static void setPathToNames(X509CertSelector sel, argument 64 instance.implSetPathToNames(sel, names); 67 public static void setDateAndTime(X509CRLSelector sel, Date date, long skew) { argument 68 instance.implSetDateAndTime(sel, date, skew);
|
/openjdk10/jdk/test/java/nio/channels/SocketChannel/ |
H A D | Trivial.java | 35 Selector sel = Selector.open(); 37 if (sc.keyFor(sel) != null) 40 SelectionKey sk = sc.register(sel, SelectionKey.OP_READ, args); 41 if (sc.keyFor(sel) != sk) 42 throw new Exception("keyFor returned " + sc.keyFor(sel)); 54 sel.close();
|
H A D | Hangup.java | 54 static void doSelect(Selector sel, SelectionKey sk, int count) argument 57 int n = sel.select(); 60 Set sks = sel.selectedKeys(); 82 Selector sel = null; 108 sel = Selector.open(); 110 SelectionKey sk = sv.register(sel, SelectionKey.OP_READ); 125 doSelect(sel, sk, ++ns); 139 doSelect(sel, sk, ++ns); 152 doSelect(sel, sk, ++ns); 153 doSelect(sel, s [all...] |
/openjdk10/jdk/src/java.base/share/classes/java/security/cert/ |
H A D | CertPathHelperImpl.java | 58 protected void implSetPathToNames(X509CertSelector sel, argument 60 sel.setPathToNamesInternal(names); 63 protected void implSetDateAndTime(X509CRLSelector sel, Date date, long skew) { argument 64 sel.setDateAndTime(date, skew);
|
/openjdk10/jdk/src/java.base/share/classes/java/nio/channels/ |
H A D | SelectableChannel.java | 145 * @param sel 152 public abstract SelectionKey keyFor(Selector sel); argument 154 // sync(keySet) { return findKey(sel); } 185 * @param sel 219 public abstract SelectionKey register(Selector sel, int ops, Object att) argument 238 * <blockquote>{@code sc.register(sel, ops)}</blockquote> 244 * register(sel, ops, null)}</blockquote> 246 * @param sel 277 public final SelectionKey register(Selector sel, int ops) argument 280 return register(sel, op [all...] |
/openjdk10/jdk/test/java/nio/channels/DatagramChannel/ |
H A D | SelectWhenRefused.java | 47 Selector sel = Selector.open(); 50 dc.register(sel, SelectionKey.OP_READ); 54 int n = sel.select(2000); 56 sel.selectedKeys().clear(); 67 n = sel.select(2000); 69 sel.selectedKeys().clear(); 83 n = sel.select(2000); 91 sel.close();
|
/openjdk10/jdk/test/java/net/ProxySelector/ |
H A D | B6563259.java | 38 ProxySelector sel = ProxySelector.getDefault(); 39 java.util.List<Proxy> l = sel.select(new URI("http://HOST1.sun.com/"));
|