package s.coroutines; import io.netty.handler.codec.rtsp.RtspHeaders; import java.util.Objects; import java.util.concurrent.CancellationException; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import kotlin.Metadata; import kotlin.Result; import kotlin.Unit; import kotlin.coroutines.Continuation; import kotlin.coroutines.CoroutineContext; import kotlin.coroutines.intrinsics.CoroutineSingletons; import kotlin.coroutines.j.internal.CoroutineStackFrame; import kotlin.jvm.functions.Function1; import kotlin.reflect.w.internal.y0.n.c2.c; import s.coroutines.Job; import s.coroutines.internal.DispatchedContinuation; /* JADX INFO: renamed from: s.a.i, reason: from Kotlin metadata */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000¶\u0001\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u0001\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0003\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000b\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0010\u000e\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0010\n\u0002\u0018\u0002\n\u0002\u0018\u0002\b\u0011\u0018\u0000*\u0006\b\u0000\u0010\u0001 \u00002\t\u0012\u0004\u0012\u00028\u00000\u008a\u00012\t\u0012\u0004\u0012\u00028\u00000\u008b\u00012\u00060tj\u0002`uB\u001d\u0012\f\u0010\u0003\u001a\b\u0012\u0004\u0012\u00028\u00000\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007J\u0019\u0010\u000b\u001a\u00020\n2\b\u0010\t\u001a\u0004\u0018\u00010\bH\u0002¢\u0006\u0004\b\u000b\u0010\fJ\u001f\u0010\u0012\u001a\u00020\u00112\u0006\u0010\u000e\u001a\u00020\r2\b\u0010\u0010\u001a\u0004\u0018\u00010\u000f¢\u0006\u0004\b\u0012\u0010\u0013JB\u0010\u0012\u001a\u00020\u00112'\u0010\u000e\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u00110\u0014j\u0002`\u00172\b\u0010\u0010\u001a\u0004\u0018\u00010\u000fH\u0002¢\u0006\u0004\b\u0012\u0010\u0018J\u001e\u0010\u001b\u001a\u00020\u00112\f\u0010\u001a\u001a\b\u0012\u0004\u0012\u00020\u00110\u0019H\u0082\b¢\u0006\u0004\b\u001b\u0010\u001cJ8\u0010\u001e\u001a\u00020\u00112!\u0010\u001d\u001a\u001d\u0012\u0013\u0012\u00110\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u00110\u00142\u0006\u0010\u0010\u001a\u00020\u000f¢\u0006\u0004\b\u001e\u0010\u0018J\u0019\u0010 \u001a\u00020\u001f2\b\u0010\u0010\u001a\u0004\u0018\u00010\u000fH\u0016¢\u0006\u0004\b \u0010!J!\u0010%\u001a\u00020\u00112\b\u0010\"\u001a\u0004\u0018\u00010\b2\u0006\u0010\u0010\u001a\u00020\u000fH\u0010¢\u0006\u0004\b#\u0010$J\u0017\u0010&\u001a\u00020\u001f2\u0006\u0010\u0010\u001a\u00020\u000fH\u0002¢\u0006\u0004\b&\u0010!J\u0017\u0010(\u001a\u00020\u00112\u0006\u0010'\u001a\u00020\bH\u0016¢\u0006\u0004\b(\u0010)J\u000f\u0010,\u001a\u00020\u0011H\u0000¢\u0006\u0004\b*\u0010+J\u000f\u0010-\u001a\u00020\u0011H\u0002¢\u0006\u0004\b-\u0010+J\u0017\u0010/\u001a\u00020\u00112\u0006\u0010.\u001a\u00020\u0004H\u0002¢\u0006\u0004\b/\u00100J\u0017\u00103\u001a\u00020\u000f2\u0006\u00102\u001a\u000201H\u0016¢\u0006\u0004\b3\u00104J\u001b\u00108\u001a\u0004\u0018\u00010\u000f2\b\u00105\u001a\u0004\u0018\u00010\bH\u0010¢\u0006\u0004\b6\u00107J\u0011\u00109\u001a\u0004\u0018\u00010\bH\u0001¢\u0006\u0004\b9\u0010:J\u0017\u0010=\u001a\n\u0018\u00010;j\u0004\u0018\u0001`J\u001f\u0010A\u001a\u00028\u0001\"\u0004\b\u0001\u0010\u00012\b\u00105\u001a\u0004\u0018\u00010\bH\u0010¢\u0006\u0004\b?\u0010@J\u000f\u0010B\u001a\u00020\u0011H\u0016¢\u0006\u0004\bB\u0010+J\u0011\u0010D\u001a\u0004\u0018\u00010CH\u0002¢\u0006\u0004\bD\u0010EJ8\u0010F\u001a\u00020\u00112'\u0010\u000e\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u00110\u0014j\u0002`\u0017H\u0016¢\u0006\u0004\bF\u0010GJ\u000f\u0010H\u001a\u00020\u001fH\u0002¢\u0006\u0004\bH\u0010IJ8\u0010J\u001a\u00020\r2'\u0010\u000e\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u00110\u0014j\u0002`\u0017H\u0002¢\u0006\u0004\bJ\u0010KJB\u0010L\u001a\u00020\u00112'\u0010\u000e\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u00110\u0014j\u0002`\u00172\b\u00105\u001a\u0004\u0018\u00010\bH\u0002¢\u0006\u0004\bL\u0010MJ\u000f\u0010O\u001a\u00020NH\u0014¢\u0006\u0004\bO\u0010PJ\u0017\u0010S\u001a\u00020\u00112\u0006\u0010\u0010\u001a\u00020\u000fH\u0000¢\u0006\u0004\bQ\u0010RJ\u000f\u0010T\u001a\u00020\u0011H\u0002¢\u0006\u0004\bT\u0010+J\u000f\u0010U\u001a\u00020\u001fH\u0001¢\u0006\u0004\bU\u0010IJ<\u0010W\u001a\u00020\u00112\u0006\u0010V\u001a\u00028\u00002#\u0010\u001d\u001a\u001f\u0012\u0013\u0012\u00110\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u0011\u0018\u00010\u0014H\u0016¢\u0006\u0004\bW\u0010XJH\u0010Y\u001a\u00020\u00112\b\u0010\t\u001a\u0004\u0018\u00010\b2\u0006\u0010\u0005\u001a\u00020\u00042%\b\u0002\u0010\u001d\u001a\u001f\u0012\u0013\u0012\u00110\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u0011\u0018\u00010\u0014H\u0002¢\u0006\u0004\bY\u0010ZJ \u0010]\u001a\u00020\u00112\f\u0010\\\u001a\b\u0012\u0004\u0012\u00028\u00000[H\u0016ø\u0001\u0000¢\u0006\u0004\b]\u0010)JZ\u0010`\u001a\u0004\u0018\u00010\b2\u0006\u00105\u001a\u00020^2\b\u0010\t\u001a\u0004\u0018\u00010\b2\u0006\u0010\u0005\u001a\u00020\u00042#\u0010\u001d\u001a\u001f\u0012\u0013\u0012\u00110\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u0011\u0018\u00010\u00142\b\u0010_\u001a\u0004\u0018\u00010\bH\u0002¢\u0006\u0004\b`\u0010aJ\u0011\u0010c\u001a\u0004\u0018\u00010\bH\u0010¢\u0006\u0004\bb\u0010:J\u000f\u0010d\u001a\u00020NH\u0016¢\u0006\u0004\bd\u0010PJ\u000f\u0010e\u001a\u00020\u001fH\u0002¢\u0006\u0004\be\u0010IJ#\u0010e\u001a\u0004\u0018\u00010\b2\u0006\u0010V\u001a\u00028\u00002\b\u0010_\u001a\u0004\u0018\u00010\bH\u0016¢\u0006\u0004\be\u0010fJH\u0010e\u001a\u0004\u0018\u00010\b2\u0006\u0010V\u001a\u00028\u00002\b\u0010_\u001a\u0004\u0018\u00010\b2#\u0010\u001d\u001a\u001f\u0012\u0013\u0012\u00110\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u0011\u0018\u00010\u0014H\u0016¢\u0006\u0004\be\u0010gJJ\u0010i\u001a\u0004\u0018\u00010h2\b\u0010\t\u001a\u0004\u0018\u00010\b2\b\u0010_\u001a\u0004\u0018\u00010\b2#\u0010\u001d\u001a\u001f\u0012\u0013\u0012\u00110\u000f¢\u0006\f\b\u0015\u0012\b\b\u0016\u0012\u0004\b\b(\u0010\u0012\u0004\u0012\u00020\u0011\u0018\u00010\u0014H\u0002¢\u0006\u0004\bi\u0010jJ\u0019\u0010l\u001a\u0004\u0018\u00010\b2\u0006\u0010k\u001a\u00020\u000fH\u0016¢\u0006\u0004\bl\u0010mJ\u000f\u0010n\u001a\u00020\u001fH\u0002¢\u0006\u0004\bn\u0010IJ\u001b\u0010p\u001a\u00020\u0011*\u00020o2\u0006\u0010V\u001a\u00028\u0000H\u0016¢\u0006\u0004\bp\u0010qJ\u001b\u0010r\u001a\u00020\u0011*\u00020o2\u0006\u0010k\u001a\u00020\u000fH\u0016¢\u0006\u0004\br\u0010sR\u001c\u0010x\u001a\n\u0018\u00010tj\u0004\u0018\u0001`u8VX\u0096\u0004¢\u0006\u0006\u001a\u0004\bv\u0010wR\u001a\u0010z\u001a\u00020y8\u0016X\u0096\u0004¢\u0006\f\n\u0004\bz\u0010{\u001a\u0004\b|\u0010}R!\u0010\u0003\u001a\b\u0012\u0004\u0012\u00028\u00000\u00028\u0000X\u0080\u0004¢\u0006\r\n\u0004\b\u0003\u0010~\u001a\u0005\b\u007f\u0010\u0080\u0001R\u0016\u0010\u0081\u0001\u001a\u00020\u001f8VX\u0096\u0004¢\u0006\u0007\u001a\u0005\b\u0081\u0001\u0010IR\u0016\u0010\u0082\u0001\u001a\u00020\u001f8VX\u0096\u0004¢\u0006\u0007\u001a\u0005\b\u0082\u0001\u0010IR\u0016\u0010\u0083\u0001\u001a\u00020\u001f8VX\u0096\u0004¢\u0006\u0007\u001a\u0005\b\u0083\u0001\u0010IR\u001b\u0010\u0084\u0001\u001a\u0004\u0018\u00010C8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0084\u0001\u0010\u0085\u0001R\u0017\u00105\u001a\u0004\u0018\u00010\b8@X\u0080\u0004¢\u0006\u0007\u001a\u0005\b\u0086\u0001\u0010:R\u0016\u0010\u0088\u0001\u001a\u00020N8BX\u0082\u0004¢\u0006\u0007\u001a\u0005\b\u0087\u0001\u0010P\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u0089\u0001"}, d2 = {"Lkotlinx/coroutines/CancellableContinuationImpl;", "T", "Lkotlin/coroutines/Continuation;", "delegate", "", "resumeMode", "", "(Lkotlin/coroutines/Continuation;I)V", "", "proposedUpdate", "", "alreadyResumedError", "(Ljava/lang/Object;)Ljava/lang/Void;", "Lkotlinx/coroutines/CancelHandler;", "handler", "", "cause", "", "callCancelHandler", "(Lkotlinx/coroutines/CancelHandler;Ljava/lang/Throwable;)V", "Lkotlin/Function1;", "Lkotlin/ParameterName;", "name", "Lkotlinx/coroutines/CompletionHandler;", "(Lkotlin/jvm/functions/Function1;Ljava/lang/Throwable;)V", "Lkotlin/Function0;", "block", "callCancelHandlerSafely", "(Lkotlin/jvm/functions/Function0;)V", "onCancellation", "callOnCancellation", "", "cancel", "(Ljava/lang/Throwable;)Z", "takenState", "cancelCompletedResult$kotlinx_coroutines_core", "(Ljava/lang/Object;Ljava/lang/Throwable;)V", "cancelCompletedResult", "cancelLater", "token", "completeResume", "(Ljava/lang/Object;)V", "detachChild$kotlinx_coroutines_core", "()V", "detachChild", "detachChildIfNonResuable", RtspHeaders.Values.MODE, "dispatchResume", "(I)V", "Lkotlinx/coroutines/Job;", "parent", "getContinuationCancellationCause", "(Lkotlinx/coroutines/Job;)Ljava/lang/Throwable;", "state", "getExceptionalResult$kotlinx_coroutines_core", "(Ljava/lang/Object;)Ljava/lang/Throwable;", "getExceptionalResult", "getResult", "()Ljava/lang/Object;", "Ljava/lang/StackTraceElement;", "Lkotlinx/coroutines/internal/StackTraceElement;", "getStackTraceElement", "()Ljava/lang/StackTraceElement;", "getSuccessfulResult$kotlinx_coroutines_core", "(Ljava/lang/Object;)Ljava/lang/Object;", "getSuccessfulResult", "initCancellability", "Lkotlinx/coroutines/DisposableHandle;", "installParentHandle", "()Lkotlinx/coroutines/DisposableHandle;", "invokeOnCancellation", "(Lkotlin/jvm/functions/Function1;)V", "isReusable", "()Z", "makeCancelHandler", "(Lkotlin/jvm/functions/Function1;)Lkotlinx/coroutines/CancelHandler;", "multipleHandlersError", "(Lkotlin/jvm/functions/Function1;Ljava/lang/Object;)V", "", "nameString", "()Ljava/lang/String;", "parentCancelled$kotlinx_coroutines_core", "(Ljava/lang/Throwable;)V", "parentCancelled", "releaseClaimedReusableContinuation", "resetStateReusable", "value", "resume", "(Ljava/lang/Object;Lkotlin/jvm/functions/Function1;)V", "resumeImpl", "(Ljava/lang/Object;ILkotlin/jvm/functions/Function1;)V", "Lkotlin/Result;", "result", "resumeWith", "Lkotlinx/coroutines/NotCompleted;", "idempotent", "resumedState", "(Lkotlinx/coroutines/NotCompleted;Ljava/lang/Object;ILkotlin/jvm/functions/Function1;Ljava/lang/Object;)Ljava/lang/Object;", "takeState$kotlinx_coroutines_core", "takeState", "toString", "tryResume", "(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;", "(Ljava/lang/Object;Ljava/lang/Object;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;", "Lkotlinx/coroutines/internal/Symbol;", "tryResumeImpl", "(Ljava/lang/Object;Ljava/lang/Object;Lkotlin/jvm/functions/Function1;)Lkotlinx/coroutines/internal/Symbol;", "exception", "tryResumeWithException", "(Ljava/lang/Throwable;)Ljava/lang/Object;", "trySuspend", "Lkotlinx/coroutines/CoroutineDispatcher;", "resumeUndispatched", "(Lkotlinx/coroutines/CoroutineDispatcher;Ljava/lang/Object;)V", "resumeUndispatchedWithException", "(Lkotlinx/coroutines/CoroutineDispatcher;Ljava/lang/Throwable;)V", "Lkotlin/coroutines/jvm/internal/CoroutineStackFrame;", "Lkotlinx/coroutines/internal/CoroutineStackFrame;", "getCallerFrame", "()Lkotlin/coroutines/jvm/internal/CoroutineStackFrame;", "callerFrame", "Lkotlin/coroutines/CoroutineContext;", "context", "Lkotlin/coroutines/CoroutineContext;", "getContext", "()Lkotlin/coroutines/CoroutineContext;", "Lkotlin/coroutines/Continuation;", "getDelegate$kotlinx_coroutines_core", "()Lkotlin/coroutines/Continuation;", "isActive", "isCancelled", "isCompleted", "parentHandle", "Lkotlinx/coroutines/DisposableHandle;", "getState$kotlinx_coroutines_core", "getStateDebugRepresentation", "stateDebugRepresentation", "kotlinx-coroutines-core", "Lkotlinx/coroutines/DispatchedTask;", "Lkotlinx/coroutines/CancellableContinuation;"}, k = 1, mv = {1, 6, 0}, xi = 48) public class CancellableContinuationImpl extends DispatchedTask implements CancellableContinuation, CoroutineStackFrame { /* JADX INFO: renamed from: o, reason: collision with root package name */ public static final /* synthetic */ AtomicIntegerFieldUpdater f9430o = AtomicIntegerFieldUpdater.newUpdater(CancellableContinuationImpl.class, "_decision"); /* JADX INFO: renamed from: p, reason: collision with root package name */ public static final /* synthetic */ AtomicReferenceFieldUpdater f9431p = AtomicReferenceFieldUpdater.newUpdater(CancellableContinuationImpl.class, Object.class, "_state"); private volatile /* synthetic */ int _decision; private volatile /* synthetic */ Object _state; /* JADX INFO: renamed from: q, reason: collision with root package name */ public final Continuation f9432q; /* JADX INFO: renamed from: r, reason: collision with root package name */ public final CoroutineContext f9433r; /* JADX INFO: renamed from: s, reason: collision with root package name */ public DisposableHandle f9434s; /* JADX WARN: Multi-variable type inference failed */ public CancellableContinuationImpl(Continuation continuation, int i2) { super(i2); this.f9432q = continuation; this.f9433r = continuation.getF9433r(); this._decision = 0; this._state = Active.f9326f; } public static void v(CancellableContinuationImpl cancellableContinuationImpl, Object obj, int i2, Function1 function1, int i3, Object obj2) { Object obj3; Object completedContinuation; int i4 = i3 & 4; do { obj3 = cancellableContinuationImpl._state; if (!(obj3 instanceof NotCompleted)) { if (obj3 instanceof CancelledContinuation) { CancelledContinuation cancelledContinuation = (CancelledContinuation) obj3; Objects.requireNonNull(cancelledContinuation); if (CancelledContinuation.f9444c.compareAndSet(cancelledContinuation, 0, 1)) { return; } } throw new IllegalStateException(("Already resumed, but proposed with update " + obj).toString()); } NotCompleted notCompleted = (NotCompleted) obj3; if (!(obj instanceof CompletedExceptionally) && e.a(i2) && (notCompleted instanceof CancelHandler)) { completedContinuation = new CompletedContinuation(obj, notCompleted instanceof CancelHandler ? (CancelHandler) notCompleted : null, null, null, null, 16); } else { completedContinuation = obj; } } while (!f9431p.compareAndSet(cancellableContinuationImpl, obj3, completedContinuation)); cancellableContinuationImpl.n(); cancellableContinuationImpl.o(i2); } @Override // s.coroutines.DispatchedTask public void a(Object obj, Throwable th) { while (true) { Object obj2 = this._state; if (obj2 instanceof NotCompleted) { throw new IllegalStateException("Not completed".toString()); } if (obj2 instanceof CompletedExceptionally) { return; } if (obj2 instanceof CompletedContinuation) { CompletedContinuation completedContinuation = (CompletedContinuation) obj2; if (!(!(completedContinuation.f9462e != null))) { throw new IllegalStateException("Must be called at most once".toString()); } if (f9431p.compareAndSet(this, obj2, CompletedContinuation.a(completedContinuation, null, null, null, null, th, 15))) { CancelHandler cancelHandler = completedContinuation.f9459b; if (cancelHandler != null) { j(cancelHandler, th); } Function1 function1 = completedContinuation.f9460c; if (function1 != null) { k(function1, th); return; } return; } } else if (f9431p.compareAndSet(this, obj2, new CompletedContinuation(obj2, null, null, null, th, 14))) { return; } } } @Override // s.coroutines.CancellableContinuation public void b(Function1 function1) { CancelHandler invokeOnCancel = function1 instanceof CancelHandler ? (CancelHandler) function1 : new InvokeOnCancel(function1); while (true) { Object obj = this._state; if (!(obj instanceof Active)) { if (obj instanceof CancelHandler) { t(function1, obj); throw null; } boolean z2 = obj instanceof CompletedExceptionally; if (z2) { CompletedExceptionally completedExceptionally = (CompletedExceptionally) obj; Objects.requireNonNull(completedExceptionally); if (!CompletedExceptionally.a.compareAndSet(completedExceptionally, 0, 1)) { t(function1, obj); throw null; } if (obj instanceof CancelledContinuation) { if (!z2) { completedExceptionally = null; } i(function1, completedExceptionally != null ? completedExceptionally.f9464b : null); return; } return; } if (obj instanceof CompletedContinuation) { CompletedContinuation completedContinuation = (CompletedContinuation) obj; if (completedContinuation.f9459b != null) { t(function1, obj); throw null; } Throwable th = completedContinuation.f9462e; if (th != null) { i(function1, th); return; } else { if (f9431p.compareAndSet(this, obj, CompletedContinuation.a(completedContinuation, null, invokeOnCancel, null, null, null, 29))) { return; } } } else { if (f9431p.compareAndSet(this, obj, new CompletedContinuation(obj, invokeOnCancel, null, null, null, 28))) { return; } } } else if (f9431p.compareAndSet(this, obj, invokeOnCancel)) { return; } } } @Override // s.coroutines.DispatchedTask public final Continuation c() { return this.f9432q; } @Override // s.coroutines.DispatchedTask public Throwable d(Object obj) { Throwable thD = super.d(obj); if (thD != null) { return thD; } return null; } @Override // s.coroutines.CancellableContinuation public void e(CoroutineDispatcher coroutineDispatcher, T t2) { Continuation continuation = this.f9432q; DispatchedContinuation dispatchedContinuation = continuation instanceof DispatchedContinuation ? (DispatchedContinuation) continuation : null; v(this, t2, (dispatchedContinuation != null ? dispatchedContinuation.f9333p : null) == coroutineDispatcher ? 4 : this.f9453n, null, 4, null); } /* JADX WARN: Multi-variable type inference failed */ @Override // s.coroutines.DispatchedTask public T f(Object obj) { return obj instanceof CompletedContinuation ? (T) ((CompletedContinuation) obj).a : obj; } @Override // kotlin.coroutines.j.internal.CoroutineStackFrame public CoroutineStackFrame getCallerFrame() { Continuation continuation = this.f9432q; if (continuation instanceof CoroutineStackFrame) { return (CoroutineStackFrame) continuation; } return null; } @Override // kotlin.coroutines.Continuation /* JADX INFO: renamed from: getContext, reason: from getter */ public CoroutineContext getF9433r() { return this.f9433r; } @Override // s.coroutines.DispatchedTask /* JADX INFO: renamed from: h, reason: from getter */ public Object get_state() { return this._state; } public final void i(Function1 function1, Throwable th) { try { function1.invoke(th); } catch (Throwable th2) { c.S(this.f9433r, new CompletionHandlerException("Exception in invokeOnCancellation handler for " + this, th2)); } } public final void j(CancelHandler cancelHandler, Throwable th) { try { cancelHandler.a(th); } catch (Throwable th2) { c.S(this.f9433r, new CompletionHandlerException("Exception in invokeOnCancellation handler for " + this, th2)); } } public final void k(Function1 function1, Throwable th) { try { function1.invoke(th); } catch (Throwable th2) { c.S(this.f9433r, new CompletionHandlerException("Exception in resume onCancellation handler for " + this, th2)); } } public boolean l(Throwable th) { Object obj; boolean z2; do { obj = this._state; if (!(obj instanceof NotCompleted)) { return false; } z2 = obj instanceof CancelHandler; } while (!f9431p.compareAndSet(this, obj, new CancelledContinuation(this, th, z2))); CancelHandler cancelHandler = z2 ? (CancelHandler) obj : null; if (cancelHandler != null) { j(cancelHandler, th); } n(); o(this.f9453n); return true; } public final void m() { DisposableHandle disposableHandle = this.f9434s; if (disposableHandle == null) { return; } disposableHandle.b(); this.f9434s = NonDisposableHandle.f9458f; } public final void n() { if (s()) { return; } m(); } public final void o(int i2) { boolean z2; while (true) { int i3 = this._decision; if (i3 != 0) { if (i3 != 1) { throw new IllegalStateException("Already resumed".toString()); } z2 = false; } else if (f9430o.compareAndSet(this, 0, 2)) { z2 = true; break; } } if (z2) { return; } Continuation continuationC = c(); boolean z3 = i2 == 4; if (z3 || !(continuationC instanceof DispatchedContinuation) || e.a(i2) != e.a(this.f9453n)) { e.b(this, continuationC, z3); return; } CoroutineDispatcher coroutineDispatcher = ((DispatchedContinuation) continuationC).f9333p; CoroutineContext f9433r = continuationC.getF9433r(); if (coroutineDispatcher.A(f9433r)) { coroutineDispatcher.z(f9433r, this); return; } ThreadLocalEventLoop threadLocalEventLoop = ThreadLocalEventLoop.a; EventLoop eventLoopA = ThreadLocalEventLoop.a(); if (eventLoopA.F()) { eventLoopA.D(this); return; } eventLoopA.E(true); try { e.b(this, c(), true); do { } while (eventLoopA.H()); } finally { try { } finally { } } } public final Object p() { boolean z2; boolean zS = s(); while (true) { int i2 = this._decision; z2 = false; if (i2 != 0) { if (i2 != 2) { throw new IllegalStateException("Already suspended".toString()); } } else if (f9430o.compareAndSet(this, 0, 1)) { z2 = true; break; } } if (z2) { if (this.f9434s == null) { r(); } if (zS) { u(); } return CoroutineSingletons.COROUTINE_SUSPENDED; } if (zS) { u(); } Object obj = this._state; if (obj instanceof CompletedExceptionally) { throw ((CompletedExceptionally) obj).f9464b; } if (e.a(this.f9453n)) { CoroutineContext coroutineContext = this.f9433r; int i3 = Job.f9422l; Job job = (Job) coroutineContext.get(Job.a.f9423f); if (job != null && !job.isActive()) { CancellationException cancellationExceptionH = job.h(); a(obj, cancellationExceptionH); throw cancellationExceptionH; } } return f(obj); } public void q() { DisposableHandle disposableHandleR = r(); if (disposableHandleR != null && (!(this._state instanceof NotCompleted))) { disposableHandleR.b(); this.f9434s = NonDisposableHandle.f9458f; } } public final DisposableHandle r() { CoroutineContext coroutineContext = this.f9433r; int i2 = Job.f9422l; Job job = (Job) coroutineContext.get(Job.a.f9423f); if (job == null) { return null; } DisposableHandle disposableHandleX = c.X(job, true, false, new ChildContinuation(this), 2, null); this.f9434s = disposableHandleX; return disposableHandleX; } @Override // kotlin.coroutines.Continuation public void resumeWith(Object result) { Throwable thA = Result.a(result); if (thA != null) { result = new CompletedExceptionally(thA, false, 2); } v(this, result, this.f9453n, null, 4, null); } public final boolean s() { return (this.f9453n == 2) && ((DispatchedContinuation) this.f9432q).i(); } public final void t(Function1 function1, Object obj) { throw new IllegalStateException(("It's prohibited to register multiple handlers, tried to register " + function1 + ", already has " + obj).toString()); } public String toString() { StringBuilder sb = new StringBuilder(); sb.append("CancellableContinuation"); sb.append('('); sb.append(e0.c(this.f9432q)); sb.append("){"); Object obj = this._state; sb.append(obj instanceof NotCompleted ? "Active" : obj instanceof CancelledContinuation ? "Cancelled" : "Completed"); sb.append("}@"); sb.append(e0.b(this)); return sb.toString(); } public final void u() { Throwable thL; Continuation continuation = this.f9432q; DispatchedContinuation dispatchedContinuation = continuation instanceof DispatchedContinuation ? (DispatchedContinuation) continuation : null; if (dispatchedContinuation == null || (thL = dispatchedContinuation.l(this)) == null) { return; } m(); l(thL); } }