package androidx.room.coroutines;

import android.database.SQLException;
import androidx.room.Transactor$SQLiteTransactionType;
import androidx.room.v0;
import androidx.room.w0;
import java.util.NoSuchElementException;
import java.util.concurrent.atomic.AtomicBoolean;
import kotlin.NoWhenBranchMatchedException;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlin.jvm.functions.Function2;

/* JADX INFO: loaded from: classes.dex */
public final class k implements v0, l {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final g f4039a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final boolean f4040b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final kotlin.collections.h f4041c = new kotlin.collections.h();

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final AtomicBoolean f4042d = new AtomicBoolean(false);

    public k(g gVar, boolean z10) {
        this.f4039a = gVar;
        this.f4040b = z10;
    }

    @Override // androidx.room.v0
    public final Object a(Transactor$SQLiteTransactionType transactor$SQLiteTransactionType, Function2 function2, Continuation continuation) {
        if (this.f4042d.get()) {
            ua.b.I(21, "Connection is recycled");
            throw null;
        }
        b bVar = (b) continuation.getContext().m(b.f4011b);
        if (bVar != null && bVar.f4012a == this) {
            return g(transactor$SQLiteTransactionType, function2, continuation);
        }
        ua.b.I(21, "Attempted to use connection on a different coroutine");
        throw null;
    }

    @Override // androidx.room.v0
    public final Object b(Continuation continuation) {
        if (this.f4042d.get()) {
            ua.b.I(21, "Connection is recycled");
            throw null;
        }
        b bVar = (b) continuation.getContext().m(b.f4011b);
        if (bVar != null && bVar.f4012a == this) {
            return Boolean.valueOf(!this.f4041c.isEmpty());
        }
        ua.b.I(21, "Attempted to use connection on a different coroutine");
        throw null;
    }

    @Override // androidx.room.coroutines.l
    public final k3.a c() {
        return this.f4039a;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // androidx.room.a0
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object d(String str, w0 w0Var, Continuation continuation) {
        PooledConnectionImpl$usePrepared$1 pooledConnectionImpl$usePrepared$1;
        k kVar;
        kotlinx.coroutines.sync.a aVar;
        sd.l lVar;
        if (continuation instanceof PooledConnectionImpl$usePrepared$1) {
            pooledConnectionImpl$usePrepared$1 = (PooledConnectionImpl$usePrepared$1) continuation;
            int i10 = pooledConnectionImpl$usePrepared$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                pooledConnectionImpl$usePrepared$1.label = i10 - Integer.MIN_VALUE;
            } else {
                pooledConnectionImpl$usePrepared$1 = new PooledConnectionImpl$usePrepared$1(this, continuation);
            }
        }
        Object obj = pooledConnectionImpl$usePrepared$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = pooledConnectionImpl$usePrepared$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj);
            if (this.f4042d.get()) {
                ua.b.I(21, "Connection is recycled");
                throw null;
            }
            b bVar = (b) pooledConnectionImpl$usePrepared$1.getContext().m(b.f4011b);
            if (bVar == null || bVar.f4012a != this) {
                ua.b.I(21, "Attempted to use connection on a different coroutine");
                throw null;
            }
            pooledConnectionImpl$usePrepared$1.L$0 = this;
            pooledConnectionImpl$usePrepared$1.L$1 = str;
            pooledConnectionImpl$usePrepared$1.L$2 = w0Var;
            g gVar = this.f4039a;
            pooledConnectionImpl$usePrepared$1.L$3 = gVar;
            pooledConnectionImpl$usePrepared$1.label = 1;
            if (gVar.f4024b.e(pooledConnectionImpl$usePrepared$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
            kVar = this;
            lVar = w0Var;
            aVar = gVar;
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            kotlinx.coroutines.sync.a aVar2 = (kotlinx.coroutines.sync.a) pooledConnectionImpl$usePrepared$1.L$3;
            sd.l lVar2 = (sd.l) pooledConnectionImpl$usePrepared$1.L$2;
            String str2 = (String) pooledConnectionImpl$usePrepared$1.L$1;
            kVar = (k) pooledConnectionImpl$usePrepared$1.L$0;
            kotlin.a.d(obj);
            aVar = aVar2;
            str = str2;
            lVar = lVar2;
        }
        try {
            i iVar = new i(kVar, kVar.f4039a.J(str));
            try {
                Object objInvoke = lVar.invoke(iVar);
                ua.b.h(iVar, null);
                return objInvoke;
            } finally {
            }
        } finally {
            aVar.g(null);
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0015  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object e(Transactor$SQLiteTransactionType transactor$SQLiteTransactionType, Continuation continuation) {
        PooledConnectionImpl$beginTransaction$1 pooledConnectionImpl$beginTransaction$1;
        k kVar;
        kotlinx.coroutines.sync.a aVar;
        if (continuation instanceof PooledConnectionImpl$beginTransaction$1) {
            pooledConnectionImpl$beginTransaction$1 = (PooledConnectionImpl$beginTransaction$1) continuation;
            int i10 = pooledConnectionImpl$beginTransaction$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                pooledConnectionImpl$beginTransaction$1.label = i10 - Integer.MIN_VALUE;
            } else {
                pooledConnectionImpl$beginTransaction$1 = new PooledConnectionImpl$beginTransaction$1(this, continuation);
            }
        }
        Object obj = pooledConnectionImpl$beginTransaction$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = pooledConnectionImpl$beginTransaction$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj);
            pooledConnectionImpl$beginTransaction$1.L$0 = this;
            pooledConnectionImpl$beginTransaction$1.L$1 = transactor$SQLiteTransactionType;
            g gVar = this.f4039a;
            pooledConnectionImpl$beginTransaction$1.L$2 = gVar;
            pooledConnectionImpl$beginTransaction$1.label = 1;
            if (gVar.f4024b.e(pooledConnectionImpl$beginTransaction$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
            kVar = this;
            aVar = gVar;
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            kotlinx.coroutines.sync.a aVar2 = (kotlinx.coroutines.sync.a) pooledConnectionImpl$beginTransaction$1.L$2;
            Transactor$SQLiteTransactionType transactor$SQLiteTransactionType2 = (Transactor$SQLiteTransactionType) pooledConnectionImpl$beginTransaction$1.L$1;
            kVar = (k) pooledConnectionImpl$beginTransaction$1.L$0;
            kotlin.a.d(obj);
            aVar = aVar2;
            transactor$SQLiteTransactionType = transactor$SQLiteTransactionType2;
        }
        try {
            kotlin.collections.h hVar = kVar.f4041c;
            int i12 = hVar.f29215c;
            boolean zIsEmpty = hVar.isEmpty();
            g gVar2 = kVar.f4039a;
            if (zIsEmpty) {
                int iOrdinal = transactor$SQLiteTransactionType.ordinal();
                if (iOrdinal == 0) {
                    ua.b.t("BEGIN DEFERRED TRANSACTION", gVar2);
                } else if (iOrdinal == 1) {
                    ua.b.t("BEGIN IMMEDIATE TRANSACTION", gVar2);
                } else {
                    if (iOrdinal != 2) {
                        throw new NoWhenBranchMatchedException();
                    }
                    ua.b.t("BEGIN EXCLUSIVE TRANSACTION", gVar2);
                }
            } else {
                ua.b.t("SAVEPOINT '" + i12 + '\'', gVar2);
            }
            hVar.addLast(new j(i12));
            kd.e eVar = kd.e.f29109a;
            aVar.g(null);
            return eVar;
        } catch (Throwable th) {
            aVar.g(null);
            throw th;
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0017  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object f(boolean z10, Continuation continuation) {
        PooledConnectionImpl$endTransaction$1 pooledConnectionImpl$endTransaction$1;
        k kVar;
        kotlinx.coroutines.sync.a aVar;
        if (continuation instanceof PooledConnectionImpl$endTransaction$1) {
            pooledConnectionImpl$endTransaction$1 = (PooledConnectionImpl$endTransaction$1) continuation;
            int i10 = pooledConnectionImpl$endTransaction$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                pooledConnectionImpl$endTransaction$1.label = i10 - Integer.MIN_VALUE;
            } else {
                pooledConnectionImpl$endTransaction$1 = new PooledConnectionImpl$endTransaction$1(this, continuation);
            }
        }
        Object obj = pooledConnectionImpl$endTransaction$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = pooledConnectionImpl$endTransaction$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj);
            pooledConnectionImpl$endTransaction$1.L$0 = this;
            g gVar = this.f4039a;
            pooledConnectionImpl$endTransaction$1.L$1 = gVar;
            pooledConnectionImpl$endTransaction$1.Z$0 = z10;
            pooledConnectionImpl$endTransaction$1.label = 1;
            if (gVar.f4024b.e(pooledConnectionImpl$endTransaction$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
            kVar = this;
            aVar = gVar;
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            z10 = pooledConnectionImpl$endTransaction$1.Z$0;
            aVar = (kotlinx.coroutines.sync.a) pooledConnectionImpl$endTransaction$1.L$1;
            kVar = (k) pooledConnectionImpl$endTransaction$1.L$0;
            kotlin.a.d(obj);
        }
        try {
            kotlin.collections.h hVar = kVar.f4041c;
            if (hVar.isEmpty()) {
                throw new IllegalStateException("Not in a transaction".toString());
            }
            nb.g.i(hVar, "<this>");
            if (hVar.isEmpty()) {
                throw new NoSuchElementException("List is empty.");
            }
            j jVar = (j) hVar.remove(hb.a.b0(hVar));
            g gVar2 = kVar.f4039a;
            if (z10) {
                jVar.getClass();
                if (hVar.isEmpty()) {
                    ua.b.t("END TRANSACTION", gVar2);
                } else {
                    ua.b.t("RELEASE SAVEPOINT '" + jVar.f4038a + '\'', gVar2);
                }
            } else if (hVar.isEmpty()) {
                ua.b.t("ROLLBACK TRANSACTION", gVar2);
            } else {
                ua.b.t("ROLLBACK TRANSACTION TO SAVEPOINT '" + jVar.f4038a + '\'', gVar2);
            }
            kd.e eVar = kd.e.f29109a;
            aVar.g(null);
            return eVar;
        } catch (Throwable th) {
            aVar.g(null);
            throw th;
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:44:0x009e  */
    /* JADX WARN: Removed duplicated region for block: B:47:0x00a9 A[RETURN] */
    /* JADX WARN: Removed duplicated region for block: B:48:0x00aa  */
    /* JADX WARN: Removed duplicated region for block: B:60:0x00c4  */
    /* JADX WARN: Removed duplicated region for block: B:62:0x00c8  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object g(Transactor$SQLiteTransactionType transactor$SQLiteTransactionType, Function2 function2, Continuation continuation) throws Throwable {
        PooledConnectionImpl$transaction$1 pooledConnectionImpl$transaction$1;
        k kVar;
        k kVar2;
        int i10;
        SQLException e10;
        Throwable th;
        if (continuation instanceof PooledConnectionImpl$transaction$1) {
            pooledConnectionImpl$transaction$1 = (PooledConnectionImpl$transaction$1) continuation;
            int i11 = pooledConnectionImpl$transaction$1.label;
            if ((i11 & Integer.MIN_VALUE) != 0) {
                pooledConnectionImpl$transaction$1.label = i11 - Integer.MIN_VALUE;
            } else {
                pooledConnectionImpl$transaction$1 = new PooledConnectionImpl$transaction$1(this, continuation);
            }
        }
        Object objInvoke = pooledConnectionImpl$transaction$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i12 = pooledConnectionImpl$transaction$1.label;
        try {
            if (i12 == 0) {
                kotlin.a.d(objInvoke);
                if (transactor$SQLiteTransactionType == null) {
                    transactor$SQLiteTransactionType = Transactor$SQLiteTransactionType.f3999a;
                }
                pooledConnectionImpl$transaction$1.L$0 = this;
                pooledConnectionImpl$transaction$1.L$1 = function2;
                pooledConnectionImpl$transaction$1.label = 1;
                if (e(transactor$SQLiteTransactionType, pooledConnectionImpl$transaction$1) == coroutineSingletons) {
                    return coroutineSingletons;
                }
                kVar = this;
            } else if (i12 == 1) {
                function2 = (Function2) pooledConnectionImpl$transaction$1.L$1;
                kVar = (k) pooledConnectionImpl$transaction$1.L$0;
                kotlin.a.d(objInvoke);
            } else {
                if (i12 != 2) {
                    if (i12 == 3) {
                        Object obj = pooledConnectionImpl$transaction$1.L$0;
                        kotlin.a.d(objInvoke);
                        return obj;
                    }
                    if (i12 == 4) {
                        Object obj2 = pooledConnectionImpl$transaction$1.L$0;
                        kotlin.a.d(objInvoke);
                        return obj2;
                    }
                    if (i12 != 5) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    th = (Throwable) pooledConnectionImpl$transaction$1.L$1;
                    th = (Throwable) pooledConnectionImpl$transaction$1.L$0;
                    try {
                        kotlin.a.d(objInvoke);
                        throw th;
                    } catch (SQLException e11) {
                        e10 = e11;
                        if (th != null) {
                            throw e10;
                        }
                        kotlin.a.a(th, e10);
                        throw th;
                    }
                }
                i10 = pooledConnectionImpl$transaction$1.I$0;
                kVar2 = (k) pooledConnectionImpl$transaction$1.L$0;
                try {
                    kotlin.a.d(objInvoke);
                    boolean z10 = i10 != 0;
                    pooledConnectionImpl$transaction$1.L$0 = objInvoke;
                    pooledConnectionImpl$transaction$1.label = 3;
                    return kVar2.f(z10, pooledConnectionImpl$transaction$1) != coroutineSingletons ? coroutineSingletons : objInvoke;
                } catch (Throwable th2) {
                    th = th2;
                    kVar = kVar2;
                    try {
                        throw th;
                    } catch (Throwable th3) {
                        try {
                            pooledConnectionImpl$transaction$1.L$0 = th;
                            pooledConnectionImpl$transaction$1.L$1 = th3;
                            pooledConnectionImpl$transaction$1.label = 5;
                            if (kVar.f(false, pooledConnectionImpl$transaction$1) == coroutineSingletons) {
                                return coroutineSingletons;
                            }
                            throw th3;
                        } catch (SQLException e12) {
                            e10 = e12;
                            th = th3;
                            if (th != null) {
                            }
                        }
                    }
                }
            }
            a aVar = new a(kVar, 1);
            pooledConnectionImpl$transaction$1.L$0 = kVar;
            pooledConnectionImpl$transaction$1.L$1 = null;
            pooledConnectionImpl$transaction$1.I$0 = 1;
            pooledConnectionImpl$transaction$1.label = 2;
            objInvoke = function2.invoke(aVar, pooledConnectionImpl$transaction$1);
            if (objInvoke == coroutineSingletons) {
                return coroutineSingletons;
            }
            kVar2 = kVar;
            i10 = 1;
            if (i10 != 0) {
            }
            pooledConnectionImpl$transaction$1.L$0 = objInvoke;
            pooledConnectionImpl$transaction$1.label = 3;
            if (kVar2.f(z10, pooledConnectionImpl$transaction$1) != coroutineSingletons) {
            }
        } catch (Throwable th4) {
            th = th4;
            throw th;
        }
    }
}