package kotlinx.coroutines.flow; import com.cvte.vman.instance.InvokeCmd; import kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.DebugMetadata; import kotlin.jvm.functions.Function4; /* JADX INFO: Add missing generic type declarations: [T] */ /* JADX INFO: compiled from: SafeCollector.common.kt */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000\u0019\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002*\u0001\u0000\b\n\u0018\u00002\b\u0012\u0004\u0012\u00028\u00000\u0001J\u001f\u0010\u0002\u001a\u00020\u00032\f\u0010\u0004\u001a\b\u0012\u0004\u0012\u00028\u00000\u0005H\u0096@ø\u0001\u0000¢\u0006\u0002\u0010\u0006\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u0007¸\u0006\u0000"}, d2 = {"kotlinx/coroutines/flow/internal/SafeCollector_commonKt$unsafeFlow$1", "Lkotlinx/coroutines/flow/Flow;", "collect", "", "collector", "Lkotlinx/coroutines/flow/FlowCollector;", "(Lkotlinx/coroutines/flow/FlowCollector;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) public final class FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1 implements Flow { final /* synthetic */ Function4 $predicate$inlined; final /* synthetic */ Flow $this_retryWhen$inlined; /* JADX INFO: renamed from: kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1$1, reason: invalid class name */ /* JADX INFO: compiled from: SafeCollector.common.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1", f = "Errors.kt", i = {0, 0, 0, 0, 1, 1, 1, 1}, l = {InvokeCmd.CMD_SYSTEMCTRL_CANCEL_GPU_PERFORMANCE, InvokeCmd.CMD_SYSTEMCTRL_GET_UI_RT_APPS}, m = "collect", n = {"this", "$this$retryWhen_u24lambda_u2d2", "attempt", "shallRetry", "this", "$this$retryWhen_u24lambda_u2d2", "cause", "attempt"}, s = {"L$0", "L$1", "J$0", "I$0", "L$0", "L$1", "L$2", "J$0"}) public static final class AnonymousClass1 extends ContinuationImpl { int I$0; long J$0; Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; public AnonymousClass1(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1.this.collect(null, this); } } /* JADX WARN: Removed duplicated region for block: B:19:0x0078 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:20:0x0079 */ /* JADX WARN: Removed duplicated region for block: B:23:0x0081 */ /* JADX WARN: Removed duplicated region for block: B:29:0x00ab */ /* JADX WARN: Removed duplicated region for block: B:30:0x00b0 */ /* JADX WARN: Removed duplicated region for block: B:33:0x00b7 */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:22:0x007f -> B:31:0x00b1). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:26:0x00a0 -> B:27:0x00a3). Please report as a decompilation issue!!! */ @Override // kotlinx.coroutines.flow.Flow /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public java.lang.Object collect(kotlinx.coroutines.flow.FlowCollector r13, kotlin.coroutines.Continuation r14) throws java.lang.Throwable { /* r12 = this; boolean r0 = r14 instanceof kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1.AnonymousClass1 if (r0 == 0) goto L14 r0 = r14 kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1$1 r0 = (kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1.AnonymousClass1) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r14 = r0.label int r14 = r14 - r2 r0.label = r14 goto L19 L14: kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1$1 r0 = new kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1$1 r0.(r14) L19: java.lang.Object r14 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 2 r4 = 1 if (r2 == 0) goto L5a if (r2 == r4) goto L44 if (r2 != r3) goto L3c long r12 = r0.J$0 java.lang.Object r2 = r0.L$2 java.lang.Throwable r2 = (java.lang.Throwable) r2 java.lang.Object r5 = r0.L$1 kotlinx.coroutines.flow.FlowCollector r5 = (kotlinx.coroutines.flow.FlowCollector) r5 java.lang.Object r6 = r0.L$0 kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1 r6 = (kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1) r6 kotlin.ResultKt.throwOnFailure(r14) goto La3 L3c: java.lang.IllegalStateException r12 = new java.lang.IllegalStateException java.lang.String r13 = "call to 'resume' before 'invoke' with coroutine" r12.(r13) throw r12 L44: int r12 = r0.I$0 long r5 = r0.J$0 java.lang.Object r13 = r0.L$1 kotlinx.coroutines.flow.FlowCollector r13 = (kotlinx.coroutines.flow.FlowCollector) r13 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1 r2 = (kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1) r2 kotlin.ResultKt.throwOnFailure(r14) r9 = r2 r2 = r12 r10 = r5 r5 = r13 r6 = r9 r12 = r10 goto L7d L5a: kotlin.ResultKt.throwOnFailure(r14) r14 = r0 kotlin.coroutines.Continuation r14 = (kotlin.coroutines.Continuation) r14 r5 = 0 L62: kotlinx.coroutines.flow.Flow r14 = r12.$this_retryWhen$inlined r0.L$0 = r12 r0.L$1 = r13 r2 = 0 r0.L$2 = r2 r0.J$0 = r5 r2 = 0 r0.I$0 = r2 r0.label = r4 java.lang.Object r14 = kotlinx.coroutines.flow.FlowKt.catchImpl(r14, r13, r0) if (r14 != r1) goto L79 return r1 L79: r9 = r5 r6 = r12 r5 = r13 r12 = r9 L7d: java.lang.Throwable r14 = (java.lang.Throwable) r14 if (r14 == 0) goto Lb1 kotlin.jvm.functions.Function4 r2 = r6.$predicate$inlined java.lang.Long r7 = kotlin.coroutines.jvm.internal.Boxing.boxLong(r12) r0.L$0 = r6 r0.L$1 = r5 r0.L$2 = r14 r0.J$0 = r12 r0.label = r3 r8 = 6 kotlin.jvm.internal.InlineMarker.mark(r8) java.lang.Object r2 = r2.invoke(r5, r14, r7, r0) r7 = 7 kotlin.jvm.internal.InlineMarker.mark(r7) if (r2 != r1) goto La0 return r1 La0: r9 = r2 r2 = r14 r14 = r9 La3: java.lang.Boolean r14 = (java.lang.Boolean) r14 boolean r14 = r14.booleanValue() if (r14 == 0) goto Lb0 r7 = 1 long r12 = r12 + r7 r2 = r4 goto Lb1 Lb0: throw r2 Lb1: r9 = r12 r13 = r5 r12 = r6 r5 = r9 if (r2 != 0) goto L62 kotlin.Unit r12 = kotlin.Unit.INSTANCE return r12 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.flow.FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1.collect(kotlinx.coroutines.flow.FlowCollector, kotlin.coroutines.Continuation):java.lang.Object"); } public FlowKt__ErrorsKt$retryWhen$$inlined$unsafeFlow$1(Flow flow, Function4 function4) { this.$this_retryWhen$inlined = flow; this.$predicate$inlined = function4; } }