package s.coroutines;

import kotlin.Metadata;
import kotlin.Pair;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.ContinuationInterceptor;
import kotlin.coroutines.CoroutineContext;
import kotlin.reflect.w.internal.y0.n.c2.c;
import s.coroutines.internal.ScopeCoroutine;
import s.coroutines.internal.u;

/* JADX INFO: renamed from: s.a.x1, reason: from Kotlin metadata */
/* JADX INFO: loaded from: classes2.dex */
@Metadata(d1 = {"\u00008\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0003\b\u0000\u0018\u0000*\u0006\b\u0000\u0010\u0001 \u00002\b\u0012\u0004\u0012\u0002H\u00010\u0002B\u001b\u0012\u0006\u0010\u0003\u001a\u00020\u0004\u0012\f\u0010\u0005\u001a\b\u0012\u0004\u0012\u00028\u00000\u0006¢\u0006\u0002\u0010\u0007J\u0012\u0010\f\u001a\u00020\r2\b\u0010\u000e\u001a\u0004\u0018\u00010\u000bH\u0014J\u0006\u0010\u000f\u001a\u00020\u0010J\u0018\u0010\u0011\u001a\u00020\r2\u0006\u0010\u0003\u001a\u00020\u00042\b\u0010\u0012\u001a\u0004\u0018\u00010\u000bR\"\u0010\b\u001a\u0016\u0012\u0012\u0012\u0010\u0012\u0004\u0012\u00020\u0004\u0012\u0006\u0012\u0004\u0018\u00010\u000b0\n0\tX\u0082\u000e¢\u0006\u0002\n\u0000¨\u0006\u0013"}, d2 = {"Lkotlinx/coroutines/UndispatchedCoroutine;", "T", "Lkotlinx/coroutines/internal/ScopeCoroutine;", "context", "Lkotlin/coroutines/CoroutineContext;", "uCont", "Lkotlin/coroutines/Continuation;", "(Lkotlin/coroutines/CoroutineContext;Lkotlin/coroutines/Continuation;)V", "threadStateToRecover", "Ljava/lang/ThreadLocal;", "Lkotlin/Pair;", "", "afterResume", "", "state", "clearThreadContext", "", "saveThreadContext", "oldValue", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
public final class UndispatchedCoroutine<T> extends ScopeCoroutine<T> {

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    public ThreadLocal<Pair<CoroutineContext, Object>> f9492o;

    /* JADX WARN: Illegal instructions before constructor call */
    public UndispatchedCoroutine(CoroutineContext coroutineContext, Continuation<? super T> continuation) {
        UndispatchedMarker undispatchedMarker = UndispatchedMarker.f9494f;
        super(coroutineContext.get(undispatchedMarker) == null ? coroutineContext.plus(undispatchedMarker) : coroutineContext, continuation);
        this.f9492o = new ThreadLocal<>();
        CoroutineContext f9433r = continuation.getF9433r();
        int i2 = ContinuationInterceptor.f6136i;
        if (f9433r.get(ContinuationInterceptor.a.f6137f) instanceof CoroutineDispatcher) {
            return;
        }
        Object objB = u.b(coroutineContext, null);
        u.a(coroutineContext, objB);
        this.f9492o.set(new Pair<>(coroutineContext, objB));
    }

    @Override // s.coroutines.internal.ScopeCoroutine, s.coroutines.AbstractCoroutine
    public void T(Object obj) {
        Pair<CoroutineContext, Object> pair = this.f9492o.get();
        if (pair != null) {
            u.a(pair.f5909f, pair.f5910m);
            this.f9492o.set(null);
        }
        Object objU0 = c.u0(obj, this.f9356n);
        Continuation<T> continuation = this.f9356n;
        CoroutineContext f9433r = continuation.getF9433r();
        Object objB = u.b(f9433r, null);
        UndispatchedCoroutine<?> undispatchedCoroutineQ0 = objB != u.a ? c.Q0(continuation, f9433r, objB) : null;
        try {
            this.f9356n.resumeWith(objU0);
        } finally {
            if (undispatchedCoroutineQ0 == null || undispatchedCoroutineQ0.V()) {
                u.a(f9433r, objB);
            }
        }
    }

    public final boolean V() {
        if (this.f9492o.get() == null) {
            return false;
        }
        this.f9492o.set(null);
        return true;
    }
}
