package defpackage;

import java.util.concurrent.atomic.AtomicBoolean;

/* renamed from: ᵺᵴʡ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C5151 implements InterfaceC2274 {

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final C0543 f19175;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public final long f19176;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final C0543 f19177;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final ThreadLocal f19179 = new ThreadLocal();

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public final AtomicBoolean f19178 = new AtomicBoolean(false);

    public C5151(ᵪᵨ r4) {
        ʾᵚᵱ r0 = C1058.f4589;
        this.f19176 = AbstractC0494.m2157(30, EnumC0171.SECONDS);
        C0543 c0543 = new C0543(1, new ᐧﾞ(18, r4));
        this.f19177 = c0543;
        this.f19175 = c0543;
    }

    public C5151(final ᵪᵨ r5, final String str, int i) {
        final int i2 = 0;
        ʾᵚᵱ r0 = C1058.f4589;
        this.f19176 = AbstractC0494.m2157(30, EnumC0171.SECONDS);
        if (i <= 0) {
            ᵹˉᵞ.ˌᵜᵹᵩ("Maximum number of readers must be greater than 0");
            throw null;
        }
        this.f19177 = new C0543(i, new InterfaceC4622() { // from class: ʾˀʜ
            @Override // defpackage.InterfaceC4622
            /* renamed from: ᵥᵯˎ */
            public final Object mo1401() {
                int i3 = i2;
                String str2 = str;
                ᵪᵨ r2 = r5;
                switch (i3) {
                    case 0:
                        InterfaceC3042 interfaceC3042 = r2.ᵞʡ(str2);
                        ᵭʝʜ.ᵪʩ(interfaceC3042, "PRAGMA query_only = 1");
                        return interfaceC3042;
                    default:
                        return r2.ᵞʡ(str2);
                }
            }
        });
        final int i3 = 1;
        this.f19175 = new C0543(1, new InterfaceC4622() { // from class: ʾˀʜ
            @Override // defpackage.InterfaceC4622
            /* renamed from: ᵥᵯˎ */
            public final Object mo1401() {
                int i32 = i3;
                String str2 = str;
                ᵪᵨ r2 = r5;
                switch (i32) {
                    case 0:
                        InterfaceC3042 interfaceC3042 = r2.ᵞʡ(str2);
                        ᵭʝʜ.ᵪʩ(interfaceC3042, "PRAGMA query_only = 1");
                        return interfaceC3042;
                    default:
                        return r2.ᵞʡ(str2);
                }
            }
        });
    }

    @Override // java.lang.AutoCloseable
    public final void close() {
        if (this.f19178.compareAndSet(false, true)) {
            this.f19177.m2339();
            this.f19175.m2339();
        }
    }

    /* 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.InterfaceC2274
    /* renamed from: ˏˋٴ */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final java.lang.Object mo5945(boolean r18, defpackage.InterfaceC3759 r19, defpackage.AbstractC1989 r20) {
        /*
            Method dump skipped, instructions count: 523
            To view this dump add '--comments-level debug' option
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C5151.mo5945(boolean, ᵨᵱ, ːᵱ):java.lang.Object");
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final void m10632(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.f19175.m2337(sb);
        sb.append("Reader pool:");
        sb.append('\n');
        this.f19177.m2337(sb);
        ᵭʝʜ.ˑᵥˁ(5, sb.toString());
        throw null;
    }
}