Lines Matching refs:result
180 * consume the result when the connection is established (or fails).
184 private final PendingFuture<Void,A> result;
186 ConnectTask(InetSocketAddress remote, PendingFuture<Void,A> result) {
188 this.result = result;
227 // synchronize on result to allow this thread handle the case
229 synchronized (result) {
230 overlapped = ioCache.add(result);
241 result.setResult(null);
253 result.setFailure(toIOException(exc));
255 Invoker.invoke(result);
267 result.setResult(null);
278 result.setFailure(toIOException(exc));
282 Invoker.invokeUnchecked(result);
284 Invoker.invoke(result);
295 result.setFailure(x);
297 result.setFailure(new AsynchronousCloseException());
299 Invoker.invoke(result);
354 PendingFuture<Void,A> result =
356 ConnectTask task = new ConnectTask<A>(isa, result);
357 result.setContext(task);
365 return result;
370 * result when the read completes.
376 private final PendingFuture<V,A> result;
383 PendingFuture<V,A> result)
388 this.result = result;
487 overlapped = ioCache.add(result);
500 result.setResult((V)Long.valueOf(-1L));
502 result.setResult((V)Integer.valueOf(-1));
515 result.setFailure(x);
528 Invoker.invoke(result);
547 synchronized (result) {
548 if (result.isDone())
552 result.setResult((V)Long.valueOf(bytesTransferred));
554 result.setResult((V)Integer.valueOf(bytesTransferred));
558 Invoker.invokeUnchecked(result);
560 Invoker.invoke(result);
573 synchronized (result) {
574 if (result.isDone())
577 result.setFailure(x);
579 Invoker.invoke(result);
586 // synchronize on result as the I/O could complete/fail
587 synchronized (result) {
588 if (result.isDone())
593 result.setFailure(new InterruptedByTimeoutException());
597 Invoker.invoke(result);
611 PendingFuture<V,A> result =
620 final ReadTask readTask = new ReadTask<V,A>(bufs, isScatteringRead, result);
621 result.setContext(readTask);
630 result.setTimeoutTask(timeoutTask);
639 return result;
644 * result when the write completes.
650 private final PendingFuture<V,A> result;
657 PendingFuture<V,A> result)
662 this.result = result;
755 overlapped = ioCache.add(result);
776 result.setFailure(x);
789 Invoker.invoke(result);
804 synchronized (result) {
805 if (result.isDone())
809 result.setResult((V)Long.valueOf(bytesTransferred));
811 result.setResult((V)Integer.valueOf(bytesTransferred));
815 Invoker.invokeUnchecked(result);
817 Invoker.invoke(result);
830 synchronized (result) {
831 if (result.isDone())
834 result.setFailure(x);
836 Invoker.invoke(result);
843 // synchronize on result as the I/O could complete/fail
844 synchronized (result) {
845 if (result.isDone())
850 result.setFailure(new InterruptedByTimeoutException());
854 Invoker.invoke(result);
868 PendingFuture<V,A> result =
877 final WriteTask writeTask = new WriteTask<V,A>(bufs, gatheringWrite, result);
878 result.setContext(writeTask);
887 result.setTimeoutTask(timeoutTask);
897 return result;