package androidx.room;

import com.google.android.gms.internal.atv_ads_framework.d1;
import java.nio.channels.FileChannel;
import java.util.concurrent.locks.ReentrantLock;

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

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final k3.b f4003a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ c f4004b;

    public b(c cVar, k3.b bVar) {
        nb.g.i(bVar, "actual");
        this.f4004b = cVar;
        this.f4003a = bVar;
    }

    /* JADX WARN: Removed duplicated region for block: B:21:0x0057 A[Catch: all -> 0x009d, TRY_LEAVE, TryCatch #5 {all -> 0x009d, blocks: (B:19:0x0052, B:21:0x0057, B:24:0x0066, B:28:0x006d, B:26:0x006a, B:27:0x006c, B:40:0x0091, B:41:0x009c, B:23:0x0061), top: B:62:0x0052, outer: #0, inners: #3 }] */
    /* JADX WARN: Removed duplicated region for block: B:40:0x0091 A[Catch: all -> 0x009d, TRY_ENTER, TryCatch #5 {all -> 0x009d, blocks: (B:19:0x0052, B:21:0x0057, B:24:0x0066, B:28:0x006d, B:26:0x006a, B:27:0x006c, B:40:0x0091, B:41:0x009c, B:23:0x0061), top: B:62:0x0052, outer: #0, inners: #3 }] */
    @Override // k3.b
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final k3.a open(String str) {
        FileChannel fileChannel;
        FileChannel fileChannel2;
        nb.g.i(str, "fileName");
        c cVar = this.f4004b;
        f0 f0Var = (f0) cVar;
        f0Var.getClass();
        if (!nb.g.c(str, ":memory:")) {
            str = f0Var.f4083c.f4060a.getDatabasePath(str).getAbsolutePath();
            nb.g.f(str);
        }
        boolean z10 = true;
        f3.b bVar = new f3.b(str, (cVar.f4007a || cVar.f4008b || nb.g.c(str, ":memory:")) ? false : true);
        a aVar = new a(str);
        ReentrantLock reentrantLock = bVar.f25940a;
        reentrantLock.lock();
        d1 d1Var = bVar.f25941b;
        if (d1Var != null) {
            try {
                d1Var.l();
                try {
                    try {
                        if (!cVar.f4008b) {
                            throw new IllegalStateException("Recursive database initialization detected. Did you try to use the database instance during initialization? Maybe in one of the callbacks?".toString());
                        }
                        k3.a aVarOpen = this.f4003a.open(str);
                        if (cVar.f4007a) {
                            cVar.c(aVarOpen);
                            c.b(aVarOpen);
                            ((f0) cVar).f4084d.onOpen(aVarOpen);
                        } else {
                            try {
                                cVar.f4008b = true;
                                c.a(cVar, aVarOpen);
                                cVar.f4008b = false;
                            } catch (Throwable th) {
                                cVar.f4008b = false;
                                throw th;
                            }
                        }
                        if (d1Var != null && (fileChannel2 = (FileChannel) d1Var.f19915c) != null) {
                            try {
                                fileChannel2.close();
                                d1Var.f19915c = null;
                            } finally {
                            }
                        }
                        return aVarOpen;
                    } catch (Throwable th2) {
                        th = th2;
                    }
                } catch (Throwable th3) {
                    if (d1Var != null && (fileChannel = (FileChannel) d1Var.f19915c) != null) {
                        try {
                            fileChannel.close();
                            d1Var.f19915c = null;
                        } finally {
                        }
                    }
                    throw th3;
                }
            } catch (Throwable th4) {
                th = th4;
                z10 = false;
            }
        } else if (!cVar.f4008b) {
        }
        try {
            if (z10) {
                throw th;
            }
            aVar.invoke(th);
            throw null;
        } finally {
            reentrantLock.unlock();
        }
    }
}