package s.coroutines.internal;

import g.h.a.i;
import io.netty.handler.codec.rtsp.RtspHeaders;
import java.util.concurrent.CancellationException;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.CoroutineContext;
import kotlin.jvm.functions.Function1;
import kotlin.reflect.w.internal.y0.n.c2.c;
import s.coroutines.CompletedWithCancellation;
import s.coroutines.EventLoop;
import s.coroutines.Job;
import s.coroutines.ThreadLocalEventLoop;
import s.coroutines.UndispatchedCoroutine;

/* JADX INFO: loaded from: classes2.dex */
@Metadata(d1 = {"\u0000J\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000b\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\u001a;\u0010\u0006\u001a\u00020\u0007*\u0006\u0012\u0002\b\u00030\b2\b\u0010\t\u001a\u0004\u0018\u00010\n2\u0006\u0010\u000b\u001a\u00020\f2\b\b\u0002\u0010\r\u001a\u00020\u00072\f\u0010\u000e\u001a\b\u0012\u0004\u0012\u00020\u00100\u000fH\u0082\b\u001aU\u0010\u0011\u001a\u00020\u0010\"\u0004\b\u0000\u0010\u0012*\b\u0012\u0004\u0012\u0002H\u00120\u00132\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u0002H\u00120\u00152%\b\u0002\u0010\u0016\u001a\u001f\u0012\u0013\u0012\u00110\u0018¢\u0006\f\b\u0019\u0012\b\b\u001a\u0012\u0004\b\b(\u001b\u0012\u0004\u0012\u00020\u0010\u0018\u00010\u0017H\u0007ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001a\u0012\u0010\u001d\u001a\u00020\u0007*\b\u0012\u0004\u0012\u00020\u00100\bH\u0000\"\u0016\u0010\u0000\u001a\u00020\u00018\u0000X\u0081\u0004¢\u0006\b\n\u0000\u0012\u0004\b\u0002\u0010\u0003\"\u0016\u0010\u0004\u001a\u00020\u00018\u0002X\u0083\u0004¢\u0006\b\n\u0000\u0012\u0004\b\u0005\u0010\u0003\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u001e"}, d2 = {"REUSABLE_CLAIMED", "Lkotlinx/coroutines/internal/Symbol;", "getREUSABLE_CLAIMED$annotations", "()V", "UNDEFINED", "getUNDEFINED$annotations", "executeUnconfined", "", "Lkotlinx/coroutines/internal/DispatchedContinuation;", "contState", "", RtspHeaders.Values.MODE, "", "doYield", "block", "Lkotlin/Function0;", "", "resumeCancellableWith", "T", "Lkotlin/coroutines/Continuation;", "result", "Lkotlin/Result;", "onCancellation", "Lkotlin/Function1;", "", "Lkotlin/ParameterName;", "name", "cause", "(Lkotlin/coroutines/Continuation;Ljava/lang/Object;Lkotlin/jvm/functions/Function1;)V", "yieldUndispatched", "kotlinx-coroutines-core"}, k = 2, mv = {1, 6, 0}, xi = 48)
public final class f {
    public static final Symbol a = new Symbol("UNDEFINED");

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final Symbol f9337b = new Symbol("REUSABLE_CLAIMED");

    /* JADX WARN: Finally extract failed */
    public static final <T> void a(Continuation<? super T> continuation, Object obj, Function1<? super Throwable, Unit> function1) {
        boolean z2;
        if (!(continuation instanceof DispatchedContinuation)) {
            continuation.resumeWith(obj);
            return;
        }
        DispatchedContinuation dispatchedContinuation = (DispatchedContinuation) continuation;
        Object objP0 = c.P0(obj, function1);
        if (dispatchedContinuation.f9333p.A(dispatchedContinuation.getF9433r())) {
            dispatchedContinuation.f9335r = objP0;
            dispatchedContinuation.f9453n = 1;
            dispatchedContinuation.f9333p.z(dispatchedContinuation.getF9433r(), dispatchedContinuation);
            return;
        }
        ThreadLocalEventLoop threadLocalEventLoop = ThreadLocalEventLoop.a;
        EventLoop eventLoopA = ThreadLocalEventLoop.a();
        if (eventLoopA.F()) {
            dispatchedContinuation.f9335r = objP0;
            dispatchedContinuation.f9453n = 1;
            eventLoopA.D(dispatchedContinuation);
            return;
        }
        eventLoopA.E(true);
        try {
            Job job = (Job) dispatchedContinuation.getF9433r().get(Job.a.f9423f);
            if (job == null || job.isActive()) {
                z2 = false;
            } else {
                CancellationException cancellationExceptionH = job.h();
                if (objP0 instanceof CompletedWithCancellation) {
                    ((CompletedWithCancellation) objP0).f9466b.invoke(cancellationExceptionH);
                }
                dispatchedContinuation.resumeWith(i.q0(cancellationExceptionH));
                z2 = true;
            }
            if (!z2) {
                Continuation<T> continuation2 = dispatchedContinuation.f9334q;
                Object obj2 = dispatchedContinuation.f9336s;
                CoroutineContext context = continuation2.getF9433r();
                Object objB = u.b(context, obj2);
                UndispatchedCoroutine<?> undispatchedCoroutineQ0 = objB != u.a ? c.Q0(continuation2, context, objB) : null;
                try {
                    dispatchedContinuation.f9334q.resumeWith(obj);
                    if (undispatchedCoroutineQ0 == null || undispatchedCoroutineQ0.V()) {
                        u.a(context, objB);
                    }
                } catch (Throwable th) {
                    if (undispatchedCoroutineQ0 == null || undispatchedCoroutineQ0.V()) {
                        u.a(context, objB);
                    }
                    throw th;
                }
            }
            while (eventLoopA.H()) {
            }
        } finally {
            try {
            } finally {
            }
        }
    }

    public static /* synthetic */ void b(Continuation continuation, Object obj, Function1 function1, int i2) {
        int i3 = i2 & 2;
        a(continuation, obj, null);
    }
}