package defpackage; import androidx.media3.container.NalUnitUtil; import androidx.media3.exoplayer.upstream.CmcdData; import defpackage.dw7; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.OutputStream; import java.util.Iterator; import java.util.LinkedHashSet; import java.util.List; import kotlin.Metadata; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.SuspendLambda; /* JADX INFO: loaded from: classes.dex */ @Metadata(d1 = {"\u0000\u000e\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0000\u0018\u0000*\u0004\b\u0000\u0010\u00012\b\u0012\u0004\u0012\u00028\u00000\u0002:\u0003\u0003\u0004\u0005¨\u0006\u0006"}, d2 = {"Lgu8;", "T", "Lbr1;", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "b", "c", "datastore-core"}, k = 1, mv = {1, 5, 1}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class gu8 implements br1 { public static final LinkedHashSet j = new LinkedHashSet(); public static final Object k = new Object(); public final qq3 a; public final rk1 b; public final ak1 c; public final j43 d = k63.n(new C0647ou8(this, null)); public final String e = ".tmp"; public final j65 f = v65.a(new pu8(this)); public final ig6 g = i49.a(y4a.a); public List h; public final ys8 i; @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\b\u0080\u0003\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lgu8$a;", "", "datastore-core"}, k = 1, mv = {1, 5, 1}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class a { } @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b2\u0018\u0000*\u0004\b\u0001\u0010\u00012\u00020\u0002:\u0002\u0003\u0004\u0082\u0001\u0002\u0005\u0006¨\u0006\u0007"}, d2 = {"Lgu8$b;", "T", "", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "b", "Lgu8$b$a;", "Lgu8$b$b;", "datastore-core"}, k = 1, mv = {1, 5, 1}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static abstract class b { @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\u0018\u0000*\u0004\b\u0002\u0010\u00012\b\u0012\u0004\u0012\u00028\u00020\u0002¨\u0006\u0003"}, d2 = {"Lgu8$b$a;", "T", "Lgu8$b;", "datastore-core"}, k = 1, mv = {1, 5, 1}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class a extends b { public final l29 a; public a(l29 l29Var) { this.a = l29Var; } } /* JADX INFO: renamed from: gu8$b$b, reason: collision with other inner class name */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\u0018\u0000*\u0004\b\u0002\u0010\u00012\b\u0012\u0004\u0012\u00028\u00020\u0002¨\u0006\u0003"}, d2 = {"Lgu8$b$b;", "T", "Lgu8$b;", "datastore-core"}, k = 1, mv = {1, 5, 1}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class C0144b extends b { public final SuspendLambda a; public final q81 b; public final l29 c; public final gj1 d; /* JADX WARN: Multi-variable type inference failed */ public C0144b(gr3 gr3Var, q81 q81Var, l29 l29Var, gj1 gj1Var) { cr4.g(gj1Var, "callerContext"); this.a = (SuspendLambda) gr3Var; this.b = q81Var; this.c = l29Var; this.d = gj1Var; } } } @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0002\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lgu8$c;", "Ljava/io/OutputStream;", "datastore-core"}, k = 1, mv = {1, 5, 1}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class c extends OutputStream { public final FileOutputStream a; public c(FileOutputStream fileOutputStream) { this.a = fileOutputStream; } @Override // java.io.OutputStream, java.io.Closeable, java.lang.AutoCloseable public final void close() { } @Override // java.io.OutputStream, java.io.Flushable public final void flush() throws IOException { this.a.flush(); } @Override // java.io.OutputStream public final void write(int i) throws IOException { this.a.write(i); } @Override // java.io.OutputStream public final void write(byte[] bArr) throws IOException { cr4.g(bArr, "b"); this.a.write(bArr); } @Override // java.io.OutputStream public final void write(byte[] bArr, int i, int i2) throws IOException { cr4.g(bArr, "bytes"); this.a.write(bArr, i, i2); } } public gu8(qq3 qq3Var, List list, rk1 rk1Var, ak1 ak1Var) { this.a = qq3Var; this.b = rk1Var; this.c = ak1Var; this.h = y41.bo(list); this.i = new ys8(ak1Var, new C0571hu8(this), new C0587ju8(this, null)); } /* JADX WARN: Code restructure failed: missing block: B:43:0x00a2, code lost: if (r8 != r1) goto L29; */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* JADX WARN: Type inference failed for: r2v10, types: [gr3, kotlin.coroutines.jvm.internal.SuspendLambda] */ /* JADX WARN: Type inference failed for: r2v3, types: [gr3, kotlin.coroutines.jvm.internal.SuspendLambda] */ /* JADX WARN: Type inference failed for: r8v0, types: [gu8] */ /* JADX WARN: Type inference failed for: r8v10, types: [q81] */ /* JADX WARN: Type inference failed for: r8v13 */ /* JADX WARN: Type inference failed for: r8v14 */ /* JADX WARN: Type inference failed for: r8v20 */ /* JADX WARN: Type inference failed for: r8v21 */ /* JADX WARN: Type inference failed for: r8v22 */ /* JADX WARN: Type inference failed for: r8v5 */ /* JADX WARN: Type inference failed for: r8v7 */ /* JADX WARN: Type inference failed for: r8v8, types: [gu8] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public static final Object c(gu8 gu8Var, b.C0144b c0144b, ContinuationImpl continuationImpl) { qu8 qu8Var; q81 q81Var; ?? r8; Object objJ; ?? r82; if (continuationImpl instanceof qu8) { qu8Var = (qu8) continuationImpl; int i = qu8Var.f; if ((i & Integer.MIN_VALUE) != 0) { qu8Var.f = i - Integer.MIN_VALUE; } else { qu8Var = new qu8(gu8Var, continuationImpl); } } Object objA = qu8Var.d; ck1 ck1Var = ck1.a; int i2 = qu8Var.f; boolean z = true; if (i2 != 0) { try { if (i2 != 1) { if (i2 == 2) { q81 q81Var2 = (q81) qu8Var.c; gu8 gu8Var2 = qu8Var.b; b.C0144b c0144b2 = (b.C0144b) qu8Var.a; s38.b(objA); q81Var = q81Var2; r8 = gu8Var2; c0144b = c0144b2; ?? r2 = c0144b.a; gj1 gj1Var = c0144b.d; qu8Var.a = q81Var; qu8Var.b = null; qu8Var.c = null; qu8Var.f = 3; objJ = r8.j(r2, gj1Var, qu8Var); } else if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } } q81 q81Var3 = (q81) qu8Var.a; s38.b(objA); r82 = q81Var3; } catch (Throwable th) { th = th; objA = s38.a(th); r82 = gu8Var; } } else { s38.b(objA); q81Var = c0144b.b; try { l29 l29Var = (l29) gu8Var.g.getValue(); if (l29Var instanceof xp1) { ?? r22 = c0144b.a; gj1 gj1Var2 = c0144b.d; qu8Var.a = q81Var; qu8Var.f = 1; objJ = gu8Var.j(r22, gj1Var2, qu8Var); if (objJ == ck1Var) { } q81 q81Var4 = q81Var; objA = objJ; r82 = q81Var4; } else { if (!(l29Var instanceof rt7)) { z = l29Var instanceof y4a; } if (!z) { if (l29Var instanceof e03) { throw ((e03) l29Var).a; } throw new io6(); } if (l29Var != c0144b.c) { throw ((rt7) l29Var).a; } qu8Var.a = c0144b; qu8Var.b = gu8Var; qu8Var.c = q81Var; qu8Var.f = 2; Object objF = gu8Var.f(qu8Var); r8 = gu8Var; if (objF != ck1Var) { ?? r23 = c0144b.a; gj1 gj1Var3 = c0144b.d; qu8Var.a = q81Var; qu8Var.b = null; qu8Var.c = null; qu8Var.f = 3; objJ = r8.j(r23, gj1Var3, qu8Var); } } return ck1Var; } catch (Throwable th2) { th = th2; gu8Var = q81Var; objA = s38.a(th); r82 = gu8Var; } } Throwable thA = q38.a(objA); if (thA == null) { r82.ak(objA); } else { r82.d(thA); } return e6a.a; } @Override // defpackage.br1 public final Object a(gr3 gr3Var, ContinuationImpl continuationImpl) { q81 q81VarA = s81.a(); this.i.a(new b.C0144b(gr3Var, q81VarA, (l29) this.g.getValue(), continuationImpl.getB())); return q81VarA.ab(continuationImpl); } @Override // defpackage.br1 /* JADX INFO: renamed from: b, reason: from getter */ public final j43 getD() { return this.d; } public final File d() { return (File) this.f.getValue(); } /* JADX WARN: Removed duplicated region for block: B:35:0x00d3 */ /* JADX WARN: Removed duplicated region for block: B:42:0x010a */ /* JADX WARN: Removed duplicated region for block: B:46:0x0119 */ /* JADX WARN: Removed duplicated region for block: B:47:0x011e */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object e(ContinuationImpl continuationImpl) throws qk1, FileNotFoundException { ru8 ru8Var; mg6 mg6VarA; dw7.h hVar; gu8 gu8Var; dw7.h hVar2; gu8 gu8Var2; dw7.h hVar3; tu8 tu8Var; Iterator it; mg6 mg6Var; dw7.a aVar; dw7.a aVar2; ru8 ru8Var2; gu8 gu8Var3; dw7.h hVar4; mg6 mg6Var2; if (continuationImpl instanceof ru8) { ru8Var = (ru8) continuationImpl; int i = ru8Var.k; if ((i & Integer.MIN_VALUE) != 0) { ru8Var.k = i - Integer.MIN_VALUE; } else { ru8Var = new ru8(this, continuationImpl); } } Object objI = ru8Var.i; ck1 ck1Var = ck1.a; int i2 = ru8Var.k; if (i2 == 0) { s38.b(objI); ig6 ig6Var = this.g; if (!cr4.b(ig6Var.getValue(), y4a.a) && !(ig6Var.getValue() instanceof rt7)) { throw new IllegalStateException("Check failed."); } mg6VarA = rg6.a(); hVar = new dw7.h(); ru8Var.a = this; ru8Var.b = mg6VarA; ru8Var.c = hVar; ru8Var.d = hVar; ru8Var.k = 1; objI = i(ru8Var); if (objI != ck1Var) { gu8Var = this; hVar2 = hVar; } return ck1Var; } if (i2 != 1) { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } mg6Var2 = (mg6) ru8Var.d; aVar2 = (dw7.a) ru8Var.c; hVar4 = (dw7.h) ru8Var.b; gu8Var3 = ru8Var.a; s38.b(objI); try { aVar2.a = true; mg6Var2.c(null); ig6 ig6Var2 = gu8Var3.g; Object obj = hVar4.a; ig6Var2.setValue(new xp1(obj, obj == null ? obj.hashCode() : 0)); return e6a.a; } catch (Throwable th) { mg6Var2.c(null); throw th; } } it = ru8Var.f; tu8Var = ru8Var.e; aVar = (dw7.a) ru8Var.d; hVar3 = (dw7.h) ru8Var.c; mg6Var = (mg6) ru8Var.b; gu8Var2 = ru8Var.a; s38.b(objI); while (it.hasNext()) { gr3 gr3Var = (gr3) it.next(); ru8Var.a = gu8Var2; ru8Var.b = mg6Var; ru8Var.c = hVar3; ru8Var.d = aVar; ru8Var.e = tu8Var; ru8Var.f = it; ru8Var.k = 2; if (gr3Var.invoke(tu8Var, ru8Var) == ck1Var) { break; } } ru8Var2 = ru8Var; aVar2 = aVar; hVar2 = hVar3; mg6VarA = mg6Var; gu8Var3 = gu8Var2; gu8Var3.h = null; ru8Var2.a = gu8Var3; ru8Var2.b = hVar2; ru8Var2.c = aVar2; ru8Var2.d = mg6VarA; ru8Var2.e = null; ru8Var2.f = null; ru8Var2.k = 3; if (mg6VarA.a(ru8Var2) != ck1Var) { hVar4 = hVar2; mg6Var2 = mg6VarA; aVar2.a = true; mg6Var2.c(null); ig6 ig6Var22 = gu8Var3.g; Object obj2 = hVar4.a; ig6Var22.setValue(new xp1(obj2, obj2 == null ? obj2.hashCode() : 0)); return e6a.a; } return ck1Var; } hVar = (dw7.h) ru8Var.d; hVar2 = (dw7.h) ru8Var.c; mg6VarA = (mg6) ru8Var.b; gu8Var = ru8Var.a; s38.b(objI); hVar.a = objI; dw7.a aVar3 = new dw7.a(); tu8 tu8Var2 = new tu8(mg6VarA, aVar3, hVar2, gu8Var); List list = gu8Var.h; if (list == null) { aVar2 = aVar3; ru8Var2 = ru8Var; gu8Var3 = gu8Var; gu8Var3.h = null; ru8Var2.a = gu8Var3; ru8Var2.b = hVar2; ru8Var2.c = aVar2; ru8Var2.d = mg6VarA; ru8Var2.e = null; ru8Var2.f = null; ru8Var2.k = 3; if (mg6VarA.a(ru8Var2) != ck1Var) { } return ck1Var; } gu8Var2 = gu8Var; hVar3 = hVar2; tu8Var = tu8Var2; it = list.iterator(); mg6Var = mg6VarA; aVar = aVar3; while (it.hasNext()) { } ru8Var2 = ru8Var; aVar2 = aVar; hVar2 = hVar3; mg6VarA = mg6Var; gu8Var3 = gu8Var2; gu8Var3.h = null; ru8Var2.a = gu8Var3; ru8Var2.b = hVar2; ru8Var2.c = aVar2; ru8Var2.d = mg6VarA; ru8Var2.e = null; ru8Var2.f = null; ru8Var2.k = 3; if (mg6VarA.a(ru8Var2) != ck1Var) { } return ck1Var; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object f(ContinuationImpl continuationImpl) throws Throwable { uu8 uu8Var; gu8 gu8Var; if (continuationImpl instanceof uu8) { uu8Var = (uu8) continuationImpl; int i = uu8Var.d; if ((i & Integer.MIN_VALUE) != 0) { uu8Var.d = i - Integer.MIN_VALUE; } else { uu8Var = new uu8(this, continuationImpl); } } Object obj = uu8Var.b; ck1 ck1Var = ck1.a; int i2 = uu8Var.d; if (i2 != 0) { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } gu8Var = uu8Var.a; try { s38.b(obj); return e6a.a; } catch (Throwable th) { th = th; gu8Var.g.setValue(new rt7(th)); throw th; } } s38.b(obj); try { uu8Var.a = this; uu8Var.d = 1; if (e(uu8Var) == ck1Var) { return ck1Var; } return e6a.a; } catch (Throwable th2) { th = th2; gu8Var = this; gu8Var.g.setValue(new rt7(th)); throw th; } } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object g(ContinuationImpl continuationImpl) { vu8 vu8Var; gu8 gu8Var; if (continuationImpl instanceof vu8) { vu8Var = (vu8) continuationImpl; int i = vu8Var.d; if ((i & Integer.MIN_VALUE) != 0) { vu8Var.d = i - Integer.MIN_VALUE; } else { vu8Var = new vu8(this, continuationImpl); } } Object obj = vu8Var.b; ck1 ck1Var = ck1.a; int i2 = vu8Var.d; if (i2 == 0) { s38.b(obj); try { vu8Var.a = this; vu8Var.d = 1; if (e(vu8Var) == ck1Var) { return ck1Var; } } catch (Throwable th) { th = th; gu8Var = this; gu8Var.g.setValue(new rt7(th)); } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } gu8Var = vu8Var.a; try { s38.b(obj); } catch (Throwable th2) { th = th2; gu8Var.g.setValue(new rt7(th)); } } return e6a.a; } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* JADX WARN: Type inference failed for: r0v12 */ /* JADX WARN: Type inference failed for: r0v14, types: [gu8] */ /* JADX WARN: Type inference failed for: r0v17 */ /* JADX WARN: Type inference failed for: r0v18 */ /* JADX WARN: Type inference failed for: r0v2, types: [wu8] */ /* JADX WARN: Type inference failed for: r0v3 */ /* JADX WARN: Type inference failed for: r0v4, types: [gu8] */ /* JADX WARN: Type inference failed for: r0v7 */ /* JADX WARN: Type inference failed for: r0v9 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object h(ContinuationImpl continuationImpl) throws FileNotFoundException { ?? wu8Var; FileInputStream fileInputStream; Throwable th; if (continuationImpl instanceof wu8) { wu8 wu8Var2 = (wu8) continuationImpl; int i = wu8Var2.e; if ((i & Integer.MIN_VALUE) != 0) { wu8Var2.e = i - Integer.MIN_VALUE; wu8Var = wu8Var2; } else { wu8Var = new wu8(this, continuationImpl); } } Object obj = wu8Var.c; ck1 ck1Var = ck1.a; int i2 = wu8Var.e; boolean z = true; try { if (i2 != 0) { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } fileInputStream = wu8Var.b; wu8Var = wu8Var.a; try { s38.b(obj); f21.a(fileInputStream, null); return obj; } catch (Throwable th2) { th = th2; try { throw th; } catch (Throwable th3) { f21.a(fileInputStream, th); throw th3; } } } s38.b(obj); try { FileInputStream fileInputStream2 = new FileInputStream(d()); try { rg7 rg7Var = rg7.a; wu8Var.a = this; wu8Var.b = fileInputStream2; wu8Var.e = 1; lf6 lf6VarA = rg7Var.a(fileInputStream2); if (lf6VarA == ck1Var) { return ck1Var; } fileInputStream = fileInputStream2; obj = lf6VarA; f21.a(fileInputStream, null); return obj; } catch (Throwable th4) { fileInputStream = fileInputStream2; th = th4; wu8Var = this; throw th; } } catch (FileNotFoundException e) { e = e; wu8Var = this; if (wu8Var.d().exists()) { throw e; } return new lf6(z); } } catch (FileNotFoundException e2) { e = e2; } } /* JADX WARN: Removed duplicated region for block: B:36:0x0073 */ /* JADX WARN: Removed duplicated region for block: B:39:0x0083 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:40:0x0084 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object i(ContinuationImpl continuationImpl) throws qk1, FileNotFoundException { xu8 xu8Var; gu8 gu8Var; Object objA; qk1 qk1Var; gu8 gu8Var2; qk1 qk1Var2; if (continuationImpl instanceof xu8) { xu8Var = (xu8) continuationImpl; int i = xu8Var.e; if ((i & Integer.MIN_VALUE) != 0) { xu8Var.e = i - Integer.MIN_VALUE; } else { xu8Var = new xu8(this, continuationImpl); } } Object obj = xu8Var.c; ck1 ck1Var = ck1.a; int i2 = xu8Var.e; if (i2 == 0) { s38.b(obj); try { xu8Var.a = this; xu8Var.e = 1; Object objH = h(xu8Var); if (objH != ck1Var) { return objH; } } catch (qk1 e) { e = e; gu8Var = this; rk1 rk1Var = gu8Var.b; xu8Var.a = gu8Var; xu8Var.b = e; xu8Var.e = 2; objA = rk1Var.a(e); if (objA != ck1Var) { } } } else { if (i2 != 1) { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } Object obj2 = xu8Var.b; qk1Var2 = (qk1) xu8Var.a; try { s38.b(obj); return obj2; } catch (IOException e2) { e = e2; cr2.a(qk1Var2, e); throw qk1Var2; } } qk1Var = (qk1) xu8Var.b; gu8Var2 = (gu8) xu8Var.a; s38.b(obj); try { xu8Var.a = qk1Var; xu8Var.b = obj; xu8Var.e = 3; return gu8Var2.k(obj, xu8Var) != ck1Var ? ck1Var : obj; } catch (IOException e3) { e = e3; qk1Var2 = qk1Var; cr2.a(qk1Var2, e); throw qk1Var2; } } gu8Var = (gu8) xu8Var.a; try { s38.b(obj); return obj; } catch (qk1 e4) { e = e4; } } rk1 rk1Var2 = gu8Var.b; xu8Var.a = gu8Var; xu8Var.b = e; xu8Var.e = 2; objA = rk1Var2.a(e); if (objA != ck1Var) { gu8 gu8Var3 = gu8Var; qk1Var = e; obj = objA; gu8Var2 = gu8Var3; xu8Var.a = qk1Var; xu8Var.b = obj; xu8Var.e = 3; if (gu8Var2.k(obj, xu8Var) != ck1Var) { } } } /* JADX WARN: Removed duplicated region for block: B:41:0x00a6 */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object j(gr3 gr3Var, gj1 gj1Var, ContinuationImpl continuationImpl) throws Throwable { yu8 yu8Var; xp1 xp1Var; Object obj; gu8 gu8Var; Object obj2; gu8 gu8Var2; if (continuationImpl instanceof yu8) { yu8Var = (yu8) continuationImpl; int i = yu8Var.f; if ((i & Integer.MIN_VALUE) != 0) { yu8Var.f = i - Integer.MIN_VALUE; } else { yu8Var = new yu8(this, continuationImpl); } } Object obj3 = yu8Var.d; ck1 ck1Var = ck1.a; int i2 = yu8Var.f; if (i2 == 0) { s38.b(obj3); xp1 xp1Var2 = (xp1) this.g.getValue(); Object obj4 = xp1Var2.a; if ((obj4 != null ? obj4.hashCode() : 0) != xp1Var2.b) { throw new IllegalStateException("Data in DataStore was mutated but DataStore is only compatible with Immutable types."); } Object obj5 = xp1Var2.a; C0763zu8 c0763zu8 = new C0763zu8(gr3Var, obj5, null); yu8Var.a = this; yu8Var.b = xp1Var2; yu8Var.c = obj5; yu8Var.f = 1; Object objF = wj0.f(gj1Var, c0763zu8, yu8Var); if (objF != ck1Var) { xp1Var = xp1Var2; obj3 = objF; obj = obj5; gu8Var = this; } return ck1Var; } if (i2 != 1) { if (i2 != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } obj2 = yu8Var.b; gu8Var2 = yu8Var.a; s38.b(obj3); gu8Var2.g.setValue(new xp1(obj2, obj2 != null ? obj2.hashCode() : 0)); return obj2; } obj = yu8Var.c; xp1Var = (xp1) yu8Var.b; gu8Var = yu8Var.a; s38.b(obj3); Object obj6 = xp1Var.a; if ((obj6 != null ? obj6.hashCode() : 0) != xp1Var.b) { throw new IllegalStateException("Data in DataStore was mutated but DataStore is only compatible with Immutable types."); } if (cr4.b(obj, obj3)) { return obj; } yu8Var.a = gu8Var; yu8Var.b = obj3; yu8Var.c = null; yu8Var.f = 2; if (gu8Var.k(obj3, yu8Var) != ck1Var) { obj2 = obj3; gu8Var2 = gu8Var; gu8Var2.g.setValue(new xp1(obj2, obj2 != null ? obj2.hashCode() : 0)); return obj2; } return ck1Var; } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:7:0x0015 */ /* JADX WARN: Type inference failed for: r3v0, types: [int] */ /* JADX WARN: Type inference failed for: r3v10 */ /* JADX WARN: Type inference failed for: r3v11 */ /* JADX WARN: Type inference failed for: r3v6 */ /* JADX WARN: Type inference failed for: r3v7 */ /* JADX WARN: Type inference failed for: r3v8, types: [java.io.File, java.lang.Object] */ /* JADX WARN: Type inference failed for: r3v9, types: [java.io.File] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object k(Object obj, ContinuationImpl continuationImpl) throws IOException { av8 av8Var; FileOutputStream fileOutputStream; gu8 gu8Var; FileOutputStream fileOutputStream2; if (continuationImpl instanceof av8) { av8Var = (av8) continuationImpl; int i = av8Var.i; if ((i & Integer.MIN_VALUE) != 0) { av8Var.i = i - Integer.MIN_VALUE; } else { av8Var = new av8(this, continuationImpl); } } Object obj2 = av8Var.e; ck1 ck1Var = ck1.a; File file = av8Var.i; e6a e6aVar = e6a.a; try { if (file == 0) { s38.b(obj2); File fileD = d(); File parentFile = fileD.getCanonicalFile().getParentFile(); if (parentFile != null) { parentFile.mkdirs(); if (!parentFile.isDirectory()) { throw new IOException(cr4.l(fileD, "Unable to create parent directories of ")); } } file = new File(cr4.l(this.e, d().getAbsolutePath())); FileOutputStream fileOutputStream3 = new FileOutputStream(file); try { rg7 rg7Var = rg7.a; c cVar = new c(fileOutputStream3); av8Var.a = this; av8Var.b = file; av8Var.c = fileOutputStream3; av8Var.d = fileOutputStream3; av8Var.i = 1; rg7Var.b(obj, cVar); if (e6aVar == ck1Var) { return ck1Var; } gu8Var = this; fileOutputStream2 = fileOutputStream3; fileOutputStream = fileOutputStream2; file = file; } catch (Throwable th) { th = th; fileOutputStream = fileOutputStream3; throw th; } } else { if (file != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } fileOutputStream2 = av8Var.d; fileOutputStream = av8Var.c; file = av8Var.b; gu8Var = av8Var.a; try { s38.b(obj2); file = file; } catch (Throwable th2) { th = th2; try { throw th; } catch (Throwable th3) { f21.a(fileOutputStream, th); throw th3; } } } fileOutputStream2.getFD().sync(); f21.a(fileOutputStream, null); if (file.renameTo(gu8Var.d())) { return e6aVar; } throw new IOException("Unable to rename " + ((Object) file) + ".This likely means that there are multiple instances of DataStore for this file. Ensure that you are only creating a single instance of datastore for this file."); } catch (IOException e) { if (file.exists()) { file.delete(); } throw e; } } }