package androidx.room;

import java.util.concurrent.locks.ReentrantLock;
import kotlin.Metadata;
import kotlin.NoWhenBranchMatchedException;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.SourceDebugExtension;

/* JADX INFO: loaded from: classes.dex */
@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0001\u001a\u00020\u0000H\n"}, d2 = {"Landroidx/room/v0;", "connection", "Lkd/e;", "<anonymous>"}, k = 3, mv = {2, 0, 0})
@DebugMetadata(c = "androidx.room.TriggerBasedInvalidationTracker$syncTriggers$2$1", f = "InvalidationTracker.kt", i = {0}, l = {301, 309}, m = "invokeSuspend", n = {"connection"}, s = {"L$0"})
final class TriggerBasedInvalidationTracker$syncTriggers$2$1 extends SuspendLambda implements Function2 {
    /* synthetic */ Object L$0;
    int label;
    final /* synthetic */ x0 this$0;

    /* JADX INFO: renamed from: androidx.room.TriggerBasedInvalidationTracker$syncTriggers$2$1$1, reason: invalid class name */
    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\u0010\u0002\u001a\u00020\u0001*\b\u0012\u0004\u0012\u00020\u00010\u0000H\n"}, d2 = {"Landroidx/room/u0;", "Lkd/e;", "<anonymous>"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "androidx.room.TriggerBasedInvalidationTracker$syncTriggers$2$1$1", f = "InvalidationTracker.kt", i = {0, 0, 1, 1}, l = {313, 314}, m = "invokeSuspend", n = {"$this$forEachIndexed$iv", "index$iv", "$this$forEachIndexed$iv", "index$iv"}, s = {"L$0", "I$0", "L$0", "I$0"})
    @SourceDebugExtension({"SMAP\nInvalidationTracker.kt\nKotlin\n*S Kotlin\n*F\n+ 1 InvalidationTracker.kt\nandroidx/room/TriggerBasedInvalidationTracker$syncTriggers$2$1$1\n+ 2 _Arrays.kt\nkotlin/collections/ArraysKt___ArraysKt\n*L\n1#1,604:1\n13467#2,3:605\n*S KotlinDebug\n*F\n+ 1 InvalidationTracker.kt\nandroidx/room/TriggerBasedInvalidationTracker$syncTriggers$2$1$1\n*L\n310#1:605,3\n*E\n"})
    final class AnonymousClass1 extends SuspendLambda implements Function2 {
        final /* synthetic */ v0 $connection;
        final /* synthetic */ ObservedTableStates$ObserveOp[] $tablesToSync;
        int I$0;
        int I$1;
        int I$2;
        Object L$0;
        Object L$1;
        Object L$2;
        int label;
        final /* synthetic */ x0 this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public AnonymousClass1(ObservedTableStates$ObserveOp[] observedTableStates$ObserveOpArr, x0 x0Var, v0 v0Var, Continuation continuation) {
            super(2, continuation);
            this.$tablesToSync = observedTableStates$ObserveOpArr;
            this.this$0 = x0Var;
            this.$connection = v0Var;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation create(Object obj, Continuation continuation) {
            return new AnonymousClass1(this.$tablesToSync, this.this$0, this.$connection, continuation);
        }

        @Override // kotlin.jvm.functions.Function2
        public final Object invoke(Object obj, Object obj2) {
            return ((AnonymousClass1) create((u0) obj, (Continuation) obj2)).invokeSuspend(kd.e.f29109a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:29:0x0064, code lost:
        
            r6 = r13;
            r13 = r5;
            r5 = r10;
         */
        /* JADX WARN: Removed duplicated region for block: B:11:0x003e  */
        /* JADX WARN: Removed duplicated region for block: B:27:0x0087  */
        /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:25:0x0084 -> B:26:0x0085). Please report as a decompilation issue!!! */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            int i10;
            ObservedTableStates$ObserveOp[] observedTableStates$ObserveOpArr;
            x0 x0Var;
            v0 v0Var;
            int i11;
            int i12;
            AnonymousClass1 anonymousClass1;
            CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
            int i13 = this.label;
            if (i13 == 0) {
                kotlin.a.d(obj);
                ObservedTableStates$ObserveOp[] observedTableStates$ObserveOpArr2 = this.$tablesToSync;
                x0 x0Var2 = this.this$0;
                v0 v0Var2 = this.$connection;
                int length = observedTableStates$ObserveOpArr2.length;
                i10 = 0;
                observedTableStates$ObserveOpArr = observedTableStates$ObserveOpArr2;
                x0Var = x0Var2;
                v0Var = v0Var2;
                i11 = length;
                i12 = 0;
                anonymousClass1 = this;
                if (i12 >= i11) {
                }
            } else {
                if (i13 != 1 && i13 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                i11 = this.I$2;
                i12 = this.I$1;
                int i14 = this.I$0;
                v0 v0Var3 = (v0) this.L$2;
                x0Var = (x0) this.L$1;
                observedTableStates$ObserveOpArr = (ObservedTableStates$ObserveOp[]) this.L$0;
                kotlin.a.d(obj);
                AnonymousClass1 anonymousClass12 = this;
                int i15 = i14;
                anonymousClass1 = anonymousClass12;
                v0Var = v0Var3;
                i10 = i15;
                i12++;
                if (i12 >= i11) {
                    int i16 = i10 + 1;
                    int iOrdinal = observedTableStates$ObserveOpArr[i12].ordinal();
                    if (iOrdinal == 0) {
                        i10 = i16;
                        i12++;
                        if (i12 >= i11) {
                            return kd.e.f29109a;
                        }
                    } else {
                        if (iOrdinal == 1) {
                            anonymousClass1.L$0 = observedTableStates$ObserveOpArr;
                            anonymousClass1.L$1 = x0Var;
                            anonymousClass1.L$2 = v0Var;
                            anonymousClass1.I$0 = i16;
                            anonymousClass1.I$1 = i12;
                            anonymousClass1.I$2 = i11;
                            anonymousClass1.label = 1;
                            if (x0.c(x0Var, v0Var, i10, anonymousClass1) == coroutineSingletons) {
                                return coroutineSingletons;
                            }
                            v0Var3 = v0Var;
                            anonymousClass12 = anonymousClass1;
                            i14 = i16;
                        } else {
                            if (iOrdinal != 2) {
                                throw new NoWhenBranchMatchedException();
                            }
                            anonymousClass1.L$0 = observedTableStates$ObserveOpArr;
                            anonymousClass1.L$1 = x0Var;
                            anonymousClass1.L$2 = v0Var;
                            anonymousClass1.I$0 = i16;
                            anonymousClass1.I$1 = i12;
                            anonymousClass1.I$2 = i11;
                            anonymousClass1.label = 2;
                            if (x0.d(x0Var, v0Var, i10, anonymousClass1) == coroutineSingletons) {
                                return coroutineSingletons;
                            }
                            v0Var3 = v0Var;
                            anonymousClass12 = anonymousClass1;
                            i14 = i16;
                        }
                        int i152 = i14;
                        anonymousClass1 = anonymousClass12;
                        v0Var = v0Var3;
                        i10 = i152;
                        i12++;
                        if (i12 >= i11) {
                        }
                    }
                }
            }
        }
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public TriggerBasedInvalidationTracker$syncTriggers$2$1(x0 x0Var, Continuation continuation) {
        super(2, continuation);
        this.this$0 = x0Var;
    }

    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    public final Continuation create(Object obj, Continuation continuation) {
        TriggerBasedInvalidationTracker$syncTriggers$2$1 triggerBasedInvalidationTracker$syncTriggers$2$1 = new TriggerBasedInvalidationTracker$syncTriggers$2$1(this.this$0, continuation);
        triggerBasedInvalidationTracker$syncTriggers$2$1.L$0 = obj;
        return triggerBasedInvalidationTracker$syncTriggers$2$1;
    }

    @Override // kotlin.jvm.functions.Function2
    public final Object invoke(Object obj, Object obj2) {
        return ((TriggerBasedInvalidationTracker$syncTriggers$2$1) create((v0) obj, (Continuation) obj2)).invokeSuspend(kd.e.f29109a);
    }

    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    public final Object invokeSuspend(Object obj) {
        v0 v0Var;
        Object objB;
        ObservedTableStates$ObserveOp[] observedTableStates$ObserveOpArr;
        ObservedTableStates$ObserveOp observedTableStates$ObserveOp;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i10 = this.label;
        kd.e eVar = kd.e.f29109a;
        boolean z10 = true;
        if (i10 == 0) {
            kotlin.a.d(obj);
            v0Var = (v0) this.L$0;
            this.L$0 = v0Var;
            this.label = 1;
            objB = v0Var.b(this);
            if (objB == coroutineSingletons) {
                return coroutineSingletons;
            }
        } else {
            if (i10 != 1) {
                if (i10 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                kotlin.a.d(obj);
                return eVar;
            }
            v0Var = (v0) this.L$0;
            kotlin.a.d(obj);
            objB = obj;
        }
        if (((Boolean) objB).booleanValue()) {
            return eVar;
        }
        x xVar = this.this$0.f4207h;
        ReentrantLock reentrantLock = (ReentrantLock) xVar.f4197c;
        reentrantLock.lock();
        try {
            if (xVar.f4196b) {
                xVar.f4196b = false;
                int length = ((long[]) xVar.f4198d).length;
                observedTableStates$ObserveOpArr = new ObservedTableStates$ObserveOp[length];
                int i11 = 0;
                boolean z11 = false;
                while (i11 < length) {
                    boolean z12 = ((long[]) xVar.f4198d)[i11] > 0 ? z10 : false;
                    Object obj2 = xVar.f4195a;
                    if (z12 != ((boolean[]) obj2)[i11]) {
                        ((boolean[]) obj2)[i11] = z12;
                        observedTableStates$ObserveOp = z12 ? ObservedTableStates$ObserveOp.f3992b : ObservedTableStates$ObserveOp.f3993c;
                        z11 = true;
                    } else {
                        observedTableStates$ObserveOp = ObservedTableStates$ObserveOp.f3991a;
                    }
                    observedTableStates$ObserveOpArr[i11] = observedTableStates$ObserveOp;
                    i11++;
                    z10 = true;
                }
                if (!z11) {
                    observedTableStates$ObserveOpArr = null;
                }
                reentrantLock.unlock();
            } else {
                reentrantLock.unlock();
                observedTableStates$ObserveOpArr = null;
            }
            if (observedTableStates$ObserveOpArr != null) {
                Transactor$SQLiteTransactionType transactor$SQLiteTransactionType = Transactor$SQLiteTransactionType.f4000b;
                AnonymousClass1 anonymousClass1 = new AnonymousClass1(observedTableStates$ObserveOpArr, this.this$0, v0Var, null);
                this.L$0 = null;
                this.label = 2;
                if (v0Var.a(transactor$SQLiteTransactionType, anonymousClass1, this) == coroutineSingletons) {
                    return coroutineSingletons;
                }
            }
            return eVar;
        } catch (Throwable th) {
            reentrantLock.unlock();
            throw th;
        }
    }
}