package okio; import io.netty.handler.codec.rtsp.RtspHeaders; import java.io.IOException; import java.io.InterruptedIOException; import java.util.concurrent.TimeUnit; import kotlin.Metadata; import kotlin.jvm.internal.DefaultConstructorMarker; import kotlin.jvm.internal.o; /* JADX INFO: renamed from: z.a, reason: from Kotlin metadata */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000@\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0016\u0018\u0000 \u001b2\u00020\u0001:\u0002\u001b\u001cB\u0005¢\u0006\u0002\u0010\u0002J\u0012\u0010\b\u001a\u00020\t2\b\u0010\n\u001a\u0004\u0018\u00010\tH\u0001J\u0006\u0010\u000b\u001a\u00020\fJ\u0006\u0010\r\u001a\u00020\u0004J\u0012\u0010\u000e\u001a\u00020\t2\b\u0010\n\u001a\u0004\u0018\u00010\tH\u0014J\u0010\u0010\u000f\u001a\u00020\u00072\u0006\u0010\u0010\u001a\u00020\u0007H\u0002J\u000e\u0010\u0011\u001a\u00020\u00122\u0006\u0010\u0011\u001a\u00020\u0012J\u000e\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0013\u001a\u00020\u0014J\b\u0010\u0015\u001a\u00020\fH\u0014J%\u0010\u0016\u001a\u0002H\u0017\"\u0004\b\u0000\u0010\u00172\f\u0010\u0018\u001a\b\u0012\u0004\u0012\u0002H\u00170\u0019H\u0086\bø\u0001\u0000¢\u0006\u0002\u0010\u001aR\u000e\u0010\u0003\u001a\u00020\u0004X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u0010\u0005\u001a\u0004\u0018\u00010\u0000X\u0082\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0006\u001a\u00020\u0007X\u0082\u000e¢\u0006\u0002\n\u0000\u0082\u0002\u0007\n\u0005\b\u009920\u0001¨\u0006\u001d"}, d2 = {"Lokio/AsyncTimeout;", "Lokio/Timeout;", "()V", "inQueue", "", "next", "timeoutAt", "", "access$newTimeoutException", "Ljava/io/IOException;", "cause", "enter", "", "exit", "newTimeoutException", "remainingNanos", "now", "sink", "Lokio/Sink;", "source", "Lokio/Source;", "timedOut", "withTimeout", "T", "block", "Lkotlin/Function0;", "(Lkotlin/jvm/functions/Function0;)Ljava/lang/Object;", "Companion", "Watchdog", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48) public class AsyncTimeout extends Timeout { /* JADX INFO: renamed from: e, reason: collision with root package name */ public static final a f10106e = new a(null); /* JADX INFO: renamed from: f, reason: collision with root package name */ public static final long f10107f; /* JADX INFO: renamed from: g, reason: collision with root package name */ public static final long f10108g; /* JADX INFO: renamed from: h, reason: collision with root package name */ public static AsyncTimeout f10109h; /* JADX INFO: renamed from: i, reason: collision with root package name */ public boolean f10110i; /* JADX INFO: renamed from: j, reason: collision with root package name */ public AsyncTimeout f10111j; /* JADX INFO: renamed from: k, reason: collision with root package name */ public long f10112k; /* JADX INFO: renamed from: z.a$a */ @Metadata(d1 = {"\u00002\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0003\b\u0086\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002J\u000f\u0010\n\u001a\u0004\u0018\u00010\tH\u0000¢\u0006\u0002\b\u000bJ\u0010\u0010\f\u001a\u00020\r2\u0006\u0010\u000e\u001a\u00020\tH\u0002J \u0010\u000f\u001a\u00020\u00102\u0006\u0010\u000e\u001a\u00020\t2\u0006\u0010\u0011\u001a\u00020\u00042\u0006\u0010\u0012\u001a\u00020\rH\u0002R\u000e\u0010\u0003\u001a\u00020\u0004X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0005\u001a\u00020\u0004X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0006\u001a\u00020\u0007X\u0082T¢\u0006\u0002\n\u0000R\u0010\u0010\b\u001a\u0004\u0018\u00010\tX\u0082\u000e¢\u0006\u0002\n\u0000¨\u0006\u0013"}, d2 = {"Lokio/AsyncTimeout$Companion;", "", "()V", "IDLE_TIMEOUT_MILLIS", "", "IDLE_TIMEOUT_NANOS", "TIMEOUT_WRITE_SIZE", "", "head", "Lokio/AsyncTimeout;", "awaitTimeout", "awaitTimeout$okio", "cancelScheduledTimeout", "", "node", "scheduleTimeout", "", "timeoutNanos", "hasDeadline", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48) public static final class a { public a(DefaultConstructorMarker defaultConstructorMarker) { } public final AsyncTimeout a() throws InterruptedException { AsyncTimeout asyncTimeout = AsyncTimeout.f10109h; o.c(asyncTimeout); AsyncTimeout asyncTimeout2 = asyncTimeout.f10111j; long jNanoTime = System.nanoTime(); if (asyncTimeout2 == null) { AsyncTimeout.class.wait(AsyncTimeout.f10107f); AsyncTimeout asyncTimeout3 = AsyncTimeout.f10109h; o.c(asyncTimeout3); if (asyncTimeout3.f10111j != null || System.nanoTime() - jNanoTime < AsyncTimeout.f10108g) { return null; } return AsyncTimeout.f10109h; } long j2 = asyncTimeout2.f10112k - jNanoTime; if (j2 > 0) { long j3 = j2 / 1000000; AsyncTimeout.class.wait(j3, (int) (j2 - (1000000 * j3))); return null; } AsyncTimeout asyncTimeout4 = AsyncTimeout.f10109h; o.c(asyncTimeout4); asyncTimeout4.f10111j = asyncTimeout2.f10111j; asyncTimeout2.f10111j = null; return asyncTimeout2; } } /* JADX INFO: renamed from: z.a$b */ @Metadata(d1 = {"\u0000\u0012\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0000\b\u0002\u0018\u00002\u00020\u0001B\u0007\b\u0000¢\u0006\u0002\u0010\u0002J\b\u0010\u0003\u001a\u00020\u0004H\u0016¨\u0006\u0005"}, d2 = {"Lokio/AsyncTimeout$Watchdog;", "Ljava/lang/Thread;", "()V", "run", "", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48) public static final class b extends Thread { public b() { super("Okio Watchdog"); setDaemon(true); } @Override // java.lang.Thread, java.lang.Runnable public void run() { AsyncTimeout asyncTimeoutA; while (true) { try { synchronized (AsyncTimeout.class) { asyncTimeoutA = AsyncTimeout.f10106e.a(); if (asyncTimeoutA == AsyncTimeout.f10109h) { AsyncTimeout.f10109h = null; return; } } if (asyncTimeoutA != null) { asyncTimeoutA.k(); } } catch (InterruptedException unused) { } } } } static { long millis = TimeUnit.SECONDS.toMillis(60L); f10107f = millis; f10108g = TimeUnit.MILLISECONDS.toNanos(millis); } /* JADX WARN: Removed duplicated region for block: B:24:0x0053 A[Catch: all -> 0x0082, TryCatch #0 {, blocks: (B:8:0x0010, B:10:0x0016, B:12:0x001c, B:13:0x002b, B:16:0x0033, B:18:0x003f, B:21:0x0047, B:22:0x004c, B:24:0x0053, B:27:0x005e, B:28:0x0061, B:30:0x006b, B:20:0x0043, B:33:0x0070, B:34:0x0075, B:35:0x0076, B:36:0x0081), top: B:40:0x0010 }] */ /* JADX WARN: Removed duplicated region for block: B:30:0x006b A[Catch: all -> 0x0082, TRY_LEAVE, TryCatch #0 {, blocks: (B:8:0x0010, B:10:0x0016, B:12:0x001c, B:13:0x002b, B:16:0x0033, B:18:0x003f, B:21:0x0047, B:22:0x004c, B:24:0x0053, B:27:0x005e, B:28:0x0061, B:30:0x006b, B:20:0x0043, B:33:0x0070, B:34:0x0075, B:35:0x0076, B:36:0x0081), top: B:40:0x0010 }] */ /* JADX WARN: Removed duplicated region for block: B:41:0x0061 A[EDGE_INSN: B:41:0x0061->B:28:0x0061 BREAK A[LOOP:0: B:22:0x004c->B:27:0x005e], SYNTHETIC] */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final void h() { /* r9 = this; long r0 = r9.f10165d boolean r2 = r9.f10163b r3 = 0 int r3 = (r0 > r3 ? 1 : (r0 == r3 ? 0 : -1)) if (r3 != 0) goto Ld if (r2 != 0) goto Ld return Ld: java.lang.Class r4 = okio.AsyncTimeout.class monitor-enter(r4) boolean r5 = r9.f10110i // Catch: java.lang.Throwable -> L82 r6 = 1 r5 = r5 ^ r6 if (r5 == 0) goto L76 r9.f10110i = r6 // Catch: java.lang.Throwable -> L82 z.a r5 = okio.AsyncTimeout.f10109h // Catch: java.lang.Throwable -> L82 if (r5 != 0) goto L2b z.a r5 = new z.a // Catch: java.lang.Throwable -> L82 r5.() // Catch: java.lang.Throwable -> L82 okio.AsyncTimeout.f10109h = r5 // Catch: java.lang.Throwable -> L82 z.a$b r5 = new z.a$b // Catch: java.lang.Throwable -> L82 r5.() // Catch: java.lang.Throwable -> L82 r5.start() // Catch: java.lang.Throwable -> L82 L2b: long r5 = java.lang.System.nanoTime() // Catch: java.lang.Throwable -> L82 if (r3 == 0) goto L3d if (r2 == 0) goto L3d long r2 = r9.c() // Catch: java.lang.Throwable -> L82 long r2 = r2 - r5 long r0 = java.lang.Math.min(r0, r2) // Catch: java.lang.Throwable -> L82 goto L3f L3d: if (r3 == 0) goto L41 L3f: long r0 = r0 + r5 goto L47 L41: if (r2 == 0) goto L70 long r0 = r9.c() // Catch: java.lang.Throwable -> L82 L47: r9.f10112k = r0 // Catch: java.lang.Throwable -> L82 long r0 = r0 - r5 z.a r2 = okio.AsyncTimeout.f10109h // Catch: java.lang.Throwable -> L82 L4c: kotlin.jvm.internal.o.c(r2) // Catch: java.lang.Throwable -> L82 z.a r3 = r2.f10111j // Catch: java.lang.Throwable -> L82 if (r3 == 0) goto L61 kotlin.jvm.internal.o.c(r3) // Catch: java.lang.Throwable -> L82 long r7 = r3.f10112k // Catch: java.lang.Throwable -> L82 long r7 = r7 - r5 int r3 = (r0 > r7 ? 1 : (r0 == r7 ? 0 : -1)) if (r3 >= 0) goto L5e goto L61 L5e: z.a r2 = r2.f10111j // Catch: java.lang.Throwable -> L82 goto L4c L61: z.a r0 = r2.f10111j // Catch: java.lang.Throwable -> L82 r9.f10111j = r0 // Catch: java.lang.Throwable -> L82 r2.f10111j = r9 // Catch: java.lang.Throwable -> L82 z.a r0 = okio.AsyncTimeout.f10109h // Catch: java.lang.Throwable -> L82 if (r2 != r0) goto L6e r4.notify() // Catch: java.lang.Throwable -> L82 L6e: monitor-exit(r4) return L70: java.lang.AssertionError r0 = new java.lang.AssertionError // Catch: java.lang.Throwable -> L82 r0.() // Catch: java.lang.Throwable -> L82 throw r0 // Catch: java.lang.Throwable -> L82 L76: java.lang.String r0 = "Unbalanced enter/exit" java.lang.IllegalStateException r1 = new java.lang.IllegalStateException // Catch: java.lang.Throwable -> L82 java.lang.String r0 = r0.toString() // Catch: java.lang.Throwable -> L82 r1.(r0) // Catch: java.lang.Throwable -> L82 throw r1 // Catch: java.lang.Throwable -> L82 L82: r0 = move-exception monitor-exit(r4) throw r0 */ throw new UnsupportedOperationException("Method not decompiled: okio.AsyncTimeout.h():void"); } /* JADX WARN: Code restructure failed: missing block: B:11:0x0013, code lost: r1.f10111j = r4.f10111j; r4.f10111j = null; */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final boolean i() { /* r4 = this; java.lang.Class r0 = okio.AsyncTimeout.class monitor-enter(r0) boolean r1 = r4.f10110i // Catch: java.lang.Throwable -> L20 r2 = 0 if (r1 != 0) goto L9 goto L1e L9: r4.f10110i = r2 // Catch: java.lang.Throwable -> L20 z.a r1 = okio.AsyncTimeout.f10109h // Catch: java.lang.Throwable -> L20 Ld: if (r1 == 0) goto L1d z.a r3 = r1.f10111j // Catch: java.lang.Throwable -> L20 if (r3 != r4) goto L1b z.a r3 = r4.f10111j // Catch: java.lang.Throwable -> L20 r1.f10111j = r3 // Catch: java.lang.Throwable -> L20 r1 = 0 r4.f10111j = r1 // Catch: java.lang.Throwable -> L20 goto L1e L1b: r1 = r3 goto Ld L1d: r2 = 1 L1e: monitor-exit(r0) return r2 L20: r1 = move-exception monitor-exit(r0) throw r1 */ throw new UnsupportedOperationException("Method not decompiled: okio.AsyncTimeout.i():boolean"); } public IOException j(IOException iOException) { InterruptedIOException interruptedIOException = new InterruptedIOException(RtspHeaders.Values.TIMEOUT); if (iOException != null) { interruptedIOException.initCause(iOException); } return interruptedIOException; } public void k() { } }