/openjdk7/jdk/test/java/nio/channels/Selector/ |
H A D | SelectWrite.java | 43 Selector sel = Selector.open(); 47 sc.register(sel, SelectionKey.OP_WRITE); 48 sel.select(); 49 sel.selectedKeys().clear(); 50 if (sel.select() == 0) { 54 sel.close();
|
H A D | WakeupAfterClose.java | 35 final Selector sel = Selector.open(); 40 sel.select(); 56 sel.close(); 57 sel.wakeup();
|
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 | 63 final Selector sel = Selector.open(); 64 sel.keys(); 65 sel.selectedKeys(); 66 sel.close(); 70 sel.keys(); 75 sel.selectedKeys(); 131 static SelectionKey reg(Selector sel) throws IOException { argument 134 return dc.register(sel, SelectionKey.OP_WRITE); 139 final Selector sel = Selector.open(); 143 testNoRemoval(sel [all...] |
H A D | SelectAfterRead.java | 45 Selector sel = Selector.open(); 50 sc.register(sel, SelectionKey.OP_READ); 53 if (sel.selectNow() != 0) 56 sel.close(); 66 sel = Selector.open(); 67 sc.register(sel, SelectionKey.OP_READ); 68 if (sel.select(TIMEOUT) != 1) 70 sel.selectedKeys().clear(); 72 if (sel.selectNow() != 1) 81 if (sel [all...] |
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 | OutOfBand.java | 40 Selector sel = null; 50 sel = Selector.open(); 52 sc.register(sel, SelectionKey.OP_READ); 57 test(s, false, 0, 0, sel); 58 test(s, false, 512, 0, sel); 59 test(s, false, 0, 512, sel); 60 test(s, false, 512, 512, sel); 66 test(s, true, 0, 0, sel); 67 test(s, true, 512, 0, sel); 68 test(s, true, 0, 512, sel); 79 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 | LotsOfUpdates.java | 29 Selector sel = Selector.open(); 32 SelectionKey key = sc.register(sel, 0); 36 sel.selectNow();
|
H A D | RacyDeregister.java | 69 final Selector sel = Selector.open(); 70 SelectionKey key2 = accepted2.register(sel, SelectionKey.OP_READ); 72 accepted.register(sel, SelectionKey.OP_READ)}; 84 sel.wakeup(); 99 sel.wakeup(); 108 sel.wakeup(); 113 sel.wakeup(); 118 // main thread will be doing registering/deregistering with the sel 120 sel.select(); 123 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 | Wakeup.java | 56 Selector sel; field in class:Wakeup.Sleeper 58 Sleeper(Selector sel) { argument 60 this.sel = sel; 69 sel.select(); 136 Selector sel = Selector.open(); 139 sel.wakeup(); 141 Sleeper sleeper = new Sleeper(sel); 151 sel.wakeup(); 157 sel [all...] |
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 | LotsOfChannels.java | 47 Selector sel = Selector.open(); 49 source.register(sel, SelectionKey.OP_READ); 55 sc.register(sel, SelectionKey.OP_READ); 58 sc2.register(sel, SelectionKey.OP_WRITE); 63 int x = sel.selectNow(); 64 sel.selectedKeys().clear(); 74 sel.close();
|
H A D | ReadAfterConnect.java | 41 Selector sel = Selector.open(); 45 sc.register(sel, SelectionKey.OP_READ); 47 if (sel.selectNow() != 0)
|
/openjdk7/jdk/src/solaris/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
|
/openjdk7/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...] |
/openjdk7/jdk/src/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);
|
/openjdk7/jdk/src/share/sample/nio/server/ |
H A D | DispatcherN.java | 56 private Selector sel; field in class:DispatcherN 59 sel = Selector.open(); 75 sel.select(); 76 for (Iterator i = sel.selectedKeys().iterator(); i.hasNext(); ) { 88 sel.wakeup(); 89 ch.register(sel, ops, h);
|
H A D | Dispatcher1.java | 56 private Selector sel; field in class:Dispatcher1 59 sel = Selector.open(); 74 sel.select(); 75 for (Iterator i = sel.selectedKeys().iterator(); i.hasNext(); ) { 85 ch.register(sel, ops, h);
|
/openjdk7/jdk/src/share/classes/java/nio/channels/ |
H A D | SelectableChannel.java | 149 public abstract SelectionKey keyFor(Selector sel); argument 151 // sync(keySet) { return findKey(sel); } 182 * @param sel 216 public abstract SelectionKey register(Selector sel, int ops, Object att) argument 235 * <blockquote><tt>sc.register(sel, ops)</tt></blockquote> 241 * register}(sel, ops, null)</tt></blockquote> 243 * @param sel 274 public final SelectionKey register(Selector sel, int ops) argument 277 return register(sel, ops, null);
|
/openjdk7/jdk/src/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);
|
/openjdk7/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();
|