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

1234

/openjdk10/jdk/test/java/nio/channels/Selector/
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.java54 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 DSelectWrite.java42 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 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 DWakeup.java62 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 DOutOfBand.java43 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 DCloseThenRegister.java35 Selector sel = Selector.open();
36 sel.close();
41 ssc.register(sel, SelectionKey.OP_ACCEPT);
H A DWakeupAfterClose.java36 final Selector sel = Selector.open();
41 sel.select();
60 sel.close();
61 sel.wakeup();
H A DSelectAfterRead.java49 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 DRacyDeregister.java74 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 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 DLotsOfChannels.java48 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 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 DReadAfterConnect.java41 try (Selector sel = Selector.open()) {
43 sc.register(sel, SelectionKey.OP_READ);
45 if (sel.selectNow() != 0)
H A DLotsOfUpdates.java31 Selector sel = Selector.open();
34 SelectionKey key = sc.register(sel, 0);
38 sel.selectNow();
H A DChangingInterests.java89 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 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
/openjdk10/jdk/src/java.base/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);
/openjdk10/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...]
/openjdk10/jdk/src/java.base/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);
/openjdk10/jdk/src/java.base/share/classes/java/nio/channels/
H A DSelectableChannel.java145 * @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 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();
/openjdk10/jdk/test/java/net/ProxySelector/
H A DB6563259.java38 ProxySelector sel = ProxySelector.getDefault();
39 java.util.List<Proxy> l = sel.select(new URI("http://HOST1.sun.com/"));

Completed in 121 milliseconds

1234