/libcore/ojluni/src/main/java/java/nio/channels/ |
H A D | SelectableChannel.java | 37 * first be <i>registered</i> via the {@link #register(Selector,int,Object) 38 * register} method. This method returns a new {@link SelectionKey} object 216 public abstract SelectionKey register(Selector sel, int ops, Object att) method in class:SelectableChannel 235 * <blockquote><tt>sc.register(sel, ops)</tt></blockquote> 240 * #register(java.nio.channels.Selector,int,java.lang.Object) 241 * register}(sel, ops, null)</tt></blockquote> 274 public final SelectionKey register(Selector sel, int ops) method in class:SelectableChannel 277 return register(sel, ops, null); 293 * of the {@link #register(Selector, int) register} metho [all...] |
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/spi/ |
H A D | AbstractSelectableChannelTest.java | 105 * @tests AbstractSelectableChannel#register(Selector, int, Object) 114 SelectionKey acceptKey = sc.register(acceptSelector1, 120 //test that sc.register invokes Selector.register() 121 acceptKey = sc.register(acceptSelector2, SelectionKey.OP_READ, null); 129 channel.register(selector, 0); 135 * @tests AbstractSelectableChannel#register(Selector, int, Object) 147 msc.register(acceptSelector, SelectionKey.OP_READ, null); 153 msc.register(null, 0, null); 161 msc.register(acceptSelecto [all...] |
H A D | AbstractSelectorTest.java | 30 * Tests for AbstractSelector and register of its default implementation 112 * @tests AbstractSelector#register(Selector,int) 120 SelectionKey acceptKey = ssc.register(acceptSelector, 128 * @tests AbstractSelector#register(Selector,int) 138 ssc.register(acceptSelector, SelectionKey.OP_ACCEPT); 148 ssc.register(acceptSelector, SelectionKey.OP_ACCEPT); 155 SelectionKey acceptKey = ssc.register(acceptSelector,
|
H A D | MockAbstractSelector.java | 48 protected SelectionKey register(AbstractSelectableChannel arg0, int arg1, method in class:MockAbstractSelector
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
H A D | UnixSelectorTest.java | 65 SelectionKey mkey0 = server.serverChannel.register(sel0, SelectionKey.OP_ACCEPT); 66 server.serverChannel.register(sel1, SelectionKey.OP_ACCEPT); 79 socketChannel.register(sel2, SelectionKey.OP_WRITE); 96 SelectionKey mkey3 = socketChannel2.register(sel3, SelectionKey.OP_WRITE); 105 SelectionKey mkey4 = socketChannel2.register(sel4, SelectionKey.OP_CONNECT); 111 SelectionKey mkey5 = socketChannel2.register(sel5, SelectionKey.OP_CONNECT | SelectionKey.OP_WRITE);
|
H A D | SelectableChannelTest.java | 33 * @tests SelectableChannel#register(Selector, int) 37 // Verify that calling register(Selector, int) leads to the method 38 // register(Selector, int, Object) being called with a null value 40 msc.register(Selector.open(), SelectionKey.OP_ACCEPT); 73 public SelectionKey register(Selector sel, int ops, Object att) method in class:SelectableChannelTest.MockSelectableChannel
|
H A D | SelectorTest.java | 105 SelectionKey key = ssc.register(selector, SelectionKey.OP_ACCEPT); 118 SelectionKey key3 = sc.register(selector, SelectionKey.OP_READ); 152 ssc.register(selector, SelectionKey.OP_ACCEPT); 333 SelectionKey key1 = ssc.register(selector, SelectionKey.OP_ACCEPT); 339 SelectionKey key2 = sc.register(selector, SelectionKey.OP_READ); 363 final SelectionKey key = pipe.source().register(selector, SelectionKey.OP_READ); 396 sc.register(selector, SelectionKey.OP_CONNECT); 414 SelectionKey key1 = sc.register(selector, SelectionKey.OP_WRITE); 445 channel.register(selector, SelectionKey.OP_CONNECT); 472 ssc.register(selecto [all...] |
H A D | SelectionKeyTest.java | 47 selectionKey = sc.register(selector, SelectionKey.OP_CONNECT);
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | PhaserTest.java | 52 assertEquals(expectedPhase, phaser.register()); 135 * register() will increment the number of unarrived parties by 141 assertEquals(0, phaser.register()); 155 assertEquals(0, phaser.register()); 159 phaser.register(); 173 * register() correctly returns the current barrier phase number 178 assertEquals(0, phaser.register()); 180 assertEquals(1, phaser.register()); 185 * register causes the next arrive to not increment the phase 191 assertEquals(1, phaser.register()); [all...] |
/libcore/luni/src/test/java/libcore/java/nio/channels/ |
H A D | SelectorTest.java | 46 SelectionKey key = sc.register(selector, SelectionKey.OP_CONNECT); 64 SelectionKey key = sc.register(selector, SelectionKey.OP_CONNECT); 149 SelectionKey key = sc.register(selector, 185 sc.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE);
|
H A D | SocketChannelTest.java | 70 SelectionKey selectionKey = sc.register(selector, SelectionKey.OP_CONNECT);
|
/libcore/ojluni/src/main/java/java/nio/channels/spi/ |
H A D | AbstractSelector.java | 59 * declares the abstract {@link #register register} method that is invoked by a 60 * selectable channel's {@link AbstractSelectableChannel#register register} 157 * AbstractSelectableChannel#register register} method in order to perform 172 protected abstract SelectionKey register(AbstractSelectableChannel ch, method in class:AbstractSelector
|
H A D | AbstractSelectableChannel.java | 173 * selector, so the {@link AbstractSelector#register register} method of 188 public final SelectionKey register(Selector sel, int ops, method in class:AbstractSelectableChannel 209 k = ((AbstractSelector)sel).register(this, ops, att);
|
/libcore/ojluni/src/main/java/sun/nio/ch/ |
H A D | DevPollArrayWrapper.java | 139 register(wfd, fd0, POLLIN); 207 register(wfd, fd, POLLREMOVE); 313 private native void register(int wfd, int fd, int mask); method in class:DevPollArrayWrapper
|
H A D | SelectorImpl.java | 124 protected final SelectionKey register(AbstractSelectableChannel ch, method in class:SelectorImpl
|
H A D | ServerSocketAdaptor.java | 115 sk = ssc.register(sel, SelectionKey.OP_ACCEPT);
|
H A D | SocketAdaptor.java | 117 sk = sc.register(sel, SelectionKey.OP_CONNECT); 232 sk = sc.register(sel, SelectionKey.OP_READ);
|
H A D | DatagramSocketAdaptor.java | 189 sk = dc.register(sel, SelectionKey.OP_READ);
|
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | ArrayBlockingQueue.java | 770 register(initial); 837 void register(Itr itr) { method in class:ArrayBlockingQueue.Itrs 1000 itrs.register(this); // in this order
|
H A D | Phaser.java | 21 * methods {@link #register}, {@link #bulkRegister}, or forms of 80 * Similarly, attempts to register upon termination have no effect. 103 * constructor, {@link #register}, or {@link #bulkRegister}), the 126 * register, then start the actions, then deregister, as in: 130 * final Phaser phaser = new Phaser(1); // "1" to register self 133 * phaser.register(); 156 * phaser.register(); 158 * phaser.register(); 172 * may re-register and then execute a similar loop: 175 * phaser.register(); 558 public int register() { method in class:Phaser [all...] |
/libcore/ojluni/src/main/java/java/io/ |
H A D | ObjectInputStream.java | 559 * register the object with the stream so that when all of the objects are 568 * so it is invalid to register a callback. 577 vlist.register(obj, prio); 2223 void register(ObjectInputValidation obj, int priority) method in class:ObjectInputStream.ValidationList
|