Searched refs:sel (Results 1 - 25 of 84) sorted by relevance

1234

/openjdk7/jdk/test/java/nio/channels/Selector/
H A DSelectWrite.java43 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 DWakeupAfterClose.java35 final Selector sel = Selector.open();
40 sel.select();
56 sel.close();
57 sel.wakeup();
H A DCloseInvalidatesKeys.java38 Selector sel = Selector.open();
39 SelectionKey key = ch.register(sel, SelectionKey.OP_WRITE);
40 sel.close();
H A DWakeupEmpty.java38 final Selector sel = Selector.open();
46 sel.wakeup();
50 if (sel.select() != 0)
H A DKeySets.java63 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 DSelectAfterRead.java45 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 DWakeupNow.java42 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 DOutOfBand.java40 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 DCloseThenRegister.java35 Selector sel = Selector.open();
36 sel.close();
41 ssc.register(sel, SelectionKey.OP_ACCEPT);
H A DLotsOfUpdates.java29 Selector sel = Selector.open();
32 SelectionKey key = sc.register(sel, 0);
36 sel.selectNow();
H A DRacyDeregister.java69 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 DCloseWhenKeyIdle.java43 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 DWakeup.java56 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 DHelperSlowToDie.java45 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 DLotsOfChannels.java47 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 DReadAfterConnect.java41 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 DXMSelectionListener.java39 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 DTrivial.java35 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 DHangup.java54 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 DCertPathHelper.java57 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 DDispatcherN.java56 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 DDispatcher1.java56 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 DSelectableChannel.java149 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 DCertPathHelperImpl.java58 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 DSelectWhenRefused.java47 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();

Completed in 449 milliseconds

1234