package kotlinx.coroutines; import androidx.concurrent.futures.AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0; import com.seewo.vcommons.system.onoffsetting.Task; import java.util.ArrayList; import java.util.Collections; import java.util.IdentityHashMap; import java.util.Iterator; import java.util.List; import java.util.Set; import java.util.concurrent.CancellationException; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import kotlin.Deprecated; import kotlin.DeprecationLevel; import kotlin.Metadata; import kotlin.Unit; import kotlin.coroutines.Continuation; import kotlin.coroutines.CoroutineContext; import kotlin.coroutines.intrinsics.IntrinsicsKt; import kotlin.coroutines.jvm.internal.CoroutineStackFrame; import kotlin.coroutines.jvm.internal.DebugProbesKt; import kotlin.jvm.functions.Function1; import kotlin.jvm.functions.Function2; import kotlin.jvm.internal.Intrinsics; import kotlin.jvm.internal.Ref; import kotlin.sequences.Sequence; import kotlin.sequences.SequencesKt; import kotlinx.coroutines.Job; import kotlinx.coroutines.internal.LockFreeLinkedListKt; import kotlinx.coroutines.internal.LockFreeLinkedListNode; import kotlinx.coroutines.internal.OpDescriptor; import kotlinx.coroutines.internal.StackTraceRecoveryKt; import kotlinx.coroutines.intrinsics.CancellableKt; import kotlinx.coroutines.intrinsics.UndispatchedKt; import kotlinx.coroutines.selects.SelectClause0; import kotlinx.coroutines.selects.SelectInstance; import kotlinx.serialization.json.internal.AbstractJsonLexerKt; /* JADX INFO: compiled from: JobSupport.kt */ /* JADX INFO: loaded from: classes2.dex */ @Deprecated(level = DeprecationLevel.ERROR, message = "This is internal API and may be removed in the future releases") @Metadata(d1 = {"\u0000è\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u0003\n\u0000\n\u0002\u0010 \n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0017\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0010\u0001\n\u0002\b\u0012\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0010\b\n\u0002\b\u0010\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0012\b\u0017\u0018\u00002\u00020X2\u00020\u00172\u00020\u007f2\u00030Ã\u0001:\u0006Ò\u0001Ó\u0001Ô\u0001B\u000f\u0012\u0006\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0003\u0010\u0004J'\u0010\u000b\u001a\u00020\u00012\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010\n\u001a\u00020\tH\u0002¢\u0006\u0004\b\u000b\u0010\fJ%\u0010\u0012\u001a\u00020\u00112\u0006\u0010\u000e\u001a\u00020\r2\f\u0010\u0010\u001a\b\u0012\u0004\u0012\u00020\r0\u000fH\u0002¢\u0006\u0004\b\u0012\u0010\u0013J\u0019\u0010\u0015\u001a\u00020\u00112\b\u0010\u0014\u001a\u0004\u0018\u00010\u0005H\u0014¢\u0006\u0004\b\u0015\u0010\u0016J\u0015\u0010\u001a\u001a\u00020\u00192\u0006\u0010\u0018\u001a\u00020\u0017¢\u0006\u0004\b\u001a\u0010\u001bJ\u0015\u0010\u001e\u001a\u0004\u0018\u00010\u0005H\u0080@ø\u0001\u0000¢\u0006\u0004\b\u001c\u0010\u001dJ\u0015\u0010\u001f\u001a\u0004\u0018\u00010\u0005H\u0082@ø\u0001\u0000¢\u0006\u0004\b\u001f\u0010\u001dJ\u0019\u0010!\u001a\u00020\u00012\b\u0010 \u001a\u0004\u0018\u00010\rH\u0017¢\u0006\u0004\b!\u0010\"J\u001f\u0010!\u001a\u00020\u00112\u000e\u0010 \u001a\n\u0018\u00010#j\u0004\u0018\u0001`$H\u0016¢\u0006\u0004\b!\u0010%J\u0017\u0010&\u001a\u00020\u00012\b\u0010 \u001a\u0004\u0018\u00010\r¢\u0006\u0004\b&\u0010\"J\u0019\u0010)\u001a\u00020\u00012\b\u0010 \u001a\u0004\u0018\u00010\u0005H\u0000¢\u0006\u0004\b'\u0010(J\u0017\u0010*\u001a\u00020\u00112\u0006\u0010 \u001a\u00020\rH\u0016¢\u0006\u0004\b*\u0010+J\u001b\u0010,\u001a\u0004\u0018\u00010\u00052\b\u0010 \u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0004\b,\u0010-J\u0017\u0010.\u001a\u00020\u00012\u0006\u0010 \u001a\u00020\rH\u0002¢\u0006\u0004\b.\u0010\"J\u000f\u00100\u001a\u00020/H\u0014¢\u0006\u0004\b0\u00101J\u0017\u00102\u001a\u00020\u00012\u0006\u0010 \u001a\u00020\rH\u0016¢\u0006\u0004\b2\u0010\"J!\u00105\u001a\u00020\u00112\u0006\u0010\u0014\u001a\u0002032\b\u00104\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0004\b5\u00106J)\u0010;\u001a\u00020\u00112\u0006\u0010\u0014\u001a\u0002072\u0006\u00109\u001a\u0002082\b\u0010:\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0004\b;\u0010J(\u0010C\u001a\u00020@2\n\b\u0002\u0010?\u001a\u0004\u0018\u00010/2\n\b\u0002\u0010 \u001a\u0004\u0018\u00010\rH\u0080\b¢\u0006\u0004\bA\u0010BJ#\u0010D\u001a\u0004\u0018\u00010\u00052\u0006\u0010\u0014\u001a\u0002072\b\u0010:\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0004\bD\u0010EJ\u0019\u0010F\u001a\u0004\u0018\u0001082\u0006\u0010\u0014\u001a\u000203H\u0002¢\u0006\u0004\bF\u0010GJ\u0011\u0010H\u001a\u00060#j\u0002`$¢\u0006\u0004\bH\u0010IJ\u0013\u0010J\u001a\u00060#j\u0002`$H\u0016¢\u0006\u0004\bJ\u0010IJ\u0011\u0010M\u001a\u0004\u0018\u00010\u0005H\u0000¢\u0006\u0004\bK\u0010LJ\u000f\u0010N\u001a\u0004\u0018\u00010\r¢\u0006\u0004\bN\u0010OJ'\u0010P\u001a\u0004\u0018\u00010\r2\u0006\u0010\u0014\u001a\u0002072\f\u0010\u0010\u001a\b\u0012\u0004\u0012\u00020\r0\u000fH\u0002¢\u0006\u0004\bP\u0010QJ\u0019\u0010R\u001a\u0004\u0018\u00010\u00072\u0006\u0010\u0014\u001a\u000203H\u0002¢\u0006\u0004\bR\u0010SJ\u0017\u0010U\u001a\u00020\u00012\u0006\u0010T\u001a\u00020\rH\u0014¢\u0006\u0004\bU\u0010\"J\u0017\u0010W\u001a\u00020\u00112\u0006\u0010T\u001a\u00020\rH\u0010¢\u0006\u0004\bV\u0010+J\u0019\u0010Z\u001a\u00020\u00112\b\u0010Y\u001a\u0004\u0018\u00010XH\u0004¢\u0006\u0004\bZ\u0010[JF\u0010d\u001a\u00020c2\u0006\u0010\\\u001a\u00020\u00012\u0006\u0010]\u001a\u00020\u00012'\u0010b\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\r¢\u0006\f\b_\u0012\b\b`\u0012\u0004\b\b( \u0012\u0004\u0012\u00020\u00110^j\u0002`a¢\u0006\u0004\bd\u0010eJ6\u0010d\u001a\u00020c2'\u0010b\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\r¢\u0006\f\b_\u0012\b\b`\u0012\u0004\b\b( \u0012\u0004\u0012\u00020\u00110^j\u0002`a¢\u0006\u0004\bd\u0010fJ\u0013\u0010g\u001a\u00020\u0011H\u0086@ø\u0001\u0000¢\u0006\u0004\bg\u0010\u001dJ\u000f\u0010h\u001a\u00020\u0001H\u0002¢\u0006\u0004\bh\u0010iJ\u0013\u0010j\u001a\u00020\u0011H\u0082@ø\u0001\u0000¢\u0006\u0004\bj\u0010\u001dJ&\u0010m\u001a\u00020l2\u0014\u0010k\u001a\u0010\u0012\u0006\u0012\u0004\u0018\u00010\u0005\u0012\u0004\u0012\u00020\u00110^H\u0082\b¢\u0006\u0004\bm\u0010nJ\u001b\u0010o\u001a\u0004\u0018\u00010\u00052\b\u0010 \u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0004\bo\u0010-J\u0019\u0010q\u001a\u00020\u00012\b\u0010:\u001a\u0004\u0018\u00010\u0005H\u0000¢\u0006\u0004\bp\u0010(J\u001b\u0010s\u001a\u0004\u0018\u00010\u00052\b\u0010:\u001a\u0004\u0018\u00010\u0005H\u0000¢\u0006\u0004\br\u0010-J@\u0010t\u001a\u00020\t2'\u0010b\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\r¢\u0006\f\b_\u0012\b\b`\u0012\u0004\b\b( \u0012\u0004\u0012\u00020\u00110^j\u0002`a2\u0006\u0010\\\u001a\u00020\u0001H\u0002¢\u0006\u0004\bt\u0010uJ\u000f\u0010w\u001a\u00020/H\u0010¢\u0006\u0004\bv\u00101J\u001f\u0010x\u001a\u00020\u00112\u0006\u0010\b\u001a\u00020\u00072\u0006\u0010 \u001a\u00020\rH\u0002¢\u0006\u0004\bx\u0010yJ.\u0010{\u001a\u00020\u0011\"\n\b\u0000\u0010z\u0018\u0001*\u00020\t2\u0006\u0010\b\u001a\u00020\u00072\b\u0010 \u001a\u0004\u0018\u00010\rH\u0082\b¢\u0006\u0004\b{\u0010yJ\u0019\u0010\\\u001a\u00020\u00112\b\u0010 \u001a\u0004\u0018\u00010\rH\u0014¢\u0006\u0004\b\\\u0010+J\u0019\u0010|\u001a\u00020\u00112\b\u0010\u0014\u001a\u0004\u0018\u00010\u0005H\u0014¢\u0006\u0004\b|\u0010\u0016J\u000f\u0010}\u001a\u00020\u0011H\u0014¢\u0006\u0004\b}\u0010~J\u0019\u0010\u0081\u0001\u001a\u00020\u00112\u0007\u0010\u0080\u0001\u001a\u00020\u007f¢\u0006\u0006\b\u0081\u0001\u0010\u0082\u0001J\u001b\u0010\u0084\u0001\u001a\u00020\u00112\u0007\u0010\u0014\u001a\u00030\u0083\u0001H\u0002¢\u0006\u0006\b\u0084\u0001\u0010\u0085\u0001J\u001a\u0010\u0086\u0001\u001a\u00020\u00112\u0006\u0010\u0014\u001a\u00020\tH\u0002¢\u0006\u0006\b\u0086\u0001\u0010\u0087\u0001JI\u0010\u008c\u0001\u001a\u00020\u0011\"\u0005\b\u0000\u0010\u0088\u00012\u000e\u0010\u008a\u0001\u001a\t\u0012\u0004\u0012\u00028\u00000\u0089\u00012\u001d\u0010k\u001a\u0019\b\u0001\u0012\u000b\u0012\t\u0012\u0004\u0012\u00028\u00000\u008b\u0001\u0012\u0006\u0012\u0004\u0018\u00010\u00050^ø\u0001\u0000¢\u0006\u0006\b\u008c\u0001\u0010\u008d\u0001JX\u0010\u0091\u0001\u001a\u00020\u0011\"\u0004\b\u0000\u0010z\"\u0005\b\u0001\u0010\u0088\u00012\u000e\u0010\u008a\u0001\u001a\t\u0012\u0004\u0012\u00028\u00010\u0089\u00012$\u0010k\u001a \b\u0001\u0012\u0004\u0012\u00028\u0000\u0012\u000b\u0012\t\u0012\u0004\u0012\u00028\u00010\u008b\u0001\u0012\u0006\u0012\u0004\u0018\u00010\u00050\u008e\u0001H\u0000ø\u0001\u0000¢\u0006\u0006\b\u008f\u0001\u0010\u0090\u0001J\u001a\u0010\u0093\u0001\u001a\u00020\u00112\u0006\u0010\n\u001a\u00020\tH\u0000¢\u0006\u0006\b\u0092\u0001\u0010\u0087\u0001JX\u0010\u0095\u0001\u001a\u00020\u0011\"\u0004\b\u0000\u0010z\"\u0005\b\u0001\u0010\u0088\u00012\u000e\u0010\u008a\u0001\u001a\t\u0012\u0004\u0012\u00028\u00010\u0089\u00012$\u0010k\u001a \b\u0001\u0012\u0004\u0012\u00028\u0000\u0012\u000b\u0012\t\u0012\u0004\u0012\u00028\u00010\u008b\u0001\u0012\u0006\u0012\u0004\u0018\u00010\u00050\u008e\u0001H\u0000ø\u0001\u0000¢\u0006\u0006\b\u0094\u0001\u0010\u0090\u0001J\u000f\u0010\u0096\u0001\u001a\u00020\u0001¢\u0006\u0005\b\u0096\u0001\u0010iJ\u001d\u0010\u0098\u0001\u001a\u00030\u0097\u00012\b\u0010\u0014\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0006\b\u0098\u0001\u0010\u0099\u0001J\u001c\u0010\u009a\u0001\u001a\u00020/2\b\u0010\u0014\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0006\b\u009a\u0001\u0010\u009b\u0001J\u0011\u0010\u009c\u0001\u001a\u00020/H\u0007¢\u0006\u0005\b\u009c\u0001\u00101J\u0011\u0010\u009d\u0001\u001a\u00020/H\u0016¢\u0006\u0005\b\u009d\u0001\u00101J$\u0010\u009e\u0001\u001a\u00020\u00012\u0006\u0010\u0014\u001a\u0002032\b\u00104\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0006\b\u009e\u0001\u0010\u009f\u0001J\"\u0010 \u0001\u001a\u00020\u00012\u0006\u0010\u0014\u001a\u0002032\u0006\u0010\u000e\u001a\u00020\rH\u0002¢\u0006\u0006\b \u0001\u0010¡\u0001J(\u0010¢\u0001\u001a\u0004\u0018\u00010\u00052\b\u0010\u0014\u001a\u0004\u0018\u00010\u00052\b\u0010:\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0006\b¢\u0001\u0010£\u0001J&\u0010¤\u0001\u001a\u0004\u0018\u00010\u00052\u0006\u0010\u0014\u001a\u0002032\b\u0010:\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0006\b¤\u0001\u0010¥\u0001J-\u0010¦\u0001\u001a\u00020\u00012\u0006\u0010\u0014\u001a\u0002072\u0006\u0010\u0018\u001a\u0002082\b\u0010:\u001a\u0004\u0018\u00010\u0005H\u0082\u0010¢\u0006\u0006\b¦\u0001\u0010§\u0001J\u0019\u0010©\u0001\u001a\u0004\u0018\u000108*\u00030¨\u0001H\u0002¢\u0006\u0006\b©\u0001\u0010ª\u0001J\u001f\u0010«\u0001\u001a\u00020\u0011*\u00020\u00072\b\u0010 \u001a\u0004\u0018\u00010\rH\u0002¢\u0006\u0005\b«\u0001\u0010yJ&\u0010¬\u0001\u001a\u00060#j\u0002`$*\u00020\r2\n\b\u0002\u0010?\u001a\u0004\u0018\u00010/H\u0004¢\u0006\u0006\b¬\u0001\u0010\u00ad\u0001R\u001b\u0010±\u0001\u001a\t\u0012\u0004\u0012\u00020X0®\u00018F¢\u0006\b\u001a\u0006\b¯\u0001\u0010°\u0001R\u0018\u0010³\u0001\u001a\u0004\u0018\u00010\r8DX\u0084\u0004¢\u0006\u0007\u001a\u0005\b²\u0001\u0010OR\u0016\u0010µ\u0001\u001a\u00020\u00018DX\u0084\u0004¢\u0006\u0007\u001a\u0005\b´\u0001\u0010iR\u0016\u0010·\u0001\u001a\u00020\u00018PX\u0090\u0004¢\u0006\u0007\u001a\u0005\b¶\u0001\u0010iR\u0016\u0010¸\u0001\u001a\u00020\u00018VX\u0096\u0004¢\u0006\u0007\u001a\u0005\b¸\u0001\u0010iR\u0013\u0010¹\u0001\u001a\u00020\u00018F¢\u0006\u0007\u001a\u0005\b¹\u0001\u0010iR\u0013\u0010º\u0001\u001a\u00020\u00018F¢\u0006\u0007\u001a\u0005\bº\u0001\u0010iR\u0013\u0010»\u0001\u001a\u00020\u00018F¢\u0006\u0007\u001a\u0005\b»\u0001\u0010iR\u0016\u0010¼\u0001\u001a\u00020\u00018TX\u0094\u0004¢\u0006\u0007\u001a\u0005\b¼\u0001\u0010iR\u0019\u0010À\u0001\u001a\u0007\u0012\u0002\b\u00030½\u00018F¢\u0006\b\u001a\u0006\b¾\u0001\u0010¿\u0001R\u0016\u0010Â\u0001\u001a\u00020\u00018PX\u0090\u0004¢\u0006\u0007\u001a\u0005\bÁ\u0001\u0010iR\u0015\u0010Æ\u0001\u001a\u00030Ã\u00018F¢\u0006\b\u001a\u0006\bÄ\u0001\u0010Å\u0001R.\u0010Ì\u0001\u001a\u0004\u0018\u00010\u00192\t\u0010Ç\u0001\u001a\u0004\u0018\u00010\u00198@@@X\u0080\u000e¢\u0006\u0010\u001a\u0006\bÈ\u0001\u0010É\u0001\"\u0006\bÊ\u0001\u0010Ë\u0001R\u0017\u0010\u0014\u001a\u0004\u0018\u00010\u00058@X\u0080\u0004¢\u0006\u0007\u001a\u0005\bÍ\u0001\u0010LR\u001e\u0010Ï\u0001\u001a\u0004\u0018\u00010\r*\u0004\u0018\u00010\u00058BX\u0082\u0004¢\u0006\u0007\u001a\u0005\bÎ\u0001\u0010>R\u001b\u0010Ð\u0001\u001a\u00020\u0001*\u0002038BX\u0082\u0004¢\u0006\b\u001a\u0006\bÐ\u0001\u0010Ñ\u0001\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006Õ\u0001"}, d2 = {"Lkotlinx/coroutines/JobSupport;", "", "active", "", "(Z)V", "", "expect", "Lkotlinx/coroutines/NodeList;", "list", "Lkotlinx/coroutines/JobNode;", "node", "addLastAtomic", "(Ljava/lang/Object;Lkotlinx/coroutines/NodeList;Lkotlinx/coroutines/JobNode;)Z", "", "rootCause", "", "exceptions", "", "addSuppressedExceptions", "(Ljava/lang/Throwable;Ljava/util/List;)V", "state", "afterCompletion", "(Ljava/lang/Object;)V", "Lkotlinx/coroutines/ChildJob;", "child", "Lkotlinx/coroutines/ChildHandle;", "attachChild", "(Lkotlinx/coroutines/ChildJob;)Lkotlinx/coroutines/ChildHandle;", "awaitInternal$kotlinx_coroutines_core", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "awaitInternal", "awaitSuspend", "cause", "cancel", "(Ljava/lang/Throwable;)Z", "Ljava/util/concurrent/CancellationException;", "Lkotlinx/coroutines/CancellationException;", "(Ljava/util/concurrent/CancellationException;)V", "cancelCoroutine", "cancelImpl$kotlinx_coroutines_core", "(Ljava/lang/Object;)Z", "cancelImpl", "cancelInternal", "(Ljava/lang/Throwable;)V", "cancelMakeCompleting", "(Ljava/lang/Object;)Ljava/lang/Object;", "cancelParent", "", "cancellationExceptionMessage", "()Ljava/lang/String;", "childCancelled", "Lkotlinx/coroutines/Incomplete;", "update", "completeStateFinalization", "(Lkotlinx/coroutines/Incomplete;Ljava/lang/Object;)V", "Lkotlinx/coroutines/JobSupport$Finishing;", "Lkotlinx/coroutines/ChildHandleNode;", "lastChild", "proposedUpdate", "continueCompleting", "(Lkotlinx/coroutines/JobSupport$Finishing;Lkotlinx/coroutines/ChildHandleNode;Ljava/lang/Object;)V", "createCauseException", "(Ljava/lang/Object;)Ljava/lang/Throwable;", Task.TaskColumns.MESSAGE, "Lkotlinx/coroutines/JobCancellationException;", "defaultCancellationException$kotlinx_coroutines_core", "(Ljava/lang/String;Ljava/lang/Throwable;)Lkotlinx/coroutines/JobCancellationException;", "defaultCancellationException", "finalizeFinishingState", "(Lkotlinx/coroutines/JobSupport$Finishing;Ljava/lang/Object;)Ljava/lang/Object;", "firstChild", "(Lkotlinx/coroutines/Incomplete;)Lkotlinx/coroutines/ChildHandleNode;", "getCancellationException", "()Ljava/util/concurrent/CancellationException;", "getChildJobCancellationCause", "getCompletedInternal$kotlinx_coroutines_core", "()Ljava/lang/Object;", "getCompletedInternal", "getCompletionExceptionOrNull", "()Ljava/lang/Throwable;", "getFinalRootCause", "(Lkotlinx/coroutines/JobSupport$Finishing;Ljava/util/List;)Ljava/lang/Throwable;", "getOrPromoteCancellingList", "(Lkotlinx/coroutines/Incomplete;)Lkotlinx/coroutines/NodeList;", "exception", "handleJobException", "handleOnCompletionException$kotlinx_coroutines_core", "handleOnCompletionException", "Lkotlinx/coroutines/Job;", "parent", "initParentJob", "(Lkotlinx/coroutines/Job;)V", "onCancelling", "invokeImmediately", "Lkotlin/Function1;", "Lkotlin/ParameterName;", "name", "Lkotlinx/coroutines/CompletionHandler;", "handler", "Lkotlinx/coroutines/DisposableHandle;", "invokeOnCompletion", "(ZZLkotlin/jvm/functions/Function1;)Lkotlinx/coroutines/DisposableHandle;", "(Lkotlin/jvm/functions/Function1;)Lkotlinx/coroutines/DisposableHandle;", "join", "joinInternal", "()Z", "joinSuspend", "block", "", "loopOnState", "(Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;", "makeCancelling", "makeCompleting$kotlinx_coroutines_core", "makeCompleting", "makeCompletingOnce$kotlinx_coroutines_core", "makeCompletingOnce", "makeNode", "(Lkotlin/jvm/functions/Function1;Z)Lkotlinx/coroutines/JobNode;", "nameString$kotlinx_coroutines_core", "nameString", "notifyCancelling", "(Lkotlinx/coroutines/NodeList;Ljava/lang/Throwable;)V", "T", "notifyHandlers", "onCompletionInternal", "onStart", "()V", "Lkotlinx/coroutines/ParentJob;", "parentJob", "parentCancelled", "(Lkotlinx/coroutines/ParentJob;)V", "Lkotlinx/coroutines/Empty;", "promoteEmptyToNodeList", "(Lkotlinx/coroutines/Empty;)V", "promoteSingleToNodeList", "(Lkotlinx/coroutines/JobNode;)V", "R", "Lkotlinx/coroutines/selects/SelectInstance;", "select", "Lkotlin/coroutines/Continuation;", "registerSelectClause0", "(Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/functions/Function1;)V", "Lkotlin/Function2;", "registerSelectClause1Internal$kotlinx_coroutines_core", "(Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/functions/Function2;)V", "registerSelectClause1Internal", "removeNode$kotlinx_coroutines_core", "removeNode", "selectAwaitCompletion$kotlinx_coroutines_core", "selectAwaitCompletion", "start", "", "startInternal", "(Ljava/lang/Object;)I", "stateString", "(Ljava/lang/Object;)Ljava/lang/String;", "toDebugString", "toString", "tryFinalizeSimpleState", "(Lkotlinx/coroutines/Incomplete;Ljava/lang/Object;)Z", "tryMakeCancelling", "(Lkotlinx/coroutines/Incomplete;Ljava/lang/Throwable;)Z", "tryMakeCompleting", "(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;", "tryMakeCompletingSlowPath", "(Lkotlinx/coroutines/Incomplete;Ljava/lang/Object;)Ljava/lang/Object;", "tryWaitForChild", "(Lkotlinx/coroutines/JobSupport$Finishing;Lkotlinx/coroutines/ChildHandleNode;Ljava/lang/Object;)Z", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode;", "nextChild", "(Lkotlinx/coroutines/internal/LockFreeLinkedListNode;)Lkotlinx/coroutines/ChildHandleNode;", "notifyCompletion", "toCancellationException", "(Ljava/lang/Throwable;Ljava/lang/String;)Ljava/util/concurrent/CancellationException;", "Lkotlin/sequences/Sequence;", "getChildren", "()Lkotlin/sequences/Sequence;", "children", "getCompletionCause", "completionCause", "getCompletionCauseHandled", "completionCauseHandled", "getHandlesException$kotlinx_coroutines_core", "handlesException", "isActive", "isCancelled", "isCompleted", "isCompletedExceptionally", "isScopedCoroutine", "Lkotlin/coroutines/CoroutineContext$Key;", "getKey", "()Lkotlin/coroutines/CoroutineContext$Key;", "key", "getOnCancelComplete$kotlinx_coroutines_core", "onCancelComplete", "Lkotlinx/coroutines/selects/SelectClause0;", "getOnJoin", "()Lkotlinx/coroutines/selects/SelectClause0;", "onJoin", "value", "getParentHandle$kotlinx_coroutines_core", "()Lkotlinx/coroutines/ChildHandle;", "setParentHandle$kotlinx_coroutines_core", "(Lkotlinx/coroutines/ChildHandle;)V", "parentHandle", "getState$kotlinx_coroutines_core", "getExceptionOrNull", "exceptionOrNull", "isCancelling", "(Lkotlinx/coroutines/Incomplete;)Z", "AwaitContinuation", "ChildCompletion", "Finishing", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) public class JobSupport implements Job, ChildJob, ParentJob, SelectClause0 { private static final /* synthetic */ AtomicReferenceFieldUpdater _state$FU = AtomicReferenceFieldUpdater.newUpdater(JobSupport.class, Object.class, "_state"); private volatile /* synthetic */ Object _parentHandle; private volatile /* synthetic */ Object _state; protected void afterCompletion(Object state) { } /* JADX INFO: renamed from: getHandlesException$kotlinx_coroutines_core */ public boolean getHandlesException() { return true; } public boolean getOnCancelComplete$kotlinx_coroutines_core() { return false; } protected boolean handleJobException(Throwable exception) { return false; } protected boolean isScopedCoroutine() { return false; } protected void onCancelling(Throwable cause) { } protected void onCompletionInternal(Object state) { } protected void onStart() { } public JobSupport(boolean z) { this._state = z ? JobSupportKt.EMPTY_ACTIVE : JobSupportKt.EMPTY_NEW; this._parentHandle = null; } @Override // kotlinx.coroutines.Job @Deprecated(level = DeprecationLevel.HIDDEN, message = "Since 1.2.0, binary compatibility with versions <= 1.1.x") public /* synthetic */ void cancel() { cancel((CancellationException) null); } @Override // kotlin.coroutines.CoroutineContext.Element, kotlin.coroutines.CoroutineContext public R fold(R r, Function2 function2) { return (R) Job.DefaultImpls.fold(this, r, function2); } @Override // kotlin.coroutines.CoroutineContext.Element, kotlin.coroutines.CoroutineContext public E get(CoroutineContext.Key key) { return (E) Job.DefaultImpls.get(this, key); } @Override // kotlin.coroutines.CoroutineContext.Element, kotlin.coroutines.CoroutineContext public CoroutineContext minusKey(CoroutineContext.Key key) { return Job.DefaultImpls.minusKey(this, key); } @Override // kotlin.coroutines.CoroutineContext public CoroutineContext plus(CoroutineContext coroutineContext) { return Job.DefaultImpls.plus(this, coroutineContext); } @Override // kotlinx.coroutines.Job @Deprecated(level = DeprecationLevel.ERROR, message = "Operator '+' on two Job objects is meaningless. Job is a coroutine context element and `+` is a set-sum operator for coroutine contexts. The job to the right of `+` just replaces the job the left of `+`.") public Job plus(Job job) { return Job.DefaultImpls.plus((Job) this, job); } @Override // kotlin.coroutines.CoroutineContext.Element public final CoroutineContext.Key getKey() { return Job.INSTANCE; } public final ChildHandle getParentHandle$kotlinx_coroutines_core() { return (ChildHandle) this._parentHandle; } public final void setParentHandle$kotlinx_coroutines_core(ChildHandle childHandle) { this._parentHandle = childHandle; } protected final void initParentJob(Job parent) { if (DebugKt.getASSERTIONS_ENABLED() && getParentHandle$kotlinx_coroutines_core() != null) { throw new AssertionError(); } if (parent == null) { setParentHandle$kotlinx_coroutines_core(NonDisposableHandle.INSTANCE); return; } parent.start(); ChildHandle childHandleAttachChild = parent.attachChild(this); setParentHandle$kotlinx_coroutines_core(childHandleAttachChild); if (isCompleted()) { childHandleAttachChild.dispose(); setParentHandle$kotlinx_coroutines_core(NonDisposableHandle.INSTANCE); } } private final Void loopOnState(Function1 block) { while (true) { block.invoke(getState$kotlinx_coroutines_core()); } } @Override // kotlinx.coroutines.Job public boolean isActive() { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); return (state$kotlinx_coroutines_core instanceof Incomplete) && ((Incomplete) state$kotlinx_coroutines_core).getIsActive(); } @Override // kotlinx.coroutines.Job public final boolean isCompleted() { return !(getState$kotlinx_coroutines_core() instanceof Incomplete); } @Override // kotlinx.coroutines.Job public final boolean isCancelled() { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); return (state$kotlinx_coroutines_core instanceof CompletedExceptionally) || ((state$kotlinx_coroutines_core instanceof Finishing) && ((Finishing) state$kotlinx_coroutines_core).isCancelling()); } private final Object finalizeFinishingState(Finishing state, Object proposedUpdate) throws Throwable { boolean zIsCancelling; Throwable finalRootCause; if (DebugKt.getASSERTIONS_ENABLED() && getState$kotlinx_coroutines_core() != state) { throw new AssertionError(); } if (DebugKt.getASSERTIONS_ENABLED() && state.isSealed()) { throw new AssertionError(); } if (DebugKt.getASSERTIONS_ENABLED() && !state.isCompleting()) { throw new AssertionError(); } CompletedExceptionally completedExceptionally = proposedUpdate instanceof CompletedExceptionally ? (CompletedExceptionally) proposedUpdate : null; Throwable th = completedExceptionally != null ? completedExceptionally.cause : null; synchronized (state) { zIsCancelling = state.isCancelling(); List listSealLocked = state.sealLocked(th); finalRootCause = getFinalRootCause(state, listSealLocked); if (finalRootCause != null) { addSuppressedExceptions(finalRootCause, listSealLocked); } } if (finalRootCause != null && finalRootCause != th) { proposedUpdate = new CompletedExceptionally(finalRootCause, false, 2, null); } if (finalRootCause != null && (cancelParent(finalRootCause) || handleJobException(finalRootCause))) { if (proposedUpdate == null) { throw new NullPointerException("null cannot be cast to non-null type kotlinx.coroutines.CompletedExceptionally"); } ((CompletedExceptionally) proposedUpdate).makeHandled(); } if (!zIsCancelling) { onCancelling(finalRootCause); } onCompletionInternal(proposedUpdate); boolean zM = AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, JobSupportKt.boxIncomplete(proposedUpdate)); if (DebugKt.getASSERTIONS_ENABLED() && !zM) { throw new AssertionError(); } completeStateFinalization(state, proposedUpdate); return proposedUpdate; } private final Throwable getFinalRootCause(Finishing state, List exceptions) { Object next; Object obj = null; if (exceptions.isEmpty()) { if (state.isCancelling()) { return new JobCancellationException(cancellationExceptionMessage(), null, this); } return null; } List list = exceptions; Iterator it = list.iterator(); while (true) { if (!it.hasNext()) { next = null; break; } next = it.next(); if (!(((Throwable) next) instanceof CancellationException)) { break; } } Throwable th = (Throwable) next; if (th != null) { return th; } Throwable th2 = exceptions.get(0); if (th2 instanceof TimeoutCancellationException) { Iterator it2 = list.iterator(); while (true) { if (!it2.hasNext()) { break; } Object next2 = it2.next(); Throwable th3 = (Throwable) next2; if (th3 != th2 && (th3 instanceof TimeoutCancellationException)) { obj = next2; break; } } Throwable th4 = (Throwable) obj; if (th4 != null) { return th4; } } return th2; } private final void addSuppressedExceptions(Throwable rootCause, List exceptions) { if (exceptions.size() <= 1) { return; } Set setNewSetFromMap = Collections.newSetFromMap(new IdentityHashMap(exceptions.size())); Throwable thUnwrapImpl = !DebugKt.getRECOVER_STACK_TRACES() ? rootCause : StackTraceRecoveryKt.unwrapImpl(rootCause); for (Throwable thUnwrapImpl2 : exceptions) { if (DebugKt.getRECOVER_STACK_TRACES()) { thUnwrapImpl2 = StackTraceRecoveryKt.unwrapImpl(thUnwrapImpl2); } if (thUnwrapImpl2 != rootCause && thUnwrapImpl2 != thUnwrapImpl && !(thUnwrapImpl2 instanceof CancellationException) && setNewSetFromMap.add(thUnwrapImpl2)) { kotlin.ExceptionsKt.addSuppressed(rootCause, thUnwrapImpl2); } } } private final boolean tryFinalizeSimpleState(Incomplete state, Object update) throws Throwable { if (DebugKt.getASSERTIONS_ENABLED() && !(state instanceof Empty) && !(state instanceof JobNode)) { throw new AssertionError(); } if (DebugKt.getASSERTIONS_ENABLED() && (update instanceof CompletedExceptionally)) { throw new AssertionError(); } if (!AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, JobSupportKt.boxIncomplete(update))) { return false; } onCancelling(null); onCompletionInternal(update); completeStateFinalization(state, update); return true; } private final void completeStateFinalization(Incomplete state, Object update) throws Throwable { ChildHandle parentHandle$kotlinx_coroutines_core = getParentHandle$kotlinx_coroutines_core(); if (parentHandle$kotlinx_coroutines_core != null) { parentHandle$kotlinx_coroutines_core.dispose(); setParentHandle$kotlinx_coroutines_core(NonDisposableHandle.INSTANCE); } CompletedExceptionally completedExceptionally = update instanceof CompletedExceptionally ? (CompletedExceptionally) update : null; Throwable th = completedExceptionally != null ? completedExceptionally.cause : null; if (state instanceof JobNode) { try { ((JobNode) state).invoke(th); return; } catch (Throwable th2) { handleOnCompletionException$kotlinx_coroutines_core(new CompletionHandlerException("Exception in completion handler " + state + " for " + this, th2)); return; } } NodeList list = state.getList(); if (list != null) { notifyCompletion(list, th); } } /* JADX WARN: Removed duplicated region for block: B:15:0x0028 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ private final void notifyCancelling(kotlinx.coroutines.NodeList r7, java.lang.Throwable r8) throws java.lang.Throwable { /* r6 = this; r6.onCancelling(r8) kotlinx.coroutines.internal.LockFreeLinkedListHead r7 = (kotlinx.coroutines.internal.LockFreeLinkedListHead) r7 java.lang.Object r0 = r7.getNext() kotlinx.coroutines.internal.LockFreeLinkedListNode r0 = (kotlinx.coroutines.internal.LockFreeLinkedListNode) r0 r1 = 0 Lc: boolean r2 = kotlin.jvm.internal.Intrinsics.areEqual(r0, r7) if (r2 != 0) goto L4d boolean r2 = r0 instanceof kotlinx.coroutines.JobCancellingNode if (r2 == 0) goto L48 r2 = r0 kotlinx.coroutines.JobNode r2 = (kotlinx.coroutines.JobNode) r2 r2.invoke(r8) // Catch: java.lang.Throwable -> L1d goto L48 L1d: r3 = move-exception r4 = r1 java.lang.Throwable r4 = (java.lang.Throwable) r4 if (r4 == 0) goto L28 kotlin.ExceptionsKt.addSuppressed(r4, r3) if (r4 != 0) goto L48 L28: kotlinx.coroutines.CompletionHandlerException r1 = new kotlinx.coroutines.CompletionHandlerException java.lang.StringBuilder r4 = new java.lang.StringBuilder java.lang.String r5 = "Exception in completion handler " r4.(r5) java.lang.StringBuilder r2 = r4.append(r2) java.lang.String r4 = " for " java.lang.StringBuilder r2 = r2.append(r4) java.lang.StringBuilder r2 = r2.append(r6) java.lang.String r2 = r2.toString() r1.(r2, r3) kotlin.Unit r2 = kotlin.Unit.INSTANCE L48: kotlinx.coroutines.internal.LockFreeLinkedListNode r0 = r0.getNextNode() goto Lc L4d: java.lang.Throwable r1 = (java.lang.Throwable) r1 if (r1 == 0) goto L54 r6.handleOnCompletionException$kotlinx_coroutines_core(r1) L54: r6.cancelParent(r8) return */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.JobSupport.notifyCancelling(kotlinx.coroutines.NodeList, java.lang.Throwable):void"); } private final boolean cancelParent(Throwable cause) { if (isScopedCoroutine()) { return true; } boolean z = cause instanceof CancellationException; ChildHandle parentHandle$kotlinx_coroutines_core = getParentHandle$kotlinx_coroutines_core(); return (parentHandle$kotlinx_coroutines_core == null || parentHandle$kotlinx_coroutines_core == NonDisposableHandle.INSTANCE) ? z : parentHandle$kotlinx_coroutines_core.childCancelled(cause) || z; } /* JADX WARN: Removed duplicated region for block: B:15:0x002e */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ private final /* synthetic */ void notifyHandlers(kotlinx.coroutines.NodeList r7, java.lang.Throwable r8) throws java.lang.Throwable { /* r6 = this; kotlinx.coroutines.internal.LockFreeLinkedListHead r7 = (kotlinx.coroutines.internal.LockFreeLinkedListHead) r7 java.lang.Object r0 = r7.getNext() kotlinx.coroutines.internal.LockFreeLinkedListNode r0 = (kotlinx.coroutines.internal.LockFreeLinkedListNode) r0 r1 = 0 L9: boolean r2 = kotlin.jvm.internal.Intrinsics.areEqual(r0, r7) if (r2 != 0) goto L56 r2 = 3 java.lang.String r3 = "T" kotlin.jvm.internal.Intrinsics.reifiedOperationMarker(r2, r3) boolean r2 = r0 instanceof kotlinx.coroutines.internal.LockFreeLinkedListNode if (r2 == 0) goto L51 r2 = r0 kotlinx.coroutines.JobNode r2 = (kotlinx.coroutines.JobNode) r2 r2.invoke(r8) // Catch: java.lang.Throwable -> L20 goto L51 L20: r3 = move-exception r4 = r1 java.lang.Throwable r4 = (java.lang.Throwable) r4 if (r4 == 0) goto L2e r5 = r4 java.lang.Throwable r5 = (java.lang.Throwable) r5 kotlin.ExceptionsKt.addSuppressed(r4, r3) if (r4 != 0) goto L51 L2e: r1 = r6 kotlinx.coroutines.JobSupport r1 = (kotlinx.coroutines.JobSupport) r1 kotlinx.coroutines.CompletionHandlerException r1 = new kotlinx.coroutines.CompletionHandlerException java.lang.StringBuilder r4 = new java.lang.StringBuilder java.lang.String r5 = "Exception in completion handler " r4.(r5) java.lang.StringBuilder r2 = r4.append(r2) java.lang.String r4 = " for " java.lang.StringBuilder r2 = r2.append(r4) java.lang.StringBuilder r2 = r2.append(r6) java.lang.String r2 = r2.toString() r1.(r2, r3) kotlin.Unit r2 = kotlin.Unit.INSTANCE L51: kotlinx.coroutines.internal.LockFreeLinkedListNode r0 = r0.getNextNode() goto L9 L56: java.lang.Throwable r1 = (java.lang.Throwable) r1 if (r1 == 0) goto L60 r7 = r1 java.lang.Throwable r7 = (java.lang.Throwable) r7 r6.handleOnCompletionException$kotlinx_coroutines_core(r1) L60: return */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.JobSupport.notifyHandlers(kotlinx.coroutines.NodeList, java.lang.Throwable):void"); } private final int startInternal(Object state) { if (state instanceof Empty) { if (((Empty) state).getIsActive()) { return 0; } if (!AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, JobSupportKt.EMPTY_ACTIVE)) { return -1; } onStart(); return 1; } if (!(state instanceof InactiveNodeList)) { return 0; } if (!AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, ((InactiveNodeList) state).getList())) { return -1; } onStart(); return 1; } @Override // kotlinx.coroutines.Job public final CancellationException getCancellationException() { CancellationException cancellationException; Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (!(state$kotlinx_coroutines_core instanceof Finishing)) { if (state$kotlinx_coroutines_core instanceof Incomplete) { throw new IllegalStateException(("Job is still new or active: " + this).toString()); } return state$kotlinx_coroutines_core instanceof CompletedExceptionally ? toCancellationException$default(this, ((CompletedExceptionally) state$kotlinx_coroutines_core).cause, null, 1, null) : new JobCancellationException(DebugStringsKt.getClassSimpleName(this) + " has completed normally", null, this); } Throwable rootCause = ((Finishing) state$kotlinx_coroutines_core).getRootCause(); if (rootCause == null || (cancellationException = toCancellationException(rootCause, DebugStringsKt.getClassSimpleName(this) + " is cancelling")) == null) { throw new IllegalStateException(("Job is still new or active: " + this).toString()); } return cancellationException; } public static /* synthetic */ CancellationException toCancellationException$default(JobSupport jobSupport, Throwable th, String str, int i, Object obj) { if (obj != null) { throw new UnsupportedOperationException("Super calls with default arguments not supported in this target, function: toCancellationException"); } if ((i & 1) != 0) { str = null; } return jobSupport.toCancellationException(th, str); } protected final CancellationException toCancellationException(Throwable th, String str) { CancellationException cancellationException = th instanceof CancellationException ? (CancellationException) th : null; if (cancellationException != null) { return cancellationException; } if (str == null) { str = cancellationExceptionMessage(); } return new JobCancellationException(str, th, this); } protected final Throwable getCompletionCause() { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (state$kotlinx_coroutines_core instanceof Finishing) { Throwable rootCause = ((Finishing) state$kotlinx_coroutines_core).getRootCause(); if (rootCause != null) { return rootCause; } throw new IllegalStateException(("Job is still new or active: " + this).toString()); } if (state$kotlinx_coroutines_core instanceof Incomplete) { throw new IllegalStateException(("Job is still new or active: " + this).toString()); } if (state$kotlinx_coroutines_core instanceof CompletedExceptionally) { return ((CompletedExceptionally) state$kotlinx_coroutines_core).cause; } return null; } protected final boolean getCompletionCauseHandled() { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); return (state$kotlinx_coroutines_core instanceof CompletedExceptionally) && ((CompletedExceptionally) state$kotlinx_coroutines_core).getHandled(); } @Override // kotlinx.coroutines.Job public final DisposableHandle invokeOnCompletion(Function1 handler) { return invokeOnCompletion(false, true, handler); } @Override // kotlinx.coroutines.Job public final DisposableHandle invokeOnCompletion(boolean onCancelling, boolean invokeImmediately, Function1 handler) { JobNode jobNodeMakeNode = makeNode(handler, onCancelling); while (true) { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (state$kotlinx_coroutines_core instanceof Empty) { Empty empty = (Empty) state$kotlinx_coroutines_core; if (empty.getIsActive()) { if (AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state$kotlinx_coroutines_core, jobNodeMakeNode)) { return jobNodeMakeNode; } } else { promoteEmptyToNodeList(empty); } } else { if (state$kotlinx_coroutines_core instanceof Incomplete) { NodeList list = ((Incomplete) state$kotlinx_coroutines_core).getList(); if (list != null) { DisposableHandle disposableHandle = NonDisposableHandle.INSTANCE; if (onCancelling && (state$kotlinx_coroutines_core instanceof Finishing)) { synchronized (state$kotlinx_coroutines_core) { rootCause = ((Finishing) state$kotlinx_coroutines_core).getRootCause(); if (rootCause == null || ((handler instanceof ChildHandleNode) && !((Finishing) state$kotlinx_coroutines_core).isCompleting())) { if (addLastAtomic(state$kotlinx_coroutines_core, list, jobNodeMakeNode)) { if (rootCause == null) { return jobNodeMakeNode; } disposableHandle = jobNodeMakeNode; } } Unit unit = Unit.INSTANCE; } } if (rootCause != null) { if (invokeImmediately) { handler.invoke(rootCause); } return disposableHandle; } if (addLastAtomic(state$kotlinx_coroutines_core, list, jobNodeMakeNode)) { return jobNodeMakeNode; } } else { if (state$kotlinx_coroutines_core == null) { throw new NullPointerException("null cannot be cast to non-null type kotlinx.coroutines.JobNode"); } promoteSingleToNodeList((JobNode) state$kotlinx_coroutines_core); } } else { if (invokeImmediately) { CompletedExceptionally completedExceptionally = state$kotlinx_coroutines_core instanceof CompletedExceptionally ? (CompletedExceptionally) state$kotlinx_coroutines_core : null; handler.invoke(completedExceptionally != null ? completedExceptionally.cause : null); } return NonDisposableHandle.INSTANCE; } } } } private final JobNode makeNode(Function1 handler, boolean onCancelling) { InvokeOnCompletion invokeOnCompletion; if (onCancelling) { invokeOnCompletion = handler instanceof JobCancellingNode ? (JobCancellingNode) handler : null; if (invokeOnCompletion == null) { invokeOnCompletion = new InvokeOnCancelling(handler); } invokeOnCompletion = invokeOnCompletion; } else { invokeOnCompletion = handler instanceof JobNode ? (JobNode) handler : null; if (invokeOnCompletion != null) { if (DebugKt.getASSERTIONS_ENABLED() && (invokeOnCompletion instanceof JobCancellingNode)) { throw new AssertionError(); } } else { invokeOnCompletion = new InvokeOnCompletion(handler); } } invokeOnCompletion.setJob(this); return invokeOnCompletion; } private final boolean addLastAtomic(final Object expect, NodeList list, JobNode node) { int iTryCondAddNext; NodeList nodeList = list; final JobNode jobNode = node; LockFreeLinkedListNode.CondAddOp condAddOp = new LockFreeLinkedListNode.CondAddOp(jobNode) { // from class: kotlinx.coroutines.JobSupport$addLastAtomic$$inlined$addLastIf$1 @Override // kotlinx.coroutines.internal.AtomicOp public Object prepare(LockFreeLinkedListNode affected) { if (this.getState$kotlinx_coroutines_core() == expect) { return null; } return LockFreeLinkedListKt.getCONDITION_FALSE(); } }; do { iTryCondAddNext = nodeList.getPrevNode().tryCondAddNext(jobNode, nodeList, condAddOp); if (iTryCondAddNext == 1) { return true; } } while (iTryCondAddNext != 2); return false; } private final void promoteEmptyToNodeList(Empty state) { NodeList nodeList = new NodeList(); AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, state.getIsActive() ? nodeList : new InactiveNodeList(nodeList)); } private final void promoteSingleToNodeList(JobNode state) { state.addOneIfEmpty(new NodeList()); AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, state.getNextNode()); } @Override // kotlinx.coroutines.Job public final Object join(Continuation continuation) { if (!joinInternal()) { JobKt.ensureActive(continuation.getContext()); return Unit.INSTANCE; } Object objJoinSuspend = joinSuspend(continuation); return objJoinSuspend == IntrinsicsKt.getCOROUTINE_SUSPENDED() ? objJoinSuspend : Unit.INSTANCE; } @Override // kotlinx.coroutines.Job public final SelectClause0 getOnJoin() { return this; } /* JADX INFO: Access modifiers changed from: protected */ public String cancellationExceptionMessage() { return "Job was cancelled"; } @Override // kotlinx.coroutines.Job @Deprecated(level = DeprecationLevel.HIDDEN, message = "Added since 1.2.0 for binary compatibility with versions <= 1.1.x") public /* synthetic */ boolean cancel(Throwable cause) throws Throwable { JobCancellationException jobCancellationException; if (cause == null || (jobCancellationException = toCancellationException$default(this, cause, null, 1, null)) == null) { jobCancellationException = new JobCancellationException(cancellationExceptionMessage(), null, this); } cancelInternal(jobCancellationException); return true; } public void cancelInternal(Throwable cause) throws Throwable { cancelImpl$kotlinx_coroutines_core(cause); } @Override // kotlinx.coroutines.ChildJob public final void parentCancelled(ParentJob parentJob) throws Throwable { cancelImpl$kotlinx_coroutines_core(parentJob); } public boolean childCancelled(Throwable cause) { if (cause instanceof CancellationException) { return true; } return cancelImpl$kotlinx_coroutines_core(cause) && getHandlesException(); } public final boolean cancelCoroutine(Throwable cause) { return cancelImpl$kotlinx_coroutines_core(cause); } public final boolean cancelImpl$kotlinx_coroutines_core(Object cause) throws Throwable { Object objMakeCancelling = JobSupportKt.COMPLETING_ALREADY; if (getOnCancelComplete$kotlinx_coroutines_core() && (objMakeCancelling = cancelMakeCompleting(cause)) == JobSupportKt.COMPLETING_WAITING_CHILDREN) { return true; } if (objMakeCancelling == JobSupportKt.COMPLETING_ALREADY) { objMakeCancelling = makeCancelling(cause); } if (objMakeCancelling == JobSupportKt.COMPLETING_ALREADY || objMakeCancelling == JobSupportKt.COMPLETING_WAITING_CHILDREN) { return true; } if (objMakeCancelling == JobSupportKt.TOO_LATE_TO_CANCEL) { return false; } afterCompletion(objMakeCancelling); return true; } public static /* synthetic */ JobCancellationException defaultCancellationException$kotlinx_coroutines_core$default(JobSupport jobSupport, String str, Throwable th, int i, Object obj) { if (obj != null) { throw new UnsupportedOperationException("Super calls with default arguments not supported in this target, function: defaultCancellationException"); } if ((i & 1) != 0) { str = null; } if ((i & 2) != 0) { th = null; } if (str == null) { str = jobSupport.cancellationExceptionMessage(); } return new JobCancellationException(str, th, jobSupport); } public final JobCancellationException defaultCancellationException$kotlinx_coroutines_core(String message, Throwable cause) { if (message == null) { message = cancellationExceptionMessage(); } return new JobCancellationException(message, cause, this); } @Override // kotlinx.coroutines.ParentJob public CancellationException getChildJobCancellationCause() { Throwable rootCause; Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (state$kotlinx_coroutines_core instanceof Finishing) { rootCause = ((Finishing) state$kotlinx_coroutines_core).getRootCause(); } else if (state$kotlinx_coroutines_core instanceof CompletedExceptionally) { rootCause = ((CompletedExceptionally) state$kotlinx_coroutines_core).cause; } else { if (state$kotlinx_coroutines_core instanceof Incomplete) { throw new IllegalStateException(("Cannot be cancelling child in this state: " + state$kotlinx_coroutines_core).toString()); } rootCause = null; } CancellationException cancellationException = rootCause instanceof CancellationException ? (CancellationException) rootCause : null; return cancellationException == null ? new JobCancellationException("Parent job is " + stateString(state$kotlinx_coroutines_core), rootCause, this) : cancellationException; } private final Throwable createCauseException(Object cause) { if (cause == null ? true : cause instanceof Throwable) { Throwable th = (Throwable) cause; return th == null ? new JobCancellationException(cancellationExceptionMessage(), null, this) : th; } if (cause != null) { return ((ParentJob) cause).getChildJobCancellationCause(); } throw new NullPointerException("null cannot be cast to non-null type kotlinx.coroutines.ParentJob"); } private final NodeList getOrPromoteCancellingList(Incomplete state) { NodeList list = state.getList(); if (list != null) { return list; } if (state instanceof Empty) { return new NodeList(); } if (state instanceof JobNode) { promoteSingleToNodeList((JobNode) state); return null; } throw new IllegalStateException(("State should have list: " + state).toString()); } private final boolean tryMakeCancelling(Incomplete state, Throwable rootCause) throws Throwable { if (DebugKt.getASSERTIONS_ENABLED() && (state instanceof Finishing)) { throw new AssertionError(); } if (DebugKt.getASSERTIONS_ENABLED() && !state.getIsActive()) { throw new AssertionError(); } NodeList orPromoteCancellingList = getOrPromoteCancellingList(state); if (orPromoteCancellingList == null) { return false; } if (!AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, new Finishing(orPromoteCancellingList, false, rootCause))) { return false; } notifyCancelling(orPromoteCancellingList, rootCause); return true; } private final Object tryMakeCompleting(Object state, Object proposedUpdate) { if (!(state instanceof Incomplete)) { return JobSupportKt.COMPLETING_ALREADY; } if ((!(state instanceof Empty) && !(state instanceof JobNode)) || (state instanceof ChildHandleNode) || (proposedUpdate instanceof CompletedExceptionally)) { return tryMakeCompletingSlowPath((Incomplete) state, proposedUpdate); } return tryFinalizeSimpleState((Incomplete) state, proposedUpdate) ? proposedUpdate : JobSupportKt.COMPLETING_RETRY; } /* JADX WARN: Multi-variable type inference failed */ private final Object tryMakeCompletingSlowPath(Incomplete state, Object proposedUpdate) throws Throwable { NodeList orPromoteCancellingList = getOrPromoteCancellingList(state); if (orPromoteCancellingList == null) { return JobSupportKt.COMPLETING_RETRY; } Finishing finishing = state instanceof Finishing ? (Finishing) state : null; if (finishing == null) { finishing = new Finishing(orPromoteCancellingList, false, null); } Ref.ObjectRef objectRef = new Ref.ObjectRef(); synchronized (finishing) { if (finishing.isCompleting()) { return JobSupportKt.COMPLETING_ALREADY; } finishing.setCompleting(true); if (finishing != state && !AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state, finishing)) { return JobSupportKt.COMPLETING_RETRY; } if (DebugKt.getASSERTIONS_ENABLED() && finishing.isSealed()) { throw new AssertionError(); } boolean zIsCancelling = finishing.isCancelling(); CompletedExceptionally completedExceptionally = proposedUpdate instanceof CompletedExceptionally ? (CompletedExceptionally) proposedUpdate : null; if (completedExceptionally != null) { finishing.addExceptionLocked(completedExceptionally.cause); } objectRef.element = Boolean.valueOf(true ^ zIsCancelling).booleanValue() ? finishing.getRootCause() : 0; Unit unit = Unit.INSTANCE; Throwable th = (Throwable) objectRef.element; if (th != null) { notifyCancelling(orPromoteCancellingList, th); } ChildHandleNode childHandleNodeFirstChild = firstChild(state); if (childHandleNodeFirstChild != null && tryWaitForChild(finishing, childHandleNodeFirstChild, proposedUpdate)) { return JobSupportKt.COMPLETING_WAITING_CHILDREN; } return finalizeFinishingState(finishing, proposedUpdate); } } private final Throwable getExceptionOrNull(Object obj) { CompletedExceptionally completedExceptionally = obj instanceof CompletedExceptionally ? (CompletedExceptionally) obj : null; if (completedExceptionally != null) { return completedExceptionally.cause; } return null; } private final ChildHandleNode firstChild(Incomplete state) { ChildHandleNode childHandleNode = state instanceof ChildHandleNode ? (ChildHandleNode) state : null; if (childHandleNode != null) { return childHandleNode; } NodeList list = state.getList(); if (list != null) { return nextChild(list); } return null; } private final boolean tryWaitForChild(Finishing state, ChildHandleNode child, Object proposedUpdate) { while (Job.DefaultImpls.invokeOnCompletion$default(child.childJob, false, false, new ChildCompletion(this, state, child, proposedUpdate), 1, null) == NonDisposableHandle.INSTANCE) { child = nextChild(child); if (child == null) { return false; } } return true; } /* JADX INFO: Access modifiers changed from: private */ public final void continueCompleting(Finishing state, ChildHandleNode lastChild, Object proposedUpdate) { if (DebugKt.getASSERTIONS_ENABLED() && getState$kotlinx_coroutines_core() != state) { throw new AssertionError(); } ChildHandleNode childHandleNodeNextChild = nextChild(lastChild); if (childHandleNodeNextChild == null || !tryWaitForChild(state, childHandleNodeNextChild, proposedUpdate)) { afterCompletion(finalizeFinishingState(state, proposedUpdate)); } } private final ChildHandleNode nextChild(LockFreeLinkedListNode lockFreeLinkedListNode) { while (lockFreeLinkedListNode.isRemoved()) { lockFreeLinkedListNode = lockFreeLinkedListNode.getPrevNode(); } while (true) { lockFreeLinkedListNode = lockFreeLinkedListNode.getNextNode(); if (!lockFreeLinkedListNode.isRemoved()) { if (lockFreeLinkedListNode instanceof ChildHandleNode) { return (ChildHandleNode) lockFreeLinkedListNode; } if (lockFreeLinkedListNode instanceof NodeList) { return null; } } } } @Override // kotlinx.coroutines.Job public final Sequence getChildren() { return SequencesKt.sequence(new JobSupport$children$1(this, null)); } @Override // kotlinx.coroutines.Job public final ChildHandle attachChild(ChildJob child) { return (ChildHandle) Job.DefaultImpls.invokeOnCompletion$default(this, true, false, new ChildHandleNode(child), 2, null); } public void handleOnCompletionException$kotlinx_coroutines_core(Throwable exception) throws Throwable { throw exception; } public String toString() { return toDebugString() + '@' + DebugStringsKt.getHexAddress(this); } public final String toDebugString() { return nameString$kotlinx_coroutines_core() + AbstractJsonLexerKt.BEGIN_OBJ + stateString(getState$kotlinx_coroutines_core()) + AbstractJsonLexerKt.END_OBJ; } public String nameString$kotlinx_coroutines_core() { return DebugStringsKt.getClassSimpleName(this); } private final String stateString(Object state) { if (!(state instanceof Finishing)) { return state instanceof Incomplete ? ((Incomplete) state).getIsActive() ? "Active" : "New" : state instanceof CompletedExceptionally ? "Cancelled" : "Completed"; } Finishing finishing = (Finishing) state; return finishing.isCancelling() ? "Cancelling" : finishing.isCompleting() ? "Completing" : "Active"; } /* JADX INFO: compiled from: JobSupport.kt */ @Metadata(d1 = {"\u0000L\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\u0003\n\u0002\b\u0004\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010 \n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0002\b\u0013\n\u0002\u0018\u0002\n\u0002\u0018\u0002\b\u0002\u0018\u00002\u00060\u0018j\u0002`,2\u00020-B!\u0012\u0006\u0010\u0002\u001a\u00020\u0001\u0012\u0006\u0010\u0004\u001a\u00020\u0003\u0012\b\u0010\u0006\u001a\u0004\u0018\u00010\u0005¢\u0006\u0004\b\u0007\u0010\bJ\u0015\u0010\u000b\u001a\u00020\n2\u0006\u0010\t\u001a\u00020\u0005¢\u0006\u0004\b\u000b\u0010\fJ\u001f\u0010\u000f\u001a\u0012\u0012\u0004\u0012\u00020\u00050\rj\b\u0012\u0004\u0012\u00020\u0005`\u000eH\u0002¢\u0006\u0004\b\u000f\u0010\u0010J\u001d\u0010\u0013\u001a\b\u0012\u0004\u0012\u00020\u00050\u00122\b\u0010\u0011\u001a\u0004\u0018\u00010\u0005¢\u0006\u0004\b\u0013\u0010\u0014J\u000f\u0010\u0016\u001a\u00020\u0015H\u0016¢\u0006\u0004\b\u0016\u0010\u0017R(\u0010\u001e\u001a\u0004\u0018\u00010\u00182\b\u0010\u0019\u001a\u0004\u0018\u00010\u00188B@BX\u0082\u000e¢\u0006\f\u001a\u0004\b\u001a\u0010\u001b\"\u0004\b\u001c\u0010\u001dR\u0014\u0010\u001f\u001a\u00020\u00038VX\u0096\u0004¢\u0006\u0006\u001a\u0004\b\u001f\u0010 R\u0011\u0010!\u001a\u00020\u00038F¢\u0006\u0006\u001a\u0004\b!\u0010 R$\u0010\u0004\u001a\u00020\u00032\u0006\u0010\u0019\u001a\u00020\u00038F@FX\u0086\u000e¢\u0006\f\u001a\u0004\b\u0004\u0010 \"\u0004\b\"\u0010#R\u0011\u0010$\u001a\u00020\u00038F¢\u0006\u0006\u001a\u0004\b$\u0010 R\u001a\u0010\u0002\u001a\u00020\u00018\u0016X\u0096\u0004¢\u0006\f\n\u0004\b\u0002\u0010%\u001a\u0004\b&\u0010'R(\u0010\u0006\u001a\u0004\u0018\u00010\u00052\b\u0010\u0019\u001a\u0004\u0018\u00010\u00058F@FX\u0086\u000e¢\u0006\f\u001a\u0004\b(\u0010)\"\u0004\b*\u0010\f¨\u0006+"}, d2 = {"Lkotlinx/coroutines/JobSupport$Finishing;", "Lkotlinx/coroutines/NodeList;", "list", "", "isCompleting", "", "rootCause", "", "(Lkotlinx/coroutines/NodeList;ZLjava/lang/Throwable;)V", "exception", "", "addExceptionLocked", "(Ljava/lang/Throwable;)V", "Ljava/util/ArrayList;", "Lkotlin/collections/ArrayList;", "allocateList", "()Ljava/util/ArrayList;", "proposedException", "", "sealLocked", "(Ljava/lang/Throwable;)Ljava/util/List;", "", "toString", "()Ljava/lang/String;", "", "value", "getExceptionsHolder", "()Ljava/lang/Object;", "setExceptionsHolder", "(Ljava/lang/Object;)V", "exceptionsHolder", "isActive", "()Z", "isCancelling", "setCompleting", "(Z)V", "isSealed", "Lkotlinx/coroutines/NodeList;", "getList", "()Lkotlinx/coroutines/NodeList;", "getRootCause", "()Ljava/lang/Throwable;", "setRootCause", "kotlinx-coroutines-core", "Lkotlinx/coroutines/internal/SynchronizedObject;", "Lkotlinx/coroutines/Incomplete;"}, k = 1, mv = {1, 6, 0}, xi = 48) private static final class Finishing implements Incomplete { private volatile /* synthetic */ Object _exceptionsHolder = null; private volatile /* synthetic */ int _isCompleting; private volatile /* synthetic */ Object _rootCause; private final NodeList list; @Override // kotlinx.coroutines.Incomplete public NodeList getList() { return this.list; } public Finishing(NodeList nodeList, boolean z, Throwable th) { this.list = nodeList; this._isCompleting = z ? 1 : 0; this._rootCause = th; } /* JADX WARN: Type inference failed for: r0v1, types: [boolean, int] */ public final boolean isCompleting() { return this._isCompleting; } public final void setCompleting(boolean z) { this._isCompleting = z ? 1 : 0; } public final Throwable getRootCause() { return (Throwable) this._rootCause; } public final void setRootCause(Throwable th) { this._rootCause = th; } /* JADX INFO: renamed from: getExceptionsHolder, reason: from getter */ private final Object get_exceptionsHolder() { return this._exceptionsHolder; } private final void setExceptionsHolder(Object obj) { this._exceptionsHolder = obj; } public final boolean isSealed() { return get_exceptionsHolder() == JobSupportKt.SEALED; } public final boolean isCancelling() { return getRootCause() != null; } @Override // kotlinx.coroutines.Incomplete /* JADX INFO: renamed from: isActive */ public boolean getIsActive() { return getRootCause() == null; } public final List sealLocked(Throwable proposedException) { ArrayList arrayListAllocateList; Object obj = get_exceptionsHolder(); if (obj == null) { arrayListAllocateList = allocateList(); } else if (obj instanceof Throwable) { ArrayList arrayListAllocateList2 = allocateList(); arrayListAllocateList2.add(obj); arrayListAllocateList = arrayListAllocateList2; } else { if (!(obj instanceof ArrayList)) { throw new IllegalStateException(("State is " + obj).toString()); } arrayListAllocateList = (ArrayList) obj; } Throwable rootCause = getRootCause(); if (rootCause != null) { arrayListAllocateList.add(0, rootCause); } if (proposedException != null && !Intrinsics.areEqual(proposedException, rootCause)) { arrayListAllocateList.add(proposedException); } setExceptionsHolder(JobSupportKt.SEALED); return arrayListAllocateList; } public final void addExceptionLocked(Throwable exception) { Throwable rootCause = getRootCause(); if (rootCause == null) { setRootCause(exception); return; } if (exception == rootCause) { return; } Object obj = get_exceptionsHolder(); if (obj == null) { setExceptionsHolder(exception); return; } if (!(obj instanceof Throwable)) { if (!(obj instanceof ArrayList)) { throw new IllegalStateException(("State is " + obj).toString()); } ((ArrayList) obj).add(exception); } else { if (exception == obj) { return; } ArrayList arrayListAllocateList = allocateList(); arrayListAllocateList.add(obj); arrayListAllocateList.add(exception); setExceptionsHolder(arrayListAllocateList); } } private final ArrayList allocateList() { return new ArrayList<>(4); } public String toString() { return "Finishing[cancelling=" + isCancelling() + ", completing=" + isCompleting() + ", rootCause=" + getRootCause() + ", exceptions=" + get_exceptionsHolder() + ", list=" + getList() + AbstractJsonLexerKt.END_LIST; } } private final boolean isCancelling(Incomplete incomplete) { return (incomplete instanceof Finishing) && ((Finishing) incomplete).isCancelling(); } /* JADX INFO: compiled from: JobSupport.kt */ @Metadata(d1 = {"\u00000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u0003\n\u0000\b\u0002\u0018\u00002\u00020\u0001B'\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u0012\u0006\u0010\u0006\u001a\u00020\u0007\u0012\b\u0010\b\u001a\u0004\u0018\u00010\t¢\u0006\u0002\u0010\nJ\u0013\u0010\u000b\u001a\u00020\f2\b\u0010\r\u001a\u0004\u0018\u00010\u000eH\u0096\u0002R\u000e\u0010\u0006\u001a\u00020\u0007X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004¢\u0006\u0002\n\u0000R\u0010\u0010\b\u001a\u0004\u0018\u00010\tX\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0004\u001a\u00020\u0005X\u0082\u0004¢\u0006\u0002\n\u0000¨\u0006\u000f"}, d2 = {"Lkotlinx/coroutines/JobSupport$ChildCompletion;", "Lkotlinx/coroutines/JobNode;", "parent", "Lkotlinx/coroutines/JobSupport;", "state", "Lkotlinx/coroutines/JobSupport$Finishing;", "child", "Lkotlinx/coroutines/ChildHandleNode;", "proposedUpdate", "", "(Lkotlinx/coroutines/JobSupport;Lkotlinx/coroutines/JobSupport$Finishing;Lkotlinx/coroutines/ChildHandleNode;Ljava/lang/Object;)V", "invoke", "", "cause", "", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) private static final class ChildCompletion extends JobNode { private final ChildHandleNode child; private final JobSupport parent; private final Object proposedUpdate; private final Finishing state; @Override // kotlin.jvm.functions.Function1 public /* bridge */ /* synthetic */ Unit invoke(Throwable th) { invoke2(th); return Unit.INSTANCE; } public ChildCompletion(JobSupport jobSupport, Finishing finishing, ChildHandleNode childHandleNode, Object obj) { this.parent = jobSupport; this.state = finishing; this.child = childHandleNode; this.proposedUpdate = obj; } @Override // kotlinx.coroutines.CompletionHandlerBase /* JADX INFO: renamed from: invoke, reason: avoid collision after fix types in other method */ public void invoke2(Throwable cause) { this.parent.continueCompleting(this.state, this.child, this.proposedUpdate); } } /* JADX INFO: compiled from: JobSupport.kt */ @Metadata(d1 = {"\u0000,\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\u0010\u0003\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\b\u0002\u0018\u0000*\u0004\b\u0000\u0010\u00012\b\u0012\u0004\u0012\u0002H\u00010\u0002B\u001b\u0012\f\u0010\u0003\u001a\b\u0012\u0004\u0012\u00028\u00000\u0004\u0012\u0006\u0010\u0005\u001a\u00020\u0006¢\u0006\u0002\u0010\u0007J\u0010\u0010\b\u001a\u00020\t2\u0006\u0010\n\u001a\u00020\u000bH\u0016J\b\u0010\f\u001a\u00020\rH\u0014R\u000e\u0010\u0005\u001a\u00020\u0006X\u0082\u0004¢\u0006\u0002\n\u0000¨\u0006\u000e"}, d2 = {"Lkotlinx/coroutines/JobSupport$AwaitContinuation;", "T", "Lkotlinx/coroutines/CancellableContinuationImpl;", "delegate", "Lkotlin/coroutines/Continuation;", "job", "Lkotlinx/coroutines/JobSupport;", "(Lkotlin/coroutines/Continuation;Lkotlinx/coroutines/JobSupport;)V", "getContinuationCancellationCause", "", "parent", "Lkotlinx/coroutines/Job;", "nameString", "", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) private static final class AwaitContinuation extends CancellableContinuationImpl { private final JobSupport job; public AwaitContinuation(Continuation continuation, JobSupport jobSupport) { super(continuation, 1); this.job = jobSupport; } @Override // kotlinx.coroutines.CancellableContinuationImpl public Throwable getContinuationCancellationCause(Job parent) { Throwable rootCause; Object state$kotlinx_coroutines_core = this.job.getState$kotlinx_coroutines_core(); return (!(state$kotlinx_coroutines_core instanceof Finishing) || (rootCause = ((Finishing) state$kotlinx_coroutines_core).getRootCause()) == null) ? state$kotlinx_coroutines_core instanceof CompletedExceptionally ? ((CompletedExceptionally) state$kotlinx_coroutines_core).cause : parent.getCancellationException() : rootCause; } @Override // kotlinx.coroutines.CancellableContinuationImpl protected String nameString() { return "AwaitContinuation"; } } public final boolean isCompletedExceptionally() { return getState$kotlinx_coroutines_core() instanceof CompletedExceptionally; } public final Throwable getCompletionExceptionOrNull() { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (state$kotlinx_coroutines_core instanceof Incomplete) { throw new IllegalStateException("This job has not completed yet".toString()); } return getExceptionOrNull(state$kotlinx_coroutines_core); } public final Object getCompletedInternal$kotlinx_coroutines_core() throws Throwable { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (state$kotlinx_coroutines_core instanceof Incomplete) { throw new IllegalStateException("This job has not completed yet".toString()); } if (state$kotlinx_coroutines_core instanceof CompletedExceptionally) { throw ((CompletedExceptionally) state$kotlinx_coroutines_core).cause; } return JobSupportKt.unboxState(state$kotlinx_coroutines_core); } public final Object awaitInternal$kotlinx_coroutines_core(Continuation continuation) throws Throwable { Object state$kotlinx_coroutines_core; do { state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (!(state$kotlinx_coroutines_core instanceof Incomplete)) { if (state$kotlinx_coroutines_core instanceof CompletedExceptionally) { Throwable th = ((CompletedExceptionally) state$kotlinx_coroutines_core).cause; if (DebugKt.getRECOVER_STACK_TRACES() && (continuation instanceof CoroutineStackFrame)) { throw StackTraceRecoveryKt.recoverFromStackFrame(th, (CoroutineStackFrame) continuation); } throw th; } return JobSupportKt.unboxState(state$kotlinx_coroutines_core); } } while (startInternal(state$kotlinx_coroutines_core) < 0); return awaitSuspend(continuation); } /* JADX INFO: Access modifiers changed from: private */ public final Object awaitSuspend(Continuation continuation) { AwaitContinuation awaitContinuation = new AwaitContinuation(IntrinsicsKt.intercepted(continuation), this); awaitContinuation.initCancellability(); CancellableContinuationKt.disposeOnCancellation(awaitContinuation, invokeOnCompletion(new ResumeAwaitOnCompletion(awaitContinuation))); Object result = awaitContinuation.getResult(); if (result == IntrinsicsKt.getCOROUTINE_SUSPENDED()) { DebugProbesKt.probeCoroutineSuspended(continuation); } return result; } public final void selectAwaitCompletion$kotlinx_coroutines_core(SelectInstance select, Function2, ? extends Object> block) throws Throwable { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (state$kotlinx_coroutines_core instanceof CompletedExceptionally) { select.resumeSelectWithException(((CompletedExceptionally) state$kotlinx_coroutines_core).cause); } else { CancellableKt.startCoroutineCancellable$default(block, JobSupportKt.unboxState(state$kotlinx_coroutines_core), select.getCompletion(), null, 4, null); } } public final Object getState$kotlinx_coroutines_core() { while (true) { Object obj = this._state; if (!(obj instanceof OpDescriptor)) { return obj; } ((OpDescriptor) obj).perform(this); } } /* JADX WARN: Removed duplicated region for block: B:15:0x0025 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ private final void notifyCompletion(kotlinx.coroutines.NodeList r7, java.lang.Throwable r8) throws java.lang.Throwable { /* r6 = this; kotlinx.coroutines.internal.LockFreeLinkedListHead r7 = (kotlinx.coroutines.internal.LockFreeLinkedListHead) r7 java.lang.Object r0 = r7.getNext() kotlinx.coroutines.internal.LockFreeLinkedListNode r0 = (kotlinx.coroutines.internal.LockFreeLinkedListNode) r0 r1 = 0 L9: boolean r2 = kotlin.jvm.internal.Intrinsics.areEqual(r0, r7) if (r2 != 0) goto L4a boolean r2 = r0 instanceof kotlinx.coroutines.JobNode if (r2 == 0) goto L45 r2 = r0 kotlinx.coroutines.JobNode r2 = (kotlinx.coroutines.JobNode) r2 r2.invoke(r8) // Catch: java.lang.Throwable -> L1a goto L45 L1a: r3 = move-exception r4 = r1 java.lang.Throwable r4 = (java.lang.Throwable) r4 if (r4 == 0) goto L25 kotlin.ExceptionsKt.addSuppressed(r4, r3) if (r4 != 0) goto L45 L25: kotlinx.coroutines.CompletionHandlerException r1 = new kotlinx.coroutines.CompletionHandlerException java.lang.StringBuilder r4 = new java.lang.StringBuilder java.lang.String r5 = "Exception in completion handler " r4.(r5) java.lang.StringBuilder r2 = r4.append(r2) java.lang.String r4 = " for " java.lang.StringBuilder r2 = r2.append(r4) java.lang.StringBuilder r2 = r2.append(r6) java.lang.String r2 = r2.toString() r1.(r2, r3) kotlin.Unit r2 = kotlin.Unit.INSTANCE L45: kotlinx.coroutines.internal.LockFreeLinkedListNode r0 = r0.getNextNode() goto L9 L4a: java.lang.Throwable r1 = (java.lang.Throwable) r1 if (r1 == 0) goto L51 r6.handleOnCompletionException$kotlinx_coroutines_core(r1) L51: return */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.JobSupport.notifyCompletion(kotlinx.coroutines.NodeList, java.lang.Throwable):void"); } @Override // kotlinx.coroutines.Job public final boolean start() { int iStartInternal; do { iStartInternal = startInternal(getState$kotlinx_coroutines_core()); if (iStartInternal == 0) { return false; } } while (iStartInternal != 1); return true; } private final boolean joinInternal() { Object state$kotlinx_coroutines_core; do { state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (!(state$kotlinx_coroutines_core instanceof Incomplete)) { return false; } } while (startInternal(state$kotlinx_coroutines_core) < 0); return true; } /* JADX INFO: Access modifiers changed from: private */ public final Object joinSuspend(Continuation continuation) { CancellableContinuationImpl cancellableContinuationImpl = new CancellableContinuationImpl(IntrinsicsKt.intercepted(continuation), 1); cancellableContinuationImpl.initCancellability(); CancellableContinuationImpl cancellableContinuationImpl2 = cancellableContinuationImpl; CancellableContinuationKt.disposeOnCancellation(cancellableContinuationImpl2, invokeOnCompletion(new ResumeOnCompletion(cancellableContinuationImpl2))); Object result = cancellableContinuationImpl.getResult(); if (result == IntrinsicsKt.getCOROUTINE_SUSPENDED()) { DebugProbesKt.probeCoroutineSuspended(continuation); } return result == IntrinsicsKt.getCOROUTINE_SUSPENDED() ? result : Unit.INSTANCE; } @Override // kotlinx.coroutines.selects.SelectClause0 public final void registerSelectClause0(SelectInstance select, Function1, ? extends Object> block) { Object state$kotlinx_coroutines_core; do { state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (select.isSelected()) { return; } if (!(state$kotlinx_coroutines_core instanceof Incomplete)) { if (select.trySelect()) { UndispatchedKt.startCoroutineUnintercepted(block, select.getCompletion()); return; } return; } } while (startInternal(state$kotlinx_coroutines_core) != 0); select.disposeOnSelect(invokeOnCompletion(new SelectJoinOnCompletion(select, block))); } public final void removeNode$kotlinx_coroutines_core(JobNode node) { Object state$kotlinx_coroutines_core; do { state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (!(state$kotlinx_coroutines_core instanceof JobNode)) { if (!(state$kotlinx_coroutines_core instanceof Incomplete) || ((Incomplete) state$kotlinx_coroutines_core).getList() == null) { return; } node.mo1770remove(); return; } if (state$kotlinx_coroutines_core != node) { return; } } while (!AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_state$FU, this, state$kotlinx_coroutines_core, JobSupportKt.EMPTY_ACTIVE)); } @Override // kotlinx.coroutines.Job public void cancel(CancellationException cause) throws Throwable { if (cause == null) { cause = new JobCancellationException(cancellationExceptionMessage(), null, this); } cancelInternal(cause); } private final Object cancelMakeCompleting(Object cause) { Object objTryMakeCompleting; do { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (!(state$kotlinx_coroutines_core instanceof Incomplete) || ((state$kotlinx_coroutines_core instanceof Finishing) && ((Finishing) state$kotlinx_coroutines_core).isCompleting())) { return JobSupportKt.COMPLETING_ALREADY; } objTryMakeCompleting = tryMakeCompleting(state$kotlinx_coroutines_core, new CompletedExceptionally(createCauseException(cause), false, 2, null)); } while (objTryMakeCompleting == JobSupportKt.COMPLETING_RETRY); return objTryMakeCompleting; } private final Object makeCancelling(Object cause) throws Throwable { Throwable thCreateCauseException = null; while (true) { Object state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (!(state$kotlinx_coroutines_core instanceof Finishing)) { if (!(state$kotlinx_coroutines_core instanceof Incomplete)) { return JobSupportKt.TOO_LATE_TO_CANCEL; } if (thCreateCauseException == null) { thCreateCauseException = createCauseException(cause); } Incomplete incomplete = (Incomplete) state$kotlinx_coroutines_core; if (incomplete.getIsActive()) { if (tryMakeCancelling(incomplete, thCreateCauseException)) { return JobSupportKt.COMPLETING_ALREADY; } } else { Object objTryMakeCompleting = tryMakeCompleting(state$kotlinx_coroutines_core, new CompletedExceptionally(thCreateCauseException, false, 2, null)); if (objTryMakeCompleting != JobSupportKt.COMPLETING_ALREADY) { if (objTryMakeCompleting != JobSupportKt.COMPLETING_RETRY) { return objTryMakeCompleting; } } else { throw new IllegalStateException(("Cannot happen in " + state$kotlinx_coroutines_core).toString()); } } } else { synchronized (state$kotlinx_coroutines_core) { if (((Finishing) state$kotlinx_coroutines_core).isSealed()) { return JobSupportKt.TOO_LATE_TO_CANCEL; } boolean zIsCancelling = ((Finishing) state$kotlinx_coroutines_core).isCancelling(); if (cause != null || !zIsCancelling) { if (thCreateCauseException == null) { thCreateCauseException = createCauseException(cause); } ((Finishing) state$kotlinx_coroutines_core).addExceptionLocked(thCreateCauseException); } Throwable rootCause = zIsCancelling ? null : ((Finishing) state$kotlinx_coroutines_core).getRootCause(); if (rootCause != null) { notifyCancelling(((Finishing) state$kotlinx_coroutines_core).getList(), rootCause); } return JobSupportKt.COMPLETING_ALREADY; } } } } public final boolean makeCompleting$kotlinx_coroutines_core(Object proposedUpdate) { Object objTryMakeCompleting; do { objTryMakeCompleting = tryMakeCompleting(getState$kotlinx_coroutines_core(), proposedUpdate); if (objTryMakeCompleting == JobSupportKt.COMPLETING_ALREADY) { return false; } if (objTryMakeCompleting == JobSupportKt.COMPLETING_WAITING_CHILDREN) { return true; } } while (objTryMakeCompleting == JobSupportKt.COMPLETING_RETRY); afterCompletion(objTryMakeCompleting); return true; } public final Object makeCompletingOnce$kotlinx_coroutines_core(Object proposedUpdate) { Object objTryMakeCompleting; do { objTryMakeCompleting = tryMakeCompleting(getState$kotlinx_coroutines_core(), proposedUpdate); if (objTryMakeCompleting == JobSupportKt.COMPLETING_ALREADY) { throw new IllegalStateException("Job " + this + " is already complete or completing, but is being completed with " + proposedUpdate, getExceptionOrNull(proposedUpdate)); } } while (objTryMakeCompleting == JobSupportKt.COMPLETING_RETRY); return objTryMakeCompleting; } public final void registerSelectClause1Internal$kotlinx_coroutines_core(SelectInstance select, Function2, ? extends Object> block) { Object state$kotlinx_coroutines_core; do { state$kotlinx_coroutines_core = getState$kotlinx_coroutines_core(); if (select.isSelected()) { return; } if (!(state$kotlinx_coroutines_core instanceof Incomplete)) { if (select.trySelect()) { if (state$kotlinx_coroutines_core instanceof CompletedExceptionally) { select.resumeSelectWithException(((CompletedExceptionally) state$kotlinx_coroutines_core).cause); return; } else { UndispatchedKt.startCoroutineUnintercepted(block, JobSupportKt.unboxState(state$kotlinx_coroutines_core), select.getCompletion()); return; } } return; } } while (startInternal(state$kotlinx_coroutines_core) != 0); select.disposeOnSelect(invokeOnCompletion(new SelectAwaitOnCompletion(select, block))); } }