package kotlinx.coroutines; import kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.ContinuationInterceptor; import kotlin.coroutines.CoroutineContext; import kotlin.coroutines.EmptyCoroutineContext; import kotlin.coroutines.jvm.internal.CoroutineStackFrame; import kotlin.jvm.functions.Function0; import kotlin.jvm.functions.Function2; import kotlin.jvm.internal.InlineMarker; import kotlin.jvm.internal.Ref; import kotlinx.coroutines.internal.ThreadContextKt; /* JADX INFO: compiled from: CoroutineContext.kt */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000>\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\u001a \u0010\u0006\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00032\u0006\u0010\b\u001a\u00020\u00032\u0006\u0010\t\u001a\u00020\nH\u0002\u001a8\u0010\u000b\u001a\u0002H\f\"\u0004\b\u0000\u0010\f2\n\u0010\r\u001a\u0006\u0012\u0002\b\u00030\u000e2\b\u0010\u000f\u001a\u0004\u0018\u00010\u00102\f\u0010\u0011\u001a\b\u0012\u0004\u0012\u0002H\f0\u0012H\u0080\b¢\u0006\u0002\u0010\u0013\u001a4\u0010\u0014\u001a\u0002H\f\"\u0004\b\u0000\u0010\f2\u0006\u0010\u0015\u001a\u00020\u00032\b\u0010\u000f\u001a\u0004\u0018\u00010\u00102\f\u0010\u0011\u001a\b\u0012\u0004\u0012\u0002H\f0\u0012H\u0080\b¢\u0006\u0002\u0010\u0016\u001a\f\u0010\u0017\u001a\u00020\n*\u00020\u0003H\u0002\u001a\u0014\u0010\u0018\u001a\u00020\u0003*\u00020\u00032\u0006\u0010\u0019\u001a\u00020\u0003H\u0007\u001a\u0014\u0010\u0018\u001a\u00020\u0003*\u00020\u001a2\u0006\u0010\u0015\u001a\u00020\u0003H\u0007\u001a\u0013\u0010\u001b\u001a\b\u0012\u0002\b\u0003\u0018\u00010\u001c*\u00020\u001dH\u0080\u0010\u001a(\u0010\u001e\u001a\b\u0012\u0002\b\u0003\u0018\u00010\u001c*\u0006\u0012\u0002\b\u00030\u000e2\u0006\u0010\u0015\u001a\u00020\u00032\b\u0010\u001f\u001a\u0004\u0018\u00010\u0010H\u0000\"\u000e\u0010\u0000\u001a\u00020\u0001X\u0082T¢\u0006\u0002\n\u0000\"\u001a\u0010\u0002\u001a\u0004\u0018\u00010\u0001*\u00020\u00038@X\u0080\u0004¢\u0006\u0006\u001a\u0004\b\u0004\u0010\u0005¨\u0006 "}, d2 = {"DEBUG_THREAD_NAME_SEPARATOR", "", "coroutineName", "Lkotlin/coroutines/CoroutineContext;", "getCoroutineName", "(Lkotlin/coroutines/CoroutineContext;)Ljava/lang/String;", "foldCopies", "originalContext", "appendContext", "isNewCoroutine", "", "withContinuationContext", "T", "continuation", "Lkotlin/coroutines/Continuation;", "countOrElement", "", "block", "Lkotlin/Function0;", "(Lkotlin/coroutines/Continuation;Ljava/lang/Object;Lkotlin/jvm/functions/Function0;)Ljava/lang/Object;", "withCoroutineContext", "context", "(Lkotlin/coroutines/CoroutineContext;Ljava/lang/Object;Lkotlin/jvm/functions/Function0;)Ljava/lang/Object;", "hasCopyableElements", "newCoroutineContext", "addedContext", "Lkotlinx/coroutines/CoroutineScope;", "undispatchedCompletion", "Lkotlinx/coroutines/UndispatchedCoroutine;", "Lkotlin/coroutines/jvm/internal/CoroutineStackFrame;", "updateUndispatchedCompletion", "oldValue", "kotlinx-coroutines-core"}, k = 2, mv = {1, 6, 0}, xi = 48) public final class CoroutineContextKt { private static final String DEBUG_THREAD_NAME_SEPARATOR = " @"; public static final CoroutineContext newCoroutineContext(CoroutineScope coroutineScope, CoroutineContext coroutineContext) { CoroutineContext coroutineContextFoldCopies = foldCopies(coroutineScope.getCoroutineContext(), coroutineContext, true); CoroutineContext coroutineContextPlus = DebugKt.getDEBUG() ? coroutineContextFoldCopies.plus(new CoroutineId(DebugKt.getCOROUTINE_ID().incrementAndGet())) : coroutineContextFoldCopies; return (coroutineContextFoldCopies == Dispatchers.getDefault() || coroutineContextFoldCopies.get(ContinuationInterceptor.INSTANCE) != null) ? coroutineContextPlus : coroutineContextPlus.plus(Dispatchers.getDefault()); } public static final CoroutineContext newCoroutineContext(CoroutineContext coroutineContext, CoroutineContext coroutineContext2) { return !hasCopyableElements(coroutineContext2) ? coroutineContext.plus(coroutineContext2) : foldCopies(coroutineContext, coroutineContext2, false); } private static final boolean hasCopyableElements(CoroutineContext coroutineContext) { return ((Boolean) coroutineContext.fold(false, new Function2() { // from class: kotlinx.coroutines.CoroutineContextKt.hasCopyableElements.1 public final Boolean invoke(boolean z, CoroutineContext.Element element) { return Boolean.valueOf(z || (element instanceof CopyableThreadContextElement)); } @Override // kotlin.jvm.functions.Function2 public /* bridge */ /* synthetic */ Boolean invoke(Boolean bool, CoroutineContext.Element element) { return invoke(bool.booleanValue(), element); } })).booleanValue(); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Type inference failed for: r4v6, types: [T, java.lang.Object] */ private static final CoroutineContext foldCopies(CoroutineContext coroutineContext, CoroutineContext coroutineContext2, final boolean z) { boolean zHasCopyableElements = hasCopyableElements(coroutineContext); boolean zHasCopyableElements2 = hasCopyableElements(coroutineContext2); if (!zHasCopyableElements && !zHasCopyableElements2) { return coroutineContext.plus(coroutineContext2); } final Ref.ObjectRef objectRef = new Ref.ObjectRef(); objectRef.element = coroutineContext2; CoroutineContext coroutineContext3 = (CoroutineContext) coroutineContext.fold(EmptyCoroutineContext.INSTANCE, new Function2() { // from class: kotlinx.coroutines.CoroutineContextKt$foldCopies$folded$1 /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ { super(2); } /* JADX WARN: Type inference failed for: r1v3, types: [T, kotlin.coroutines.CoroutineContext] */ @Override // kotlin.jvm.functions.Function2 public final CoroutineContext invoke(CoroutineContext coroutineContext4, CoroutineContext.Element element) { if (!(element instanceof CopyableThreadContextElement)) { return coroutineContext4.plus(element); } CoroutineContext.Element element2 = objectRef.element.get(element.getKey()); if (element2 == null) { return coroutineContext4.plus(z ? ((CopyableThreadContextElement) element).copyForChild() : (CopyableThreadContextElement) element); } Ref.ObjectRef objectRef2 = objectRef; objectRef2.element = objectRef2.element.minusKey(element.getKey()); return coroutineContext4.plus(((CopyableThreadContextElement) element).mergeForChild(element2)); } }); if (zHasCopyableElements2) { objectRef.element = ((CoroutineContext) objectRef.element).fold(EmptyCoroutineContext.INSTANCE, new Function2() { // from class: kotlinx.coroutines.CoroutineContextKt.foldCopies.1 @Override // kotlin.jvm.functions.Function2 public final CoroutineContext invoke(CoroutineContext coroutineContext4, CoroutineContext.Element element) { if (element instanceof CopyableThreadContextElement) { return coroutineContext4.plus(((CopyableThreadContextElement) element).copyForChild()); } return coroutineContext4.plus(element); } }); } return coroutineContext3.plus((CoroutineContext) objectRef.element); } public static final T withCoroutineContext(CoroutineContext coroutineContext, Object obj, Function0 function0) { Object objUpdateThreadContext = ThreadContextKt.updateThreadContext(coroutineContext, obj); try { return function0.invoke(); } finally { InlineMarker.finallyStart(1); ThreadContextKt.restoreThreadContext(coroutineContext, objUpdateThreadContext); InlineMarker.finallyEnd(1); } } /* JADX WARN: Removed duplicated region for block: B:12:0x0025 A[DONT_GENERATE] */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final T withContinuationContext(kotlin.coroutines.Continuation r2, java.lang.Object r3, kotlin.jvm.functions.Function0 r4) { /* kotlin.coroutines.CoroutineContext r0 = r2.getContext() java.lang.Object r3 = kotlinx.coroutines.internal.ThreadContextKt.updateThreadContext(r0, r3) kotlinx.coroutines.internal.Symbol r1 = kotlinx.coroutines.internal.ThreadContextKt.NO_THREAD_ELEMENTS if (r3 == r1) goto L11 kotlinx.coroutines.UndispatchedCoroutine r2 = updateUndispatchedCompletion(r2, r0, r3) goto L15 L11: r2 = 0 r1 = r2 kotlinx.coroutines.UndispatchedCoroutine r1 = (kotlinx.coroutines.UndispatchedCoroutine) r1 L15: r1 = 1 java.lang.Object r4 = r4.invoke() // Catch: java.lang.Throwable -> L2c kotlin.jvm.internal.InlineMarker.finallyStart(r1) if (r2 == 0) goto L25 boolean r2 = r2.clearThreadContext() if (r2 == 0) goto L28 L25: kotlinx.coroutines.internal.ThreadContextKt.restoreThreadContext(r0, r3) L28: kotlin.jvm.internal.InlineMarker.finallyEnd(r1) return r4 L2c: r4 = move-exception kotlin.jvm.internal.InlineMarker.finallyStart(r1) if (r2 == 0) goto L38 boolean r2 = r2.clearThreadContext() if (r2 == 0) goto L3b L38: kotlinx.coroutines.internal.ThreadContextKt.restoreThreadContext(r0, r3) L3b: kotlin.jvm.internal.InlineMarker.finallyEnd(r1) throw r4 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.CoroutineContextKt.withContinuationContext(kotlin.coroutines.Continuation, java.lang.Object, kotlin.jvm.functions.Function0):java.lang.Object"); } public static final UndispatchedCoroutine updateUndispatchedCompletion(Continuation continuation, CoroutineContext coroutineContext, Object obj) { if (!(continuation instanceof CoroutineStackFrame) || coroutineContext.get(UndispatchedMarker.INSTANCE) == null) { return null; } UndispatchedCoroutine undispatchedCoroutineUndispatchedCompletion = undispatchedCompletion((CoroutineStackFrame) continuation); if (undispatchedCoroutineUndispatchedCompletion != null) { undispatchedCoroutineUndispatchedCompletion.saveThreadContext(coroutineContext, obj); } return undispatchedCoroutineUndispatchedCompletion; } public static final UndispatchedCoroutine undispatchedCompletion(CoroutineStackFrame coroutineStackFrame) { while (!(coroutineStackFrame instanceof DispatchedCoroutine) && (coroutineStackFrame = coroutineStackFrame.getCallerFrame()) != null) { if (coroutineStackFrame instanceof UndispatchedCoroutine) { return (UndispatchedCoroutine) coroutineStackFrame; } } return null; } public static final String getCoroutineName(CoroutineContext coroutineContext) { CoroutineId coroutineId; String name; if (!DebugKt.getDEBUG() || (coroutineId = (CoroutineId) coroutineContext.get(CoroutineId.INSTANCE)) == null) { return null; } CoroutineName coroutineName = (CoroutineName) coroutineContext.get(CoroutineName.INSTANCE); if (coroutineName == null || (name = coroutineName.getName()) == null) { name = "coroutine"; } return name + '#' + coroutineId.getId(); } }