Searched refs:AsyncTimeout (Results 1 – 7 of 7) sorted by relevance
40 public class AsyncTimeout extends Timeout { class50 private static AsyncTimeout head;56 private AsyncTimeout next;73 AsyncTimeout node, long timeoutNanos, boolean hasDeadline) { in scheduleTimeout()76 head = new AsyncTimeout(); in scheduleTimeout()95 for (AsyncTimeout prev = head; true; prev = prev.next) { in scheduleTimeout()100 AsyncTimeout.class.notify(); // Wake up the watchdog when inserting at the front. in scheduleTimeout()115 private static synchronized boolean cancelScheduledTimeout(AsyncTimeout node) { in cancelScheduledTimeout()117 for (AsyncTimeout prev = head; prev != null; prev = prev.next) { in cancelScheduledTimeout()191 return AsyncTimeout.this; in sink()[all …]
114 AsyncTimeout timeout = timeout(socket);204 AsyncTimeout timeout = timeout(socket);209 private static AsyncTimeout timeout(final Socket socket) {210 return new AsyncTimeout() {
38 private final AsyncTimeout a = new RecordingAsyncTimeout();39 private final AsyncTimeout b = new RecordingAsyncTimeout();40 private final AsyncTimeout c = new RecordingAsyncTimeout();41 private final AsyncTimeout d = new RecordingAsyncTimeout();51 AsyncTimeout timeout = new RecordingAsyncTimeout(); in zeroTimeoutIsNoTimeout()192 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSinkTimesOut()213 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSourceTimesOut()234 AsyncTimeout timeout = new AsyncTimeout(); in wrappedThrowsWithTimeout()252 AsyncTimeout timeout = new AsyncTimeout(); in wrappedThrowsWithoutTimeout()268 class RecordingAsyncTimeout extends AsyncTimeout {
18 extension point in `AsyncTimeout` to customize the exception when a timeout99 * Make AsyncTimeout public.
25 import okio.AsyncTimeout;599 class StreamTimeout extends AsyncTimeout {
1073 public class AsyncTimeout extends Timeout.Task implements Runnable class in AsyncContinuation1095 private Timeout.Task _timeout= new AsyncTimeout();
29 import okio.AsyncTimeout;1377 AsyncTimeout watchdogJob = new AsyncTimeout() {