package defpackage;

import android.database.SQLException;
import java.io.Serializable;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.ReentrantLock;
import kotlinx.coroutines.TimeoutCancellationException;

/* JADX INFO: renamed from: ᵦᵸᵯˋ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C3614 implements InterfaceC2794 {

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final C3276 f13729;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final C3276 f13731;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public final long f13733;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final ThreadLocal f13730 = new ThreadLocal();

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public final AtomicBoolean f13732 = new AtomicBoolean(false);

    public C3614(ˊˊᵞᵽ r4) {
        ˉᵠﹳᵘ r0 = C0918.f4028;
        this.f13733 = AbstractC0702.m2546(30, EnumC1893.SECONDS);
        C3276 c3276 = new C3276(1, new ˁˌᵩ(18, r4));
        this.f13729 = c3276;
        this.f13731 = c3276;
    }

    public C3614(final ˊˊᵞᵽ r5, final String str, int i) {
        final int i2 = 0;
        ˉᵠﹳᵘ r0 = C0918.f4028;
        this.f13733 = AbstractC0702.m2546(30, EnumC1893.SECONDS);
        if (i <= 0) {
            ᵕᵩʽᵲ.ᵮᵣᵗˈ("Maximum number of readers must be greater than 0");
            throw null;
        }
        this.f13729 = new C3276(i, new InterfaceC1841() { // from class: ʿʾᵢʼ
            @Override // defpackage.InterfaceC1841
            /* JADX INFO: renamed from: ᵲᵶᵳˈ */
            public final Object mo1021() {
                int i3 = i2;
                String str2 = str;
                ˊˊᵞᵽ r2 = r5;
                switch (i3) {
                    case 0:
                        InterfaceC2047 interfaceC2047 = r2.ˊᵨᵧ(str2);
                        ˋˀᵧ.ᵪᵹᵥᵻ(interfaceC2047, "PRAGMA query_only = 1");
                        return interfaceC2047;
                    default:
                        return r2.ˊᵨᵧ(str2);
                }
            }
        });
        final int i3 = 1;
        this.f13731 = new C3276(1, new InterfaceC1841() { // from class: ʿʾᵢʼ
            @Override // defpackage.InterfaceC1841
            /* JADX INFO: renamed from: ᵲᵶᵳˈ */
            public final Object mo1021() {
                int i32 = i3;
                String str2 = str;
                ˊˊᵞᵽ r2 = r5;
                switch (i32) {
                    case 0:
                        InterfaceC2047 interfaceC2047 = r2.ˊᵨᵧ(str2);
                        ˋˀᵧ.ᵪᵹᵥᵻ(interfaceC2047, "PRAGMA query_only = 1");
                        return interfaceC2047;
                    default:
                        return r2.ˊᵨᵧ(str2);
                }
            }
        });
    }

    @Override // java.lang.AutoCloseable
    public final void close() {
        if (this.f13732.compareAndSet(false, true)) {
            this.f13729.m7509();
            this.f13731.m7509();
        }
    }

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final void m8146(boolean z) {
        String str = z ? "reader" : "writer";
        StringBuilder sb = new StringBuilder();
        sb.append("Timed out attempting to acquire a " + str + " connection.");
        sb.append("\n\nWriter pool:\n");
        this.f13731.m7510(sb);
        sb.append("Reader pool:");
        sb.append('\n');
        this.f13729.m7510(sb);
        ˋˀᵧ.ᵸˆˁ(5, sb.toString());
        throw null;
    }

    /* JADX WARN: Code restructure failed: missing block: B:64:0x0117, code lost:
    
        if (ˀᵳˎᵹ.ˈᵲᵢ(r9, r0, r4) == r14) goto L87;
     */
    /* JADX WARN: Removed duplicated region for block: B:7:0x001b  */
    /* JADX WARN: Removed duplicated region for block: B:91:0x018c A[Catch: all -> 0x01b8, TRY_LEAVE, TryCatch #6 {all -> 0x01b8, blocks: (B:89:0x0186, B:91:0x018c, B:93:0x0195, B:94:0x019a, B:96:0x01aa, B:98:0x01b4, B:99:0x01b7, B:95:0x01a5), top: B:141:0x0186, inners: #2 }] */
    @Override // defpackage.InterfaceC2794
    /* JADX INFO: renamed from: ᵻˈᵦʼ */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object mo6780(boolean z, InterfaceC0321 interfaceC0321, AbstractC3500 abstractC3500) {
        C0531 c0531;
        C3276 c3276;
        C2761 c2761;
        Throwable th;
        C3276 c32762;
        C2761 c27612;
        C0773 c0773;
        Object obj;
        C2761 c27613;
        ReentrantLock reentrantLock;
        C0773 c07732;
        C3614 c3614 = this;
        boolean z2 = z;
        InterfaceC0321 interfaceC03212 = interfaceC0321;
        if (abstractC3500 instanceof C0531) {
            c0531 = (C0531) abstractC3500;
            int i = c0531.f2722;
            if ((i & Integer.MIN_VALUE) != 0) {
                c0531.f2722 = i - Integer.MIN_VALUE;
            } else {
                c0531 = new C0531(c3614, abstractC3500);
            }
        }
        InterfaceC3822 interfaceC3822 = c0531.f13450;
        Object obj2 = c0531.f2720;
        int i2 = c0531.f2722;
        EnumC0111 enumC0111 = EnumC0111.f1384;
        if (i2 == 0) {
            ᵟˌᵫ.ˊˌˊ(obj2);
            if (c3614.f13732.get()) {
                ˋˀᵧ.ᵸˆˁ(21, "Connection pool is closed");
                throw null;
            }
            ThreadLocal threadLocal = c3614.f13730;
            C0773 c07733 = (C0773) threadLocal.get();
            ᵱᵻᵧᵷ r15 = C4339.f16522;
            if (c07733 == null) {
                C4339 c4339 = (C4339) interfaceC3822.mo2664(r15);
                c07733 = c4339 != null ? c4339.f16523 : null;
            }
            if (c07733 == null) {
                c3276 = z2 ? c3614.f13729 : c3614.f13731;
                c2761 = new C2761();
                try {
                    c27612 = new C2761();
                    try {
                        long j = c3614.f13733;
                        ᵿˈⁱ r0 = new ᵿˈⁱ(c27612, c3276, (InterfaceC2643) null, 17);
                        c0531.f2726 = c3614;
                        c0531.f2727 = (Serializable) interfaceC03212;
                        c0531.f2728 = c3276;
                        c0531.f2721 = c2761;
                        c0531.f2723 = interfaceC3822;
                        c0531.f2729 = c27612;
                        c0531.f2724 = z2;
                        c0531.f2722 = 3;
                    } catch (Throwable th2) {
                        th = th2;
                    }
                } catch (Throwable th3) {
                    th = th3;
                    c32762 = c3276;
                }
            } else {
                if (!z2 && c07733.f3440) {
                    ˋˀᵧ.ᵸˆˁ(1, "Cannot upgrade connection from reader to writer");
                    throw null;
                }
                if (interfaceC3822.mo2664(r15) == null) {
                    InterfaceC3822 interfaceC38222 = ᵝˉː.ˈᵲᵢ(new C4339(c07733), new C2460(c07733, threadLocal));
                    ᵤـ r1 = new ᵤـ(interfaceC03212, c07733, (InterfaceC2643) null, 17);
                    c0531.f2722 = 1;
                    Object obj3 = ᵲᵧˇ.ᵠˏˏ(interfaceC38222, r1, c0531);
                    if (obj3 != enumC0111) {
                        return obj3;
                    }
                } else {
                    c0531.f2722 = 2;
                    Object objMo1564 = interfaceC03212.mo1564(c07733, c0531);
                    if (objMo1564 != enumC0111) {
                        return objMo1564;
                    }
                }
            }
            return enumC0111;
        }
        if (i2 == 1) {
            ᵟˌᵫ.ˊˌˊ(obj2);
            return obj2;
        }
        if (i2 == 2) {
            ᵟˌᵫ.ˊˌˊ(obj2);
            return obj2;
        }
        if (i2 != 3) {
            if (i2 != 4) {
                ᵕᵩʽᵲ.ᵪᵹᵥᵻ("call to 'resume' before 'invoke' with coroutine");
                return null;
            }
            C2761 c27614 = (C2761) c0531.f2727;
            c32762 = (C3276) c0531.f2726;
            try {
                ᵟˌᵫ.ˊˌˊ(obj2);
                obj = obj2;
                c27613 = c27614;
                try {
                    c07732 = (C0773) c27613.f10617;
                    if (c07732 != null) {
                        if (c07732.f3443.compareAndSet(false, true)) {
                            try {
                                ˋˀᵧ.ᵪᵹᵥᵻ(c07732.f3442, "ROLLBACK TRANSACTION");
                            } catch (SQLException unused) {
                            }
                        }
                        C5510 c5510 = c07732.f3442;
                        c5510.f20806 = null;
                        c5510.f20808 = null;
                        reentrantLock = c32762.f12560;
                        reentrantLock.lock();
                        try {
                            c32762.f12559.m9340(c5510);
                            reentrantLock.unlock();
                            c32762.f12563.m4184();
                        } finally {
                        }
                    }
                } catch (Throwable unused2) {
                }
                return obj;
            } catch (Throwable th4) {
                th = th4;
                c2761 = c27614;
                th = th;
                throw th;
            }
        }
        boolean z3 = c0531.f2724;
        C2761 c27615 = c0531.f2729;
        interfaceC3822 = c0531.f2723;
        C2761 c27616 = c0531.f2721;
        c3276 = c0531.f2728;
        InterfaceC0321 interfaceC03213 = (InterfaceC0321) c0531.f2727;
        C3614 c36142 = (C3614) c0531.f2726;
        try {
            ᵟˌᵫ.ˊˌˊ(obj2);
            c27612 = c27615;
            z2 = z3;
            c3614 = c36142;
            c2761 = c27616;
            interfaceC03212 = interfaceC03213;
            th = null;
        } catch (Throwable th5) {
            th = th5;
            c27612 = c27615;
            z2 = z3;
            c3614 = c36142;
            c2761 = c27616;
            interfaceC03212 = interfaceC03213;
        }
        InterfaceC3822 interfaceC38223 = interfaceC3822;
        InterfaceC0321 interfaceC03214 = interfaceC03212;
        boolean z4 = z2;
        C3614 c36143 = c3614;
        C2761 c27617 = c2761;
        try {
            C5510 c55102 = (C5510) c27612.f10617;
            if (c55102 != null) {
                c55102.f20806 = interfaceC38223;
                c55102.f20808 = new Throwable();
                c0773 = new C0773(c55102, c36143.f13729 != c36143.f13731 && z4);
            } else {
                c0773 = null;
            }
            c27617.f10617 = c0773;
            if (th instanceof TimeoutCancellationException) {
                c36143.m8146(z4);
                throw null;
            }
            if (th != null) {
                throw th;
            }
            if (c0773 == null) {
                throw new IllegalArgumentException("Required value was null.");
            }
            c36143.getClass();
            InterfaceC3822 interfaceC38224 = ᵝˉː.ˈᵲᵢ(new C4339(c0773), new C2460(c0773, c36143.f13730));
            C2517 c2517 = new C2517(interfaceC03214, c27617, null, 1);
            c0531.f2726 = c3276;
            c0531.f2727 = c27617;
            c0531.f2728 = null;
            c0531.f2721 = null;
            c0531.f2723 = null;
            c0531.f2729 = null;
            c0531.f2722 = 4;
            Object obj4 = ᵲᵧˇ.ᵠˏˏ(interfaceC38224, c2517, c0531);
            if (obj4 != enumC0111) {
                obj = obj4;
                c27613 = c27617;
                c32762 = c3276;
                c07732 = (C0773) c27613.f10617;
                if (c07732 != null) {
                }
                return obj;
            }
            return enumC0111;
        } catch (Throwable th6) {
            th = th6;
            c2761 = c27617;
            c32762 = c3276;
            th = th;
            throw th;
        }
        try {
            throw th;
        } catch (Throwable th7) {
            try {
                C0773 c07734 = (C0773) c2761.f10617;
                if (c07734 == null) {
                    throw th7;
                }
                if (c07734.f3443.compareAndSet(false, true)) {
                    try {
                        ˋˀᵧ.ᵪᵹᵥᵻ(c07734.f3442, "ROLLBACK TRANSACTION");
                    } catch (SQLException unused3) {
                    }
                }
                C5510 c55103 = c07734.f3442;
                c55103.f20806 = null;
                c55103.f20808 = null;
                reentrantLock = c32762.f12560;
                reentrantLock.lock();
                try {
                    c32762.f12559.m9340(c55103);
                    reentrantLock.unlock();
                    c32762.f12563.m4184();
                    throw th7;
                } finally {
                }
            } catch (Throwable th8) {
                ᵷˆᵣ.ʽˈˋ(th, th8);
                throw th7;
            }
        }
    }
}