package androidx.datastore.core;

import java.io.File;
import java.io.IOException;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.concurrent.CancellationException;
import kotlin.NoWhenBranchMatchedException;
import kotlin.Pair;
import kotlin.Result;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.Ref$IntRef;
import kotlin.jvm.internal.Ref$ObjectRef;
import kotlinx.coroutines.n1;

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

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final kotlinx.coroutines.x f1934c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final kotlinx.coroutines.flow.q f1935d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final kotlinx.coroutines.sync.c f1936e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public int f1937f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public n1 f1938g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final o f1939h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final j f1940i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final kd.c f1941j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final kd.c f1942k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public final a0 f1943l;

    public n(q qVar, List list, com.google.android.material.shape.f fVar, kotlinx.coroutines.x xVar) {
        nb.g.i(xVar, "scope");
        this.f1932a = qVar;
        this.f1933b = fVar;
        this.f1934c = xVar;
        this.f1935d = new kotlinx.coroutines.flow.q(new DataStoreImpl$data$1(this, null));
        this.f1936e = kotlinx.coroutines.sync.d.a();
        this.f1939h = new o();
        this.f1940i = new j(this, list);
        this.f1941j = kotlin.a.c(new sd.a() { // from class: androidx.datastore.core.DataStoreImpl$storageConnectionDelegate$1
            {
                super(0);
            }

            @Override // sd.a
            public final Object invoke() throws IOException {
                q qVar2 = (q) this.this$0.f1932a;
                final File canonicalFile = ((File) qVar2.f1952c.invoke()).getCanonicalFile();
                synchronized (q.f1949e) {
                    String absolutePath = canonicalFile.getAbsolutePath();
                    LinkedHashSet linkedHashSet = q.f1948d;
                    if (!(!linkedHashSet.contains(absolutePath))) {
                        throw new IllegalStateException(("There are multiple DataStores active for the same file: " + absolutePath + ". You should either maintain your DataStore as a singleton or confirm that there is no two DataStore's active on the same file (by confirming that the scope is cancelled).").toString());
                    }
                    nb.g.h(absolutePath, "path");
                    linkedHashSet.add(absolutePath);
                }
                return new r(canonicalFile, qVar2.f1950a, (u) qVar2.f1951b.invoke(canonicalFile), new sd.a() { // from class: androidx.datastore.core.FileStorage$createConnection$2
                    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
                    {
                        super(0);
                    }

                    @Override // sd.a
                    public final Object invoke() {
                        Object obj = q.f1949e;
                        File file = canonicalFile;
                        synchronized (obj) {
                            q.f1948d.remove(file.getAbsolutePath());
                        }
                        return kd.e.f29109a;
                    }
                });
            }
        });
        this.f1942k = kotlin.a.c(new sd.a() { // from class: androidx.datastore.core.DataStoreImpl$coordinator$2
            {
                super(0);
            }

            @Override // sd.a
            public final Object invoke() {
                return ((r) ((e0) this.this$0.f1941j.getValue())).f1955c;
            }
        });
        this.f1943l = new a0(xVar, new sd.l() { // from class: androidx.datastore.core.DataStoreImpl$writeActor$1
            {
                super(1);
            }

            @Override // sd.l
            public final Object invoke(Object obj) {
                Throwable th = (Throwable) obj;
                if (th != null) {
                    this.this$0.f1939h.c(new t(th));
                }
                if (this.this$0.f1941j.isInitialized()) {
                    ((r) ((e0) this.this$0.f1941j.getValue())).close();
                }
                return kd.e.f29109a;
            }
        }, new Function2() { // from class: androidx.datastore.core.DataStoreImpl$writeActor$2
            @Override // kotlin.jvm.functions.Function2
            public final Object invoke(Object obj, Object obj2) {
                v vVar = (v) obj;
                Throwable cancellationException = (Throwable) obj2;
                nb.g.i(vVar, "msg");
                if (cancellationException == null) {
                    cancellationException = new CancellationException("DataStore scope was cancelled before updateData could complete");
                }
                kotlinx.coroutines.o oVar = (kotlinx.coroutines.o) vVar.f1961b;
                oVar.getClass();
                oVar.N(new kotlinx.coroutines.q(cancellationException, false));
                return kd.e.f29109a;
            }
        }, new DataStoreImpl$writeActor$3(this, null));
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0016  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object b(n nVar, Continuation continuation) {
        DataStoreImpl$decrementCollector$1 dataStoreImpl$decrementCollector$1;
        kotlinx.coroutines.sync.a aVar;
        nVar.getClass();
        if (continuation instanceof DataStoreImpl$decrementCollector$1) {
            dataStoreImpl$decrementCollector$1 = (DataStoreImpl$decrementCollector$1) continuation;
            int i10 = dataStoreImpl$decrementCollector$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                dataStoreImpl$decrementCollector$1.label = i10 - Integer.MIN_VALUE;
            } else {
                dataStoreImpl$decrementCollector$1 = new DataStoreImpl$decrementCollector$1(nVar, continuation);
            }
        }
        Object obj = dataStoreImpl$decrementCollector$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = dataStoreImpl$decrementCollector$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj);
            dataStoreImpl$decrementCollector$1.L$0 = nVar;
            aVar = nVar.f1936e;
            dataStoreImpl$decrementCollector$1.L$1 = aVar;
            dataStoreImpl$decrementCollector$1.label = 1;
            if (aVar.e(dataStoreImpl$decrementCollector$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            kotlinx.coroutines.sync.a aVar2 = (kotlinx.coroutines.sync.a) dataStoreImpl$decrementCollector$1.L$1;
            n nVar2 = (n) dataStoreImpl$decrementCollector$1.L$0;
            kotlin.a.d(obj);
            aVar = aVar2;
            nVar = nVar2;
        }
        try {
            int i12 = nVar.f1937f - 1;
            nVar.f1937f = i12;
            if (i12 == 0) {
                n1 n1Var = nVar.f1938g;
                if (n1Var != null) {
                    n1Var.e(null);
                }
                nVar.f1938g = null;
            }
            aVar.g(null);
            return kd.e.f29109a;
        } catch (Throwable th) {
            aVar.g(null);
            throw th;
        }
    }

    /* JADX WARN: Can't wrap try/catch for region: R(14:0|2|(2:4|(1:6)(1:7))(0)|8|(7:69|(1:(1:(1:13)(2:18|19))(3:20|21|22))(1:23)|14|63|(1:65)(1:66)|67|68)(4:24|74|25|(9:27|70|28|(1:76)|31|63|(0)(0)|67|68)(4:38|(2:56|(2:58|59)(2:60|61))|43|(2:45|(2:47|75))(2:54|55)))|48|72|49|(1:77)|31|63|(0)(0)|67|68) */
    /* JADX WARN: Code restructure failed: missing block: B:52:0x00c9, code lost:
    
        r9 = th;
     */
    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:65:0x00f0  */
    /* JADX WARN: Removed duplicated region for block: B:66:0x00f4  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0016  */
    /* JADX WARN: Type inference failed for: r9v0, types: [androidx.datastore.core.n, java.lang.Object] */
    /* JADX WARN: Type inference failed for: r9v10, types: [androidx.datastore.core.n] */
    /* JADX WARN: Type inference failed for: r9v13 */
    /* JADX WARN: Type inference failed for: r9v14 */
    /* JADX WARN: Type inference failed for: r9v16 */
    /* JADX WARN: Type inference failed for: r9v19 */
    /* JADX WARN: Type inference failed for: r9v27 */
    /* JADX WARN: Type inference failed for: r9v28 */
    /* JADX WARN: Type inference failed for: r9v29 */
    /* JADX WARN: Type inference failed for: r9v6 */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object c(n nVar, v vVar, Continuation continuation) {
        DataStoreImpl$handleUpdate$1 dataStoreImpl$handleUpdate$1;
        kotlinx.coroutines.n nVar2;
        kotlinx.coroutines.n nVar3;
        ?? r92;
        Object objB;
        ?? r93;
        Throwable thA;
        c0 c0VarA;
        nVar.getClass();
        if (continuation instanceof DataStoreImpl$handleUpdate$1) {
            dataStoreImpl$handleUpdate$1 = (DataStoreImpl$handleUpdate$1) continuation;
            int i10 = dataStoreImpl$handleUpdate$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                dataStoreImpl$handleUpdate$1.label = i10 - Integer.MIN_VALUE;
            } else {
                dataStoreImpl$handleUpdate$1 = new DataStoreImpl$handleUpdate$1(nVar, continuation);
            }
        }
        Object objB2 = dataStoreImpl$handleUpdate$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = dataStoreImpl$handleUpdate$1.label;
        if (i11 != 0) {
            try {
                if (i11 == 1) {
                    nVar2 = (kotlinx.coroutines.n) dataStoreImpl$handleUpdate$1.L$0;
                } else if (i11 == 2) {
                    kotlinx.coroutines.n nVar4 = (kotlinx.coroutines.n) dataStoreImpl$handleUpdate$1.L$2;
                    n nVar5 = (n) dataStoreImpl$handleUpdate$1.L$1;
                    v vVar2 = (v) dataStoreImpl$handleUpdate$1.L$0;
                    kotlin.a.d(objB2);
                    nVar3 = nVar4;
                    r92 = nVar5;
                    vVar = vVar2;
                } else {
                    if (i11 != 3) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    nVar2 = (kotlinx.coroutines.n) dataStoreImpl$handleUpdate$1.L$0;
                }
                kotlin.a.d(objB2);
                r93 = nVar2;
            } catch (Throwable th) {
                th = th;
                objB2 = kotlin.a.b(th);
                r93 = nVar;
            }
            thA = Result.a(objB2);
            kotlinx.coroutines.o oVar = (kotlinx.coroutines.o) r93;
            if (thA == null) {
                oVar.N(objB2);
            } else {
                oVar.getClass();
                oVar.N(new kotlinx.coroutines.q(thA, false));
            }
            return kd.e.f29109a;
        }
        kotlin.a.d(objB2);
        nVar3 = vVar.f1961b;
        try {
            c0VarA = nVar.f1939h.a();
        } catch (Throwable th2) {
            th = th2;
            nVar = nVar3;
            objB2 = kotlin.a.b(th);
            r93 = nVar;
        }
        if (c0VarA instanceof d) {
            Function2 function2 = vVar.f1960a;
            kotlin.coroutines.h hVar = vVar.f1963d;
            dataStoreImpl$handleUpdate$1.L$0 = nVar3;
            dataStoreImpl$handleUpdate$1.label = 1;
            try {
                objB = ((b0) nVar.g()).b(dataStoreImpl$handleUpdate$1, new DataStoreImpl$transformAndWrite$2(nVar, hVar, function2, null));
                if (objB == coroutineSingletons) {
                    return coroutineSingletons;
                }
                kotlinx.coroutines.n nVar6 = nVar3;
                objB2 = objB;
                r93 = nVar6;
            } catch (Throwable th3) {
                th = th3;
                th = th;
                nVar = nVar3;
                objB2 = kotlin.a.b(th);
                r93 = nVar;
            }
            thA = Result.a(objB2);
            kotlinx.coroutines.o oVar2 = (kotlinx.coroutines.o) r93;
            if (thA == null) {
            }
            return kd.e.f29109a;
        }
        if (!(c0VarA instanceof w) && !(c0VarA instanceof f0)) {
            if (c0VarA instanceof t) {
                throw ((t) c0VarA).f1959b;
            }
            throw new NoWhenBranchMatchedException();
        }
        if (c0VarA != vVar.f1962c) {
            nb.g.g(c0VarA, "null cannot be cast to non-null type androidx.datastore.core.ReadException<T of androidx.datastore.core.DataStoreImpl.handleUpdate$lambda$2>");
            throw ((w) c0VarA).f1964b;
        }
        dataStoreImpl$handleUpdate$1.L$0 = vVar;
        dataStoreImpl$handleUpdate$1.L$1 = nVar;
        dataStoreImpl$handleUpdate$1.L$2 = nVar3;
        dataStoreImpl$handleUpdate$1.label = 2;
        Object objH = nVar.h(dataStoreImpl$handleUpdate$1);
        r92 = nVar;
        if (objH == coroutineSingletons) {
            return coroutineSingletons;
        }
        Function2 function22 = vVar.f1960a;
        kotlin.coroutines.h hVar2 = vVar.f1963d;
        dataStoreImpl$handleUpdate$1.L$0 = nVar3;
        dataStoreImpl$handleUpdate$1.L$1 = null;
        dataStoreImpl$handleUpdate$1.L$2 = null;
        dataStoreImpl$handleUpdate$1.label = 3;
        objB = ((b0) r92.g()).b(dataStoreImpl$handleUpdate$1, new DataStoreImpl$transformAndWrite$2(r92, hVar2, function22, null));
        if (objB == coroutineSingletons) {
            return coroutineSingletons;
        }
        kotlinx.coroutines.n nVar62 = nVar3;
        objB2 = objB;
        r93 = nVar62;
        thA = Result.a(objB2);
        kotlinx.coroutines.o oVar22 = (kotlinx.coroutines.o) r93;
        if (thA == null) {
        }
        return kd.e.f29109a;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0016  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object d(n nVar, Continuation continuation) {
        DataStoreImpl$incrementCollector$1 dataStoreImpl$incrementCollector$1;
        kotlinx.coroutines.sync.a aVar;
        nVar.getClass();
        if (continuation instanceof DataStoreImpl$incrementCollector$1) {
            dataStoreImpl$incrementCollector$1 = (DataStoreImpl$incrementCollector$1) continuation;
            int i10 = dataStoreImpl$incrementCollector$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                dataStoreImpl$incrementCollector$1.label = i10 - Integer.MIN_VALUE;
            } else {
                dataStoreImpl$incrementCollector$1 = new DataStoreImpl$incrementCollector$1(nVar, continuation);
            }
        }
        Object obj = dataStoreImpl$incrementCollector$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = dataStoreImpl$incrementCollector$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj);
            dataStoreImpl$incrementCollector$1.L$0 = nVar;
            aVar = nVar.f1936e;
            dataStoreImpl$incrementCollector$1.L$1 = aVar;
            dataStoreImpl$incrementCollector$1.label = 1;
            if (aVar.e(dataStoreImpl$incrementCollector$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            kotlinx.coroutines.sync.a aVar2 = (kotlinx.coroutines.sync.a) dataStoreImpl$incrementCollector$1.L$1;
            n nVar2 = (n) dataStoreImpl$incrementCollector$1.L$0;
            kotlin.a.d(obj);
            aVar = aVar2;
            nVar = nVar2;
        }
        try {
            int i12 = nVar.f1937f + 1;
            nVar.f1937f = i12;
            if (i12 == 1) {
                nVar.f1938g = hb.a.k0(nVar.f1934c, null, new DataStoreImpl$incrementCollector$2$1(nVar, null), 3);
            }
            aVar.g(null);
            return kd.e.f29109a;
        } catch (Throwable th) {
            aVar.g(null);
            throw th;
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:45:0x00dd  */
    /* JADX WARN: Removed duplicated region for block: B:50:? A[RETURN, SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0016  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object e(n nVar, boolean z10, Continuation continuation) {
        DataStoreImpl$readDataAndUpdateCache$1 dataStoreImpl$readDataAndUpdateCache$1;
        n nVar2;
        c0 c0Var;
        n nVar3;
        Pair pair;
        nVar.getClass();
        if (continuation instanceof DataStoreImpl$readDataAndUpdateCache$1) {
            dataStoreImpl$readDataAndUpdateCache$1 = (DataStoreImpl$readDataAndUpdateCache$1) continuation;
            int i10 = dataStoreImpl$readDataAndUpdateCache$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                dataStoreImpl$readDataAndUpdateCache$1.label = i10 - Integer.MIN_VALUE;
            } else {
                dataStoreImpl$readDataAndUpdateCache$1 = new DataStoreImpl$readDataAndUpdateCache$1(nVar, continuation);
            }
        }
        Object objC = dataStoreImpl$readDataAndUpdateCache$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = dataStoreImpl$readDataAndUpdateCache$1.label;
        if (i11 == 0) {
            kotlin.a.d(objC);
            c0 c0VarA = nVar.f1939h.a();
            if (!(!(c0VarA instanceof f0))) {
                throw new IllegalStateException("This is a bug in DataStore. Please file a bug at: https://issuetracker.google.com/issues/new?component=907884&template=1466542".toString());
            }
            u uVarG = nVar.g();
            dataStoreImpl$readDataAndUpdateCache$1.L$0 = nVar;
            dataStoreImpl$readDataAndUpdateCache$1.L$1 = c0VarA;
            dataStoreImpl$readDataAndUpdateCache$1.Z$0 = z10;
            dataStoreImpl$readDataAndUpdateCache$1.label = 1;
            Integer numA = ((b0) uVarG).a();
            if (numA == coroutineSingletons) {
                return coroutineSingletons;
            }
            nVar2 = nVar;
            c0Var = c0VarA;
            objC = numA;
        } else if (i11 == 1) {
            z10 = dataStoreImpl$readDataAndUpdateCache$1.Z$0;
            c0Var = (c0) dataStoreImpl$readDataAndUpdateCache$1.L$1;
            nVar2 = (n) dataStoreImpl$readDataAndUpdateCache$1.L$0;
            kotlin.a.d(objC);
        } else {
            if (i11 != 2) {
                if (i11 != 3) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                nVar3 = (n) dataStoreImpl$readDataAndUpdateCache$1.L$0;
                kotlin.a.d(objC);
                pair = (Pair) objC;
                c0 c0Var2 = (c0) pair.getFirst();
                if (((Boolean) pair.getSecond()).booleanValue()) {
                    return c0Var2;
                }
                nVar3.f1939h.c(c0Var2);
                return c0Var2;
            }
            nVar3 = (n) dataStoreImpl$readDataAndUpdateCache$1.L$0;
            kotlin.a.d(objC);
            pair = (Pair) objC;
            c0 c0Var22 = (c0) pair.getFirst();
            if (((Boolean) pair.getSecond()).booleanValue()) {
            }
        }
        int iIntValue = ((Number) objC).intValue();
        boolean z11 = c0Var instanceof d;
        int i12 = z11 ? c0Var.f1912a : -1;
        if (z11 && iIntValue == i12) {
            return c0Var;
        }
        if (z10) {
            u uVarG2 = nVar2.g();
            DataStoreImpl$readDataAndUpdateCache$3 dataStoreImpl$readDataAndUpdateCache$3 = new DataStoreImpl$readDataAndUpdateCache$3(nVar2, null);
            dataStoreImpl$readDataAndUpdateCache$1.L$0 = nVar2;
            dataStoreImpl$readDataAndUpdateCache$1.L$1 = null;
            dataStoreImpl$readDataAndUpdateCache$1.label = 2;
            objC = ((b0) uVarG2).b(dataStoreImpl$readDataAndUpdateCache$1, dataStoreImpl$readDataAndUpdateCache$3);
            if (objC == coroutineSingletons) {
                return coroutineSingletons;
            }
            nVar3 = nVar2;
            pair = (Pair) objC;
            c0 c0Var222 = (c0) pair.getFirst();
            if (((Boolean) pair.getSecond()).booleanValue()) {
            }
        } else {
            u uVarG3 = nVar2.g();
            DataStoreImpl$readDataAndUpdateCache$4 dataStoreImpl$readDataAndUpdateCache$4 = new DataStoreImpl$readDataAndUpdateCache$4(nVar2, i12, null);
            dataStoreImpl$readDataAndUpdateCache$1.L$0 = nVar2;
            dataStoreImpl$readDataAndUpdateCache$1.L$1 = null;
            dataStoreImpl$readDataAndUpdateCache$1.label = 3;
            objC = ((b0) uVarG3).c(dataStoreImpl$readDataAndUpdateCache$4, dataStoreImpl$readDataAndUpdateCache$1);
            if (objC == coroutineSingletons) {
                return coroutineSingletons;
            }
            nVar3 = nVar2;
            pair = (Pair) objC;
            c0 c0Var2222 = (c0) pair.getFirst();
            if (((Boolean) pair.getSecond()).booleanValue()) {
            }
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:27:0x0091  */
    /* JADX WARN: Removed duplicated region for block: B:56:0x00ef A[Catch: CorruptionException -> 0x00af, TryCatch #1 {CorruptionException -> 0x00af, blocks: (B:35:0x00aa, B:69:0x014f, B:40:0x00b8, B:66:0x0130, B:48:0x00d5, B:56:0x00ef, B:57:0x00f3, B:52:0x00de, B:63:0x011c), top: B:76:0x0023 }] */
    /* JADX WARN: Removed duplicated region for block: B:60:0x010b  */
    /* JADX WARN: Removed duplicated region for block: B:68:0x014e  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0016  */
    /* JADX WARN: Removed duplicated region for block: B:86:? A[RETURN, SYNTHETIC] */
    /* JADX WARN: Type inference failed for: r10v1, types: [T, java.lang.Object] */
    /* JADX WARN: Type inference failed for: r10v10 */
    /* JADX WARN: Type inference failed for: r10v12 */
    /* JADX WARN: Type inference failed for: r10v15 */
    /* JADX WARN: Type inference failed for: r10v20 */
    /* JADX WARN: Type inference failed for: r10v23 */
    /* JADX WARN: Type inference failed for: r10v24 */
    /* JADX WARN: Type inference failed for: r10v25 */
    /* JADX WARN: Type inference failed for: r10v26 */
    /* JADX WARN: Type inference failed for: r10v27 */
    /* JADX WARN: Type inference failed for: r10v28 */
    /* JADX WARN: Type inference failed for: r10v29 */
    /* JADX WARN: Type inference failed for: r10v9, types: [java.lang.Object] */
    /* JADX WARN: Type inference failed for: r1v10 */
    /* JADX WARN: Type inference failed for: r1v2 */
    /* JADX WARN: Type inference failed for: r1v3, types: [java.lang.Object] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object f(n nVar, boolean z10, Continuation continuation) throws CorruptionException {
        DataStoreImpl$readDataOrHandleCorruption$1 dataStoreImpl$readDataOrHandleCorruption$1;
        ?? r10;
        Integer numA;
        ?? r12;
        ?? r102;
        n nVar2;
        int i10;
        ?? r103;
        Object objC;
        ?? r104;
        CorruptionException corruptionException;
        Object objB;
        Ref$IntRef ref$IntRef;
        Ref$ObjectRef ref$ObjectRef;
        nVar.getClass();
        if (continuation instanceof DataStoreImpl$readDataOrHandleCorruption$1) {
            dataStoreImpl$readDataOrHandleCorruption$1 = (DataStoreImpl$readDataOrHandleCorruption$1) continuation;
            int i11 = dataStoreImpl$readDataOrHandleCorruption$1.label;
            if ((i11 & Integer.MIN_VALUE) != 0) {
                dataStoreImpl$readDataOrHandleCorruption$1.label = i11 - Integer.MIN_VALUE;
            } else {
                dataStoreImpl$readDataOrHandleCorruption$1 = new DataStoreImpl$readDataOrHandleCorruption$1(nVar, continuation);
            }
        }
        ?? r105 = dataStoreImpl$readDataOrHandleCorruption$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        try {
            switch (dataStoreImpl$readDataOrHandleCorruption$1.label) {
                case 0:
                    kotlin.a.d(r105);
                    if (!z10) {
                        u uVarG = nVar.g();
                        dataStoreImpl$readDataOrHandleCorruption$1.L$0 = nVar;
                        dataStoreImpl$readDataOrHandleCorruption$1.Z$0 = z10;
                        dataStoreImpl$readDataOrHandleCorruption$1.label = 3;
                        Integer numA2 = ((b0) uVarG).a();
                        r103 = numA2;
                        if (numA2 == coroutineSingletons) {
                            return coroutineSingletons;
                        }
                        int iIntValue = ((Number) r103).intValue();
                        u uVarG2 = nVar.g();
                        DataStoreImpl$readDataOrHandleCorruption$2 dataStoreImpl$readDataOrHandleCorruption$2 = new DataStoreImpl$readDataOrHandleCorruption$2(nVar, iIntValue, null);
                        dataStoreImpl$readDataOrHandleCorruption$1.L$0 = nVar;
                        dataStoreImpl$readDataOrHandleCorruption$1.Z$0 = z10;
                        dataStoreImpl$readDataOrHandleCorruption$1.label = 4;
                        objC = ((b0) uVarG2).c(dataStoreImpl$readDataOrHandleCorruption$2, dataStoreImpl$readDataOrHandleCorruption$1);
                        r104 = objC;
                        if (objC == coroutineSingletons) {
                            return coroutineSingletons;
                        }
                        return (d) r104;
                    }
                    dataStoreImpl$readDataOrHandleCorruption$1.L$0 = nVar;
                    dataStoreImpl$readDataOrHandleCorruption$1.Z$0 = z10;
                    dataStoreImpl$readDataOrHandleCorruption$1.label = 1;
                    Object objI = nVar.i(dataStoreImpl$readDataOrHandleCorruption$1);
                    r10 = objI;
                    if (objI == coroutineSingletons) {
                        return coroutineSingletons;
                    }
                    int iHashCode = r10 != 0 ? r10.hashCode() : 0;
                    u uVarG3 = nVar.g();
                    dataStoreImpl$readDataOrHandleCorruption$1.L$0 = nVar;
                    dataStoreImpl$readDataOrHandleCorruption$1.L$1 = r10;
                    dataStoreImpl$readDataOrHandleCorruption$1.Z$0 = z10;
                    dataStoreImpl$readDataOrHandleCorruption$1.I$0 = iHashCode;
                    dataStoreImpl$readDataOrHandleCorruption$1.label = 2;
                    numA = ((b0) uVarG3).a();
                    if (numA != coroutineSingletons) {
                        return coroutineSingletons;
                    }
                    r12 = r10;
                    r102 = numA;
                    nVar2 = nVar;
                    i10 = iHashCode;
                    return new d(i10, ((Number) r102).intValue(), r12);
                case 1:
                    z10 = dataStoreImpl$readDataOrHandleCorruption$1.Z$0;
                    nVar = (n) dataStoreImpl$readDataOrHandleCorruption$1.L$0;
                    kotlin.a.d(r105);
                    r10 = r105;
                    if (r10 != 0) {
                    }
                    u uVarG32 = nVar.g();
                    dataStoreImpl$readDataOrHandleCorruption$1.L$0 = nVar;
                    dataStoreImpl$readDataOrHandleCorruption$1.L$1 = r10;
                    dataStoreImpl$readDataOrHandleCorruption$1.Z$0 = z10;
                    dataStoreImpl$readDataOrHandleCorruption$1.I$0 = iHashCode;
                    dataStoreImpl$readDataOrHandleCorruption$1.label = 2;
                    numA = ((b0) uVarG32).a();
                    if (numA != coroutineSingletons) {
                    }
                    break;
                case 2:
                    i10 = dataStoreImpl$readDataOrHandleCorruption$1.I$0;
                    z10 = dataStoreImpl$readDataOrHandleCorruption$1.Z$0;
                    Object obj = dataStoreImpl$readDataOrHandleCorruption$1.L$1;
                    nVar2 = (n) dataStoreImpl$readDataOrHandleCorruption$1.L$0;
                    try {
                        kotlin.a.d(r105);
                        r12 = obj;
                        r102 = r105;
                        return new d(i10, ((Number) r102).intValue(), r12);
                    } catch (CorruptionException e10) {
                        e = e10;
                        nVar = nVar2;
                        Ref$ObjectRef ref$ObjectRef2 = new Ref$ObjectRef();
                        c cVar = nVar.f1933b;
                        dataStoreImpl$readDataOrHandleCorruption$1.L$0 = nVar;
                        dataStoreImpl$readDataOrHandleCorruption$1.L$1 = e;
                        dataStoreImpl$readDataOrHandleCorruption$1.L$2 = ref$ObjectRef2;
                        dataStoreImpl$readDataOrHandleCorruption$1.L$3 = ref$ObjectRef2;
                        dataStoreImpl$readDataOrHandleCorruption$1.Z$0 = z10;
                        dataStoreImpl$readDataOrHandleCorruption$1.label = 5;
                        ((com.google.android.material.shape.f) cVar).getClass();
                        throw e;
                    }
                case 3:
                    z10 = dataStoreImpl$readDataOrHandleCorruption$1.Z$0;
                    nVar = (n) dataStoreImpl$readDataOrHandleCorruption$1.L$0;
                    kotlin.a.d(r105);
                    r103 = r105;
                    int iIntValue2 = ((Number) r103).intValue();
                    u uVarG22 = nVar.g();
                    DataStoreImpl$readDataOrHandleCorruption$2 dataStoreImpl$readDataOrHandleCorruption$22 = new DataStoreImpl$readDataOrHandleCorruption$2(nVar, iIntValue2, null);
                    dataStoreImpl$readDataOrHandleCorruption$1.L$0 = nVar;
                    dataStoreImpl$readDataOrHandleCorruption$1.Z$0 = z10;
                    dataStoreImpl$readDataOrHandleCorruption$1.label = 4;
                    objC = ((b0) uVarG22).c(dataStoreImpl$readDataOrHandleCorruption$22, dataStoreImpl$readDataOrHandleCorruption$1);
                    r104 = objC;
                    if (objC == coroutineSingletons) {
                    }
                    return (d) r104;
                case 4:
                    boolean z11 = dataStoreImpl$readDataOrHandleCorruption$1.Z$0;
                    kotlin.a.d(r105);
                    r104 = r105;
                    return (d) r104;
                case 5:
                    boolean z12 = dataStoreImpl$readDataOrHandleCorruption$1.Z$0;
                    Ref$ObjectRef ref$ObjectRef3 = (Ref$ObjectRef) dataStoreImpl$readDataOrHandleCorruption$1.L$3;
                    Ref$ObjectRef ref$ObjectRef4 = (Ref$ObjectRef) dataStoreImpl$readDataOrHandleCorruption$1.L$2;
                    CorruptionException corruptionException2 = (CorruptionException) dataStoreImpl$readDataOrHandleCorruption$1.L$1;
                    n nVar3 = (n) dataStoreImpl$readDataOrHandleCorruption$1.L$0;
                    kotlin.a.d(r105);
                    ref$ObjectRef3.element = r105;
                    Ref$IntRef ref$IntRef2 = new Ref$IntRef();
                    try {
                        DataStoreImpl$readDataOrHandleCorruption$3 dataStoreImpl$readDataOrHandleCorruption$3 = new DataStoreImpl$readDataOrHandleCorruption$3(ref$ObjectRef4, nVar3, ref$IntRef2, null);
                        dataStoreImpl$readDataOrHandleCorruption$1.L$0 = corruptionException2;
                        dataStoreImpl$readDataOrHandleCorruption$1.L$1 = ref$ObjectRef4;
                        dataStoreImpl$readDataOrHandleCorruption$1.L$2 = ref$IntRef2;
                        dataStoreImpl$readDataOrHandleCorruption$1.L$3 = null;
                        dataStoreImpl$readDataOrHandleCorruption$1.label = 6;
                        if (z12) {
                            nVar3.getClass();
                            objB = dataStoreImpl$readDataOrHandleCorruption$3.invoke(dataStoreImpl$readDataOrHandleCorruption$1);
                        } else {
                            objB = ((b0) nVar3.g()).b(dataStoreImpl$readDataOrHandleCorruption$1, new DataStoreImpl$doWithWriteFileLock$3(null, dataStoreImpl$readDataOrHandleCorruption$3));
                        }
                        if (objB == coroutineSingletons) {
                            return coroutineSingletons;
                        }
                        ref$IntRef = ref$IntRef2;
                        ref$ObjectRef = ref$ObjectRef4;
                        Object obj2 = ref$ObjectRef.element;
                        return new d(obj2 != null ? obj2.hashCode() : 0, ref$IntRef.element, obj2);
                    } catch (Throwable th) {
                        th = th;
                        corruptionException = corruptionException2;
                        kotlin.a.a(corruptionException, th);
                        throw corruptionException;
                    }
                case 6:
                    ref$IntRef = (Ref$IntRef) dataStoreImpl$readDataOrHandleCorruption$1.L$2;
                    ref$ObjectRef = (Ref$ObjectRef) dataStoreImpl$readDataOrHandleCorruption$1.L$1;
                    corruptionException = (CorruptionException) dataStoreImpl$readDataOrHandleCorruption$1.L$0;
                    try {
                        kotlin.a.d(r105);
                        Object obj22 = ref$ObjectRef.element;
                        return new d(obj22 != null ? obj22.hashCode() : 0, ref$IntRef.element, obj22);
                    } catch (Throwable th2) {
                        th = th2;
                        kotlin.a.a(corruptionException, th);
                        throw corruptionException;
                    }
                default:
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
        } catch (CorruptionException e11) {
            e = e11;
        }
    }

    @Override // androidx.datastore.core.h
    public final Object a(Function2 function2, Continuation continuation) {
        i0 i0Var = (i0) continuation.getContext().m(h0.f1918a);
        if (i0Var != null) {
            i0Var.a(this);
        }
        return hb.a.G0(continuation, new i0(i0Var, this), new DataStoreImpl$updateData$2(this, function2, null));
    }

    public final u g() {
        return (u) this.f1942k.getValue();
    }

    @Override // androidx.datastore.core.h
    public final kotlinx.coroutines.flow.f getData() {
        return this.f1935d;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object h(Continuation continuation) throws Throwable {
        DataStoreImpl$readAndInitOrPropagateAndThrowFailure$1 dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1;
        n nVar;
        int iIntValue;
        int i10;
        Throwable th;
        n nVar2;
        if (continuation instanceof DataStoreImpl$readAndInitOrPropagateAndThrowFailure$1) {
            dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1 = (DataStoreImpl$readAndInitOrPropagateAndThrowFailure$1) continuation;
            int i11 = dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.label;
            if ((i11 & Integer.MIN_VALUE) != 0) {
                dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.label = i11 - Integer.MIN_VALUE;
            } else {
                dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1 = new DataStoreImpl$readAndInitOrPropagateAndThrowFailure$1(this, continuation);
            }
        }
        Object objA = dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.result;
        Object obj = CoroutineSingletons.f29226a;
        int i12 = dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.label;
        try {
            if (i12 == 0) {
                kotlin.a.d(objA);
                u uVarG = g();
                dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.L$0 = this;
                dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.label = 1;
                objA = ((b0) uVarG).a();
                if (objA == obj) {
                    return obj;
                }
                nVar = this;
            } else {
                if (i12 != 1) {
                    if (i12 != 2) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    i10 = dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.I$0;
                    nVar2 = (n) dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.L$0;
                    try {
                        kotlin.a.d(objA);
                        return kd.e.f29109a;
                    } catch (Throwable th2) {
                        th = th2;
                        nVar2.f1939h.c(new w(th, i10));
                        throw th;
                    }
                }
                nVar = (n) dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.L$0;
                kotlin.a.d(objA);
            }
            j jVar = nVar.f1940i;
            dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.L$0 = nVar;
            dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.I$0 = iIntValue;
            dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1.label = 2;
            if (jVar.b(dataStoreImpl$readAndInitOrPropagateAndThrowFailure$1) == obj) {
                return obj;
            }
            return kd.e.f29109a;
        } catch (Throwable th3) {
            i10 = iIntValue;
            th = th3;
            nVar2 = nVar;
            nVar2.f1939h.c(new w(th, i10));
            throw th;
        }
        iIntValue = ((Number) objA).intValue();
    }

    public final Object i(Continuation continuation) {
        return ((r) ((e0) this.f1941j.getValue())).a(new StorageConnectionKt$readData$2(3, null), continuation);
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object j(Object obj, boolean z10, Continuation continuation) {
        DataStoreImpl$writeData$1 dataStoreImpl$writeData$1;
        Ref$IntRef ref$IntRef;
        if (continuation instanceof DataStoreImpl$writeData$1) {
            dataStoreImpl$writeData$1 = (DataStoreImpl$writeData$1) continuation;
            int i10 = dataStoreImpl$writeData$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                dataStoreImpl$writeData$1.label = i10 - Integer.MIN_VALUE;
            } else {
                dataStoreImpl$writeData$1 = new DataStoreImpl$writeData$1(this, continuation);
            }
        }
        Object obj2 = dataStoreImpl$writeData$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = dataStoreImpl$writeData$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj2);
            Ref$IntRef ref$IntRef2 = new Ref$IntRef();
            e0 e0Var = (e0) this.f1941j.getValue();
            DataStoreImpl$writeData$2 dataStoreImpl$writeData$2 = new DataStoreImpl$writeData$2(ref$IntRef2, this, obj, z10, null);
            dataStoreImpl$writeData$1.L$0 = ref$IntRef2;
            dataStoreImpl$writeData$1.label = 1;
            if (((r) e0Var).b(dataStoreImpl$writeData$2, dataStoreImpl$writeData$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
            ref$IntRef = ref$IntRef2;
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ref$IntRef = (Ref$IntRef) dataStoreImpl$writeData$1.L$0;
            kotlin.a.d(obj2);
        }
        return new Integer(ref$IntRef.element);
    }
}