package com.google.android.play.core.assetpacks; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; import java.util.Iterator; import java.util.Map; /* loaded from: classes2.dex */ final class z1 { /* renamed from: d, reason: collision with root package name */ private static final r3.h0 f5185d = new r3.h0("ExtractorTaskFinder"); /* renamed from: a, reason: collision with root package name */ private final w1 f5186a; /* renamed from: b, reason: collision with root package name */ private final e0 f5187b; /* renamed from: c, reason: collision with root package name */ private final o0 f5188c; z1(w1 w1Var, e0 e0Var, o0 o0Var) { this.f5186a = w1Var; this.f5187b = e0Var; this.f5188c = o0Var; } private final boolean b(t1 t1Var, u1 u1Var) { s1 s1Var = t1Var.f5058c; String str = s1Var.f5045a; long j10 = s1Var.f5046b; return new b3(this.f5187b, str, t1Var.f5057b, j10, u1Var.f5073a).m(); } private static boolean c(u1 u1Var) { int i10 = u1Var.f5078f; return i10 == 1 || i10 == 2; } final y1 a() { y1 y1Var; y1 y1Var2; t2 t2Var; int i10; try { this.f5186a.h(); ArrayList arrayList = new ArrayList(); for (t1 t1Var : this.f5186a.f().values()) { if (d0.b(t1Var.f5058c.f5048d)) { arrayList.add(t1Var); } } if (!arrayList.isEmpty()) { Map E = this.f5187b.E(); Iterator it = arrayList.iterator(); while (true) { if (!it.hasNext()) { y1Var = null; break; } t1 t1Var2 = (t1) it.next(); Long l10 = (Long) E.get(t1Var2.f5058c.f5045a); if (l10 != null && t1Var2.f5058c.f5046b == l10.longValue()) { f5185d.a("Found promote pack task for session %s with pack %s.", Integer.valueOf(t1Var2.f5056a), t1Var2.f5058c.f5045a); int i11 = t1Var2.f5056a; String str = t1Var2.f5058c.f5045a; y1Var = new w2(i11, str, this.f5187b.o(str), t1Var2.f5057b, t1Var2.f5058c.f5046b); break; } } if (y1Var == null) { Iterator it2 = arrayList.iterator(); while (true) { if (!it2.hasNext()) { y1Var = null; break; } t1 t1Var3 = (t1) it2.next(); try { e0 e0Var = this.f5187b; s1 s1Var = t1Var3.f5058c; if (e0Var.p(s1Var.f5045a, t1Var3.f5057b, s1Var.f5046b) == t1Var3.f5058c.f5050f.size()) { f5185d.a("Found final move task for session %s with pack %s.", Integer.valueOf(t1Var3.f5056a), t1Var3.f5058c.f5045a); int i12 = t1Var3.f5056a; s1 s1Var2 = t1Var3.f5058c; y1Var = new k2(i12, s1Var2.f5045a, t1Var3.f5057b, s1Var2.f5046b, s1Var2.f5047c); break; } } catch (IOException e10) { throw new d1(String.format("Failed to check number of completed merges for session %s, pack %s", Integer.valueOf(t1Var3.f5056a), t1Var3.f5058c.f5045a), e10, t1Var3.f5056a); } } if (y1Var == null) { Iterator it3 = arrayList.iterator(); loop3: while (true) { if (!it3.hasNext()) { y1Var = null; break; } t1 t1Var4 = (t1) it3.next(); s1 s1Var3 = t1Var4.f5058c; if (d0.b(s1Var3.f5048d)) { for (u1 u1Var : s1Var3.f5050f) { e0 e0Var2 = this.f5187b; s1 s1Var4 = t1Var4.f5058c; if (e0Var2.C(s1Var4.f5045a, t1Var4.f5057b, s1Var4.f5046b, u1Var.f5073a).exists()) { f5185d.a("Found merge task for session %s with pack %s and slice %s.", Integer.valueOf(t1Var4.f5056a), t1Var4.f5058c.f5045a, u1Var.f5073a); int i13 = t1Var4.f5056a; s1 s1Var5 = t1Var4.f5058c; y1Var = new h2(i13, s1Var5.f5045a, t1Var4.f5057b, s1Var5.f5046b, u1Var.f5073a); break loop3; } } } } if (y1Var == null) { Iterator it4 = arrayList.iterator(); loop5: while (true) { if (!it4.hasNext()) { y1Var = null; break; } t1 t1Var5 = (t1) it4.next(); s1 s1Var6 = t1Var5.f5058c; if (d0.b(s1Var6.f5048d)) { for (u1 u1Var2 : s1Var6.f5050f) { if (b(t1Var5, u1Var2)) { e0 e0Var3 = this.f5187b; s1 s1Var7 = t1Var5.f5058c; if (e0Var3.B(s1Var7.f5045a, t1Var5.f5057b, s1Var7.f5046b, u1Var2.f5073a).exists()) { f5185d.a("Found verify task for session %s with pack %s and slice %s.", Integer.valueOf(t1Var5.f5056a), t1Var5.f5058c.f5045a, u1Var2.f5073a); int i14 = t1Var5.f5056a; s1 s1Var8 = t1Var5.f5058c; y1Var = new e3(i14, s1Var8.f5045a, t1Var5.f5057b, s1Var8.f5046b, u1Var2.f5073a, u1Var2.f5074b, u1Var2.f5075c); break loop5; } } } } } if (y1Var == null) { Iterator it5 = arrayList.iterator(); loop7: while (true) { if (!it5.hasNext()) { y1Var2 = null; break; } t1 t1Var6 = (t1) it5.next(); s1 s1Var9 = t1Var6.f5058c; if (d0.b(s1Var9.f5048d)) { for (u1 u1Var3 : s1Var9.f5050f) { if (!c(u1Var3)) { e0 e0Var4 = this.f5187b; s1 s1Var10 = t1Var6.f5058c; Iterator it6 = it5; try { i10 = new b3(e0Var4, s1Var10.f5045a, t1Var6.f5057b, s1Var10.f5046b, u1Var3.f5073a).a(); } catch (IOException e11) { f5185d.b("Slice checkpoint corrupt, restarting extraction. %s", e11); i10 = 0; } if (i10 != -1 && ((q1) u1Var3.f5076d.get(i10)).f5026a) { f5185d.a("Found extraction task using compression format %s for session %s, pack %s, slice %s, chunk %s.", Integer.valueOf(u1Var3.f5077e), Integer.valueOf(t1Var6.f5056a), t1Var6.f5058c.f5045a, u1Var3.f5073a, Integer.valueOf(i10)); InputStream a10 = this.f5188c.a(t1Var6.f5056a, t1Var6.f5058c.f5045a, u1Var3.f5073a, i10); int i15 = t1Var6.f5056a; s1 s1Var11 = t1Var6.f5058c; String str2 = s1Var11.f5045a; int i16 = t1Var6.f5057b; long j10 = s1Var11.f5046b; String str3 = s1Var11.f5047c; String str4 = u1Var3.f5073a; int i17 = u1Var3.f5077e; int size = u1Var3.f5076d.size(); s1 s1Var12 = t1Var6.f5058c; y1Var2 = new x0(i15, str2, i16, j10, str3, str4, i17, i10, size, s1Var12.f5049e, s1Var12.f5048d, a10); break loop7; } it5 = it6; } } } } if (y1Var2 == null) { Iterator it7 = arrayList.iterator(); loop9: while (true) { if (!it7.hasNext()) { t2Var = null; break; } t1 t1Var7 = (t1) it7.next(); s1 s1Var13 = t1Var7.f5058c; if (d0.b(s1Var13.f5048d)) { for (u1 u1Var4 : s1Var13.f5050f) { if (c(u1Var4) && ((q1) u1Var4.f5076d.get(0)).f5026a && !b(t1Var7, u1Var4)) { f5185d.a("Found patch slice task using patch format %s for session %s, pack %s, slice %s.", Integer.valueOf(u1Var4.f5078f), Integer.valueOf(t1Var7.f5056a), t1Var7.f5058c.f5045a, u1Var4.f5073a); InputStream a11 = this.f5188c.a(t1Var7.f5056a, t1Var7.f5058c.f5045a, u1Var4.f5073a, 0); int i18 = t1Var7.f5056a; String str5 = t1Var7.f5058c.f5045a; t2Var = new t2(i18, str5, this.f5187b.o(str5), this.f5187b.q(t1Var7.f5058c.f5045a), t1Var7.f5057b, t1Var7.f5058c.f5046b, u1Var4.f5078f, u1Var4.f5073a, u1Var4.f5075c, a11); break loop9; } } } } if (t2Var != null) { return t2Var; } } return y1Var2; } } } } y1Var2 = y1Var; return y1Var2; } y1Var2 = null; return y1Var2; } finally { this.f5186a.j(); } } }