/openjdk7/jdk/src/share/classes/java/nio/channels/ |
H A D | CompletionHandler.java | 45 public interface CompletionHandler<V,A> { interface
|
H A D | AsynchronousByteChannel.java | 108 CompletionHandler<Integer,? super A> handler); 116 * #read(ByteBuffer,Object,CompletionHandler) 117 * read(ByteBuffer,Object,CompletionHandler)} method except that instead 185 CompletionHandler<Integer,? super A> handler); 193 * #write(ByteBuffer,Object,CompletionHandler) 194 * write(ByteBuffer,Object,CompletionHandler)} method except that instead
|
H A D | AsynchronousSocketChannel.java | 96 * <p> The {@link #read(ByteBuffer,long,TimeUnit,Object,CompletionHandler) read} 97 * and {@link #write(ByteBuffer,long,TimeUnit,Object,CompletionHandler) write} 315 CompletionHandler<Void,? super A> handler); 322 * #connect(SocketAddress, Object, CompletionHandler)} method except that 365 * AsynchronousByteChannel#read(ByteBuffer,Object,CompletionHandler)} 392 CompletionHandler<Integer,? super A> handler); 405 CompletionHandler<Integer,? super A> handler) 500 CompletionHandler<Long,? super A> handler); 520 * AsynchronousByteChannel#write(ByteBuffer,Object,CompletionHandler)} 545 CompletionHandler<Intege [all...] |
H A D | AsynchronousFileChannel.java | 51 * write method that initiates asynchronous operations. A {@link CompletionHandler} 404 * {@link #lock(Object,CompletionHandler)} method simply locks a region 458 CompletionHandler<FileLock,? super A> handler); 472 * ch.{@link #lock(long,long,boolean,Object,CompletionHandler) lock}(0L, Long.MAX_VALUE, false, att, handler) 487 CompletionHandler<FileLock,? super A> handler) 497 * manner as the {@link #lock(long, long, boolean, Object, CompletionHandler)} 597 * @see #lock(Object,CompletionHandler) 598 * @see #lock(long,long,boolean,Object,CompletionHandler) 630 * @see #lock(Object,CompletionHandler) 631 * @see #lock(long,long,boolean,Object,CompletionHandler) [all...] |
H A D | AsynchronousServerSocketChannel.java | 42 * the {@link #accept(Object,CompletionHandler) accept} method 77 * listener.accept(null, new CompletionHandler<AsynchronousSocketChannel,Void>() { 279 CompletionHandler<AsynchronousSocketChannel,? super A> handler); 286 * the same manner as the {@link #accept(Object, CompletionHandler)} method
|
/openjdk7/jdk/src/share/sample/nio/chatserver/ |
H A D | ClientReader.java | 42 import java.nio.channels.CompletionHandler; 67 client.read(new CompletionHandler<Integer, ByteBuffer>() {
|
H A D | Client.java | 44 import java.nio.channels.CompletionHandler; 114 channel.write(buffer, buffer, new CompletionHandler<Integer, ByteBuffer>() { 154 public void read(CompletionHandler<Integer, ? super ByteBuffer> completionHandler) {
|
H A D | ChatServer.java | 86 // call accept to wait for connections, tell it to call our CompletionHandler when there 88 listener.accept(null, new CompletionHandler<AsynchronousSocketChannel, Void>() {
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | AsynchronousFileChannelImpl.java | 110 CompletionHandler<FileLock,? super A> handler); 126 CompletionHandler<FileLock,? super A> handler) 214 CompletionHandler<Integer,? super A> handler); 225 CompletionHandler<Integer,? super A> handler) 235 CompletionHandler<Integer,? super A> handler); 247 CompletionHandler<Integer,? super A> handler)
|
H A D | Invoker.java | 120 static <V,A> void invokeUnchecked(CompletionHandler<V,? super A> handler, 139 CompletionHandler<V,? super A> handler, 154 CompletionHandler<V,? super A> handler, 194 final CompletionHandler<V,? super A> handler, 217 static <V,A> void invokeIndirectly(final CompletionHandler<V,? super A> handler, argument 267 CompletionHandler<V,? super A> handler = future.handler(); 283 CompletionHandler<V,? super A> handler = future.handler(); 299 CompletionHandler<V,? super A> handler = future.handler(); 193 invokeIndirectly(AsynchronousChannel channel, final CompletionHandler<V,? super A> handler, final A attachment, final V result, final Throwable exc) argument
|
H A D | PendingFuture.java | 42 private final CompletionHandler<V,? super A> handler; 60 CompletionHandler<V,? super A> handler, 71 CompletionHandler<V,? super A> handler, 91 CompletionHandler<V,? super A> handler() {
|
H A D | AsynchronousSocketChannelImpl.java | 194 CompletionHandler<Void,? super A> handler); 204 CompletionHandler<Void,? super A> handler) 220 CompletionHandler<V,? super A> handler); 229 CompletionHandler<V,? super A> handler) 290 CompletionHandler<Integer,? super A> handler) 306 CompletionHandler<Long,? super A> handler) 329 CompletionHandler<V,? super A> handler); 338 CompletionHandler<V,? super A> handler) 394 CompletionHandler<Integer,? super A> handler) 408 CompletionHandler<Lon [all...] |
H A D | AsynchronousServerSocketChannelImpl.java | 119 CompletionHandler<AsynchronousSocketChannel,Object> handler); 130 CompletionHandler<AsynchronousSocketChannel,? super A> handler) 134 implAccept(attachment, (CompletionHandler<AsynchronousSocketChannel,Object>)handler);
|
H A D | SimpleAsynchronousFileChannelImpl.java | 178 final CompletionHandler<FileLock,? super A> handler) 292 final CompletionHandler<Integer,? super A> handler) 348 final CompletionHandler<Integer,? super A> handler) 174 implLock(final long position, final long size, final boolean shared, final A attachment, final CompletionHandler<FileLock,? super A> handler) argument 289 implRead(final ByteBuffer dst, final long position, final A attachment, final CompletionHandler<Integer,? super A> handler) argument 345 implWrite(final ByteBuffer src, final long position, final A attachment, final CompletionHandler<Integer,? super A> handler) argument
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousChannelGroup/ |
H A D | GroupOfOne.java | 49 listener.accept((Void)null, new CompletionHandler<AsynchronousSocketChannel,Void>() { 95 ch.connect(sa, (Void)null, new CompletionHandler<Void,Void>() { 101 ch.read(buf, (Void)null, new CompletionHandler<Integer,Void>() {
|
H A D | Unbounded.java | 48 listener.accept((Void)null, new CompletionHandler<AsynchronousSocketChannel,Void>() { 87 new CompletionHandler<Integer,AsynchronousSocketChannel>() {
|
H A D | Identity.java | 82 listener.accept((Void)null, new CompletionHandler<AsynchronousSocketChannel,Void>() { 86 ch.read(buf, ch, new CompletionHandler<Integer,AsynchronousSocketChannel>() { 131 channels[0].write(getBuffer(), 0, new CompletionHandler<Integer,Integer>() {
|
H A D | Restart.java | 97 listener.accept((Void)null, new CompletionHandler<AsynchronousSocketChannel,Void>() {
|
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | UnixAsynchronousSocketChannelImpl.java | 65 private CompletionHandler<Void,Object> connectHandler; 77 private CompletionHandler<Number,Object> readHandler; 87 private CompletionHandler<Number,Object> writeHandler; 271 CompletionHandler<Void,Object> handler = connectHandler; 289 CompletionHandler<Void,? super A> handler) 335 this.connectHandler = (CompletionHandler<Void,Object>)handler; 376 CompletionHandler<Number,Object> handler = readHandler; 439 CompletionHandler<Number,Object> handler = null; 477 CompletionHandler<V,? super A> handler) 524 this.readHandler = (CompletionHandler<Numbe [all...] |
H A D | UnixAsynchronousServerSocketChannelImpl.java | 63 private CompletionHandler<AsynchronousSocketChannel,Object> acceptHandler; 98 CompletionHandler<AsynchronousSocketChannel,Object> handler; 176 CompletionHandler<AsynchronousSocketChannel,Object> handler = acceptHandler; 249 CompletionHandler<AsynchronousSocketChannel,Object> handler)
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousFileChannel/ |
H A D | CustomThreadPool.java | 48 new CompletionHandler<Integer,AtomicReference<Thread>>() {
|
H A D | Basic.java | 75 * Writes buffer to file using a CompletionHandler to consume the result 77 * Reads file to EOF to a new buffer using a CompletionHandler to consume 198 ch.lock((Void)null, new CompletionHandler<FileLock,Void> () { 223 ch.read(buf, 0L, (Void)null, new CompletionHandler<Integer,Void>() { 315 ch.write(genBuffer(), 0L, (Void)null, new CompletionHandler<Integer,Void>() { 355 channels[i].write(genBuffer(), 0L, (Void)null, new CompletionHandler<Integer,Void>() { 556 ch.write(src, position, position, new CompletionHandler<Integer,Long>() { 581 ch.read(dst, position, position, new CompletionHandler<Integer,Long>() {
|
H A D | LotsOfWrites.java | 43 static class Writer implements CompletionHandler<Integer,ByteBuffer> {
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/ |
H A D | StressLoopback.java | 102 channel.write(sentBuffer, (Void)null, new CompletionHandler<Integer,Void> () { 143 channel.read(readBuffer, (Void)null, new CompletionHandler<Integer,Void> () {
|
H A D | Basic.java | 212 ch.connect(server.address(), (Void)null, new CompletionHandler<Void,Void>() { 315 ch.write(genBuffer(), ch, new CompletionHandler<Integer,AsynchronousSocketChannel>() { 419 ch.read(dst, (Void)null, new CompletionHandler<Integer,Void>() { 468 ch.read(dst, (Void)null, new CompletionHandler<Integer,Void>() { 525 new CompletionHandler<Long,Void>() { 552 new CompletionHandler<Long,Void>() { 586 ch.write(src, (Void)null, new CompletionHandler<Integer,Void>() { 641 new CompletionHandler<Long,Void>() { 661 new CompletionHandler<Long,Void>() { 752 ch.read(dst, timeout, unit, null, new CompletionHandler<Intege [all...] |