Searched refs:CompletionHandler (Results 1 - 25 of 30) sorted by relevance

12

/openjdk7/jdk/src/share/classes/java/nio/channels/
H A DCompletionHandler.java45 public interface CompletionHandler<V,A> { interface
H A DAsynchronousByteChannel.java108 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 DAsynchronousSocketChannel.java96 * <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 DAsynchronousFileChannel.java51 * 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 DAsynchronousServerSocketChannel.java42 * the {@link #accept(Object,CompletionHandler) accept} method
77 * listener.accept(null, new CompletionHandler&lt;AsynchronousSocketChannel,Void&gt;() {
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 DClientReader.java42 import java.nio.channels.CompletionHandler;
67 client.read(new CompletionHandler<Integer, ByteBuffer>() {
H A DClient.java44 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 DChatServer.java86 // 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 DAsynchronousFileChannelImpl.java110 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 DInvoker.java120 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 DPendingFuture.java42 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 DAsynchronousSocketChannelImpl.java194 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 DAsynchronousServerSocketChannelImpl.java119 CompletionHandler<AsynchronousSocketChannel,Object> handler);
130 CompletionHandler<AsynchronousSocketChannel,? super A> handler)
134 implAccept(attachment, (CompletionHandler<AsynchronousSocketChannel,Object>)handler);
H A DSimpleAsynchronousFileChannelImpl.java178 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 DGroupOfOne.java49 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 DUnbounded.java48 listener.accept((Void)null, new CompletionHandler<AsynchronousSocketChannel,Void>() {
87 new CompletionHandler<Integer,AsynchronousSocketChannel>() {
H A DIdentity.java82 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 DRestart.java97 listener.accept((Void)null, new CompletionHandler<AsynchronousSocketChannel,Void>() {
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/
H A DUnixAsynchronousSocketChannelImpl.java65 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 DUnixAsynchronousServerSocketChannelImpl.java63 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 DCustomThreadPool.java48 new CompletionHandler<Integer,AtomicReference<Thread>>() {
H A DBasic.java75 * 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 DLotsOfWrites.java43 static class Writer implements CompletionHandler<Integer,ByteBuffer> {
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/
H A DStressLoopback.java102 channel.write(sentBuffer, (Void)null, new CompletionHandler<Integer,Void> () {
143 channel.read(readBuffer, (Void)null, new CompletionHandler<Integer,Void> () {
H A DBasic.java212 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...]

Completed in 68 milliseconds

12