package Q1;

import F5.C0115b;
import O1.C0225a;
import Z6.AbstractC0385z;
import Z6.v0;
import Z6.w0;
import android.database.SQLException;
import com.google.android.gms.internal.measurement.C1;
import java.util.concurrent.atomic.AtomicBoolean;
import v0.AbstractC1664c;

/* JADX INFO: loaded from: classes.dex */
public final class h implements b, AutoCloseable {

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final k f5576q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final k f5577r;

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public final ThreadLocal f5578s;

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public final AtomicBoolean f5579t;

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    public final long f5580u;

    public h(C0225a c0225a) {
        this.f5578s = new ThreadLocal();
        this.f5579t = new AtomicBoolean(false);
        int i = Y6.a.f7349t;
        this.f5580u = AbstractC1664c.A(30, Y6.c.SECONDS);
        k kVar = new k(1, new C0115b(1, c0225a));
        this.f5576q = kVar;
        this.f5577r = kVar;
    }

    public final void a(boolean z8) {
        String str = z8 ? "reader" : "writer";
        StringBuilder sb = new StringBuilder();
        sb.append("Timed out attempting to acquire a " + str + " connection.");
        sb.append("\n\nWriter pool:\n");
        this.f5577r.c(sb);
        sb.append("Reader pool:");
        sb.append('\n');
        this.f5576q.c(sb);
        android.support.v4.media.session.a.t(5, sb.toString());
        throw null;
    }

    @Override // java.lang.AutoCloseable
    public final void close() {
        if (this.f5579t.compareAndSet(false, true)) {
            this.f5576q.b();
            this.f5577r.b();
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:7:0x001b  */
    /* JADX WARN: Removed duplicated region for block: B:97:0x01b4 A[Catch: all -> 0x01ca, TRY_LEAVE, TryCatch #5 {all -> 0x01ca, blocks: (B:95:0x01ae, B:97:0x01b4, B:100:0x01c0, B:101:0x01c3), top: B:139:0x01ae }] */
    @Override // Q1.b
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object e0(boolean z8, O6.p pVar, G6.c cVar) throws Throwable {
        e eVar;
        P6.m mVar;
        Throwable th;
        k kVar;
        P6.m mVar2;
        k kVar2;
        P6.m mVar3;
        E6.i iVar;
        h hVar;
        O6.p pVar2;
        P6.m mVar4;
        k kVar3;
        boolean z9;
        P6.m mVar5;
        s sVar;
        s sVar2;
        boolean z10 = z8;
        O6.p pVar3 = pVar;
        if (cVar instanceof e) {
            eVar = (e) cVar;
            int i = eVar.f5562C;
            if ((i & Integer.MIN_VALUE) != 0) {
                eVar.f5562C = i - Integer.MIN_VALUE;
            } else {
                eVar = new e(this, cVar);
            }
        }
        Object objC = eVar.f5560A;
        F6.a aVar = F6.a.f2580q;
        int i5 = eVar.f5562C;
        try {
            if (i5 == 0) {
                C1.N(objC);
                if (this.f5579t.get()) {
                    android.support.v4.media.session.a.t(21, "Connection pool is closed");
                    throw null;
                }
                ThreadLocal threadLocal = this.f5578s;
                s sVar3 = (s) threadLocal.get();
                x3.e eVar2 = a.f5551r;
                E6.i iVar2 = eVar.f3016r;
                if (sVar3 == null) {
                    P6.g.b(iVar2);
                    a aVar2 = (a) iVar2.K(eVar2);
                    sVar3 = aVar2 != null ? aVar2.f5552q : null;
                }
                if (sVar3 == null) {
                    k kVar4 = z10 ? this.f5576q : this.f5577r;
                    mVar = new P6.m();
                    try {
                        P6.g.b(iVar2);
                        mVar2 = new P6.m();
                        try {
                            long j8 = this.f5580u;
                            d dVar = new d(mVar2, kVar4, null);
                            eVar.f5563t = this;
                            eVar.f5564u = pVar3;
                            eVar.f5565v = kVar4;
                            eVar.f5566w = mVar;
                            eVar.f5567x = iVar2;
                            eVar.f5568y = mVar2;
                            eVar.f5569z = z10;
                            eVar.f5562C = 3;
                            long jZ = AbstractC0385z.z(j8);
                            if (jZ <= 0) {
                                throw new v0("Timed out immediately", null);
                            }
                            if (AbstractC0385z.x(new w0(jZ, eVar), dVar) != aVar) {
                                pVar2 = pVar3;
                                mVar4 = mVar2;
                                kVar3 = kVar4;
                                iVar = iVar2;
                                mVar3 = mVar;
                                hVar = this;
                                th = null;
                                kVar2 = kVar3;
                                mVar2 = mVar4;
                            }
                        } catch (Throwable th2) {
                            th = th2;
                            kVar2 = kVar4;
                            mVar3 = mVar;
                            iVar = iVar2;
                            hVar = this;
                            pVar2 = pVar3;
                        }
                    } catch (Throwable th3) {
                        th = th3;
                        kVar = kVar4;
                        throw th;
                    }
                } else {
                    if (!z10 && sVar3.f5629b) {
                        android.support.v4.media.session.a.t(1, "Cannot upgrade connection from reader to writer");
                        throw null;
                    }
                    P6.g.b(iVar2);
                    if (iVar2.K(eVar2) == null) {
                        a aVar3 = new a(sVar3);
                        P6.g.e(threadLocal, "<this>");
                        E6.i iVarX = s7.l.x(aVar3, new e7.u(sVar3, threadLocal));
                        f fVar = new f(pVar3, sVar3, null);
                        eVar.f5562C = 1;
                        Object objC2 = AbstractC0385z.C(iVarX, fVar, eVar);
                        if (objC2 != aVar) {
                            return objC2;
                        }
                    } else {
                        eVar.f5562C = 2;
                        Object objK = pVar3.k(sVar3, eVar);
                        if (objK != aVar) {
                            return objK;
                        }
                    }
                }
                return aVar;
            }
            if (i5 == 1) {
                C1.N(objC);
                return objC;
            }
            if (i5 == 2) {
                C1.N(objC);
                return objC;
            }
            if (i5 == 3) {
                z10 = eVar.f5569z;
                mVar4 = eVar.f5568y;
                iVar = eVar.f5567x;
                mVar3 = eVar.f5566w;
                kVar3 = eVar.f5565v;
                pVar2 = (O6.p) eVar.f5564u;
                hVar = (h) eVar.f5563t;
                try {
                    C1.N(objC);
                    th = null;
                    kVar2 = kVar3;
                    mVar2 = mVar4;
                } catch (Throwable th4) {
                    th = th4;
                    kVar2 = kVar3;
                    mVar2 = mVar4;
                    pVar3 = pVar2;
                    pVar2 = pVar3;
                }
            } else {
                if (i5 != 4) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                mVar5 = (P6.m) eVar.f5564u;
                kVar = (k) eVar.f5563t;
                try {
                    C1.N(objC);
                    try {
                        sVar2 = (s) mVar5.f5535q;
                        if (sVar2 != null) {
                            boolean zCompareAndSet = sVar2.f5631d.compareAndSet(false, true);
                            i iVar3 = sVar2.f5628a;
                            if (zCompareAndSet) {
                                try {
                                    android.support.v4.media.session.a.i(iVar3, "ROLLBACK TRANSACTION");
                                } catch (SQLException unused) {
                                }
                            }
                            iVar3.f5583s = null;
                            iVar3.f5584t = null;
                            kVar.d(iVar3);
                        }
                    } catch (Throwable unused2) {
                    }
                    return objC;
                } catch (Throwable th5) {
                    th = th5;
                    mVar = mVar5;
                    th = th;
                    try {
                        throw th;
                    } finally {
                    }
                }
            }
            i iVar4 = (i) mVar2.f5535q;
            if (iVar4 != null) {
                P6.g.e(iVar, "context");
                iVar4.f5583s = iVar;
                iVar4.f5584t = new Throwable();
                sVar = new s(iVar4, hVar.f5576q != hVar.f5577r && z9);
            } else {
                sVar = null;
            }
            mVar5.f5535q = sVar;
            if (th instanceof v0) {
                hVar.a(z9);
                throw null;
            }
            if (th != null) {
                throw th;
            }
            if (sVar == null) {
                throw new IllegalArgumentException("Required value was null.");
            }
            hVar.getClass();
            a aVar4 = new a(sVar);
            ThreadLocal threadLocal2 = hVar.f5578s;
            P6.g.e(threadLocal2, "<this>");
            E6.i iVarX2 = s7.l.x(aVar4, new e7.u(sVar, threadLocal2));
            g gVar = new g(pVar2, mVar5, null);
            eVar.f5563t = kVar2;
            eVar.f5564u = mVar5;
            eVar.f5565v = null;
            eVar.f5566w = null;
            eVar.f5567x = null;
            eVar.f5568y = null;
            eVar.f5562C = 4;
            objC = AbstractC0385z.C(iVarX2, gVar, eVar);
            if (objC != aVar) {
                kVar = kVar2;
                sVar2 = (s) mVar5.f5535q;
                if (sVar2 != null) {
                }
                return objC;
            }
            return aVar;
        } catch (Throwable th6) {
            th = th6;
            mVar = mVar5;
            kVar = kVar2;
            th = th;
            throw th;
        }
        z9 = z10;
        mVar5 = mVar3;
    }

    public h(C0225a c0225a, String str, int i) {
        P6.g.e(str, "fileName");
        this.f5578s = new ThreadLocal();
        this.f5579t = new AtomicBoolean(false);
        int i5 = Y6.a.f7349t;
        this.f5580u = AbstractC1664c.A(30, Y6.c.SECONDS);
        if (i > 0) {
            this.f5576q = new k(i, new c(c0225a, 0, str));
            this.f5577r = new k(1, new c(c0225a, 1, str));
            return;
        }
        throw new IllegalArgumentException("Maximum number of readers must be greater than 0");
    }
}