Lines Matching refs:result
214 * Task that initiates locking operation and handles completion result.
219 private final PendingFuture<FileLock,A> result;
223 PendingFuture<FileLock,A> result)
227 this.result = result;
237 overlapped = ioCache.add(result);
239 // synchronize on result to avoid race with handler thread
241 synchronized (result) {
249 result.setResult(fli);
257 result.setFailure(toIOException(x));
263 Invoker.invoke(result);
269 result.setResult(fli);
271 Invoker.invokeUnchecked(result);
273 Invoker.invoke(result);
284 result.setFailure(x);
286 result.setFailure(new AsynchronousCloseException());
288 Invoker.invoke(result);
315 PendingFuture<FileLock,A> result =
317 LockTask lockTask = new LockTask<A>(position, fli, result);
318 result.setContext(lockTask);
335 return result;
377 * Task that initiates read operation and handles completion result.
383 private final PendingFuture<Integer,A> result;
392 PendingFuture<Integer,A> result)
398 this.result = result;
447 overlapped = ioCache.add(result);
456 result.setResult(n);
458 throw new InternalError("Unexpected result: " + n);
463 result.setFailure(toIOException(x));
475 Invoker.invoke(result);
489 result.setResult(bytesTransferred);
491 Invoker.invokeUnchecked(result);
493 Invoker.invoke(result);
508 result.setFailure(x);
510 result.setFailure(new AsynchronousCloseException());
512 Invoker.invoke(result);
553 PendingFuture<Integer,A> result =
555 ReadTask readTask = new ReadTask<A>(dst, pos, rem, position, result);
556 result.setContext(readTask);
564 return result;
568 * Task that initiates write operation and handles completion result.
574 private final PendingFuture<Integer,A> result;
583 PendingFuture<Integer,A> result)
589 this.result = result;
632 overlapped = ioCache.add(result);
640 throw new InternalError("Unexpected result: " + n);
645 result.setFailure(toIOException(x));
657 Invoker.invoke(result);
671 result.setResult(bytesTransferred);
673 Invoker.invokeUnchecked(result);
675 Invoker.invoke(result);
686 result.setFailure(x);
688 result.setFailure(new AsynchronousCloseException());
690 Invoker.invoke(result);
727 PendingFuture<Integer,A> result =
729 WriteTask writeTask = new WriteTask<A>(src, pos, rem, position, result);
730 result.setContext(writeTask);
738 return result;