package com.vungle.warren.downloader; import android.text.TextUtils; import android.util.Log; import com.vungle.warren.VungleLogger; import com.vungle.warren.downloader.a; import com.vungle.warren.utility.o; import com.vungle.warren.utility.z; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.net.SocketException; import java.net.SocketTimeoutException; import java.net.UnknownHostException; import java.nio.channels.FileChannel; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import javax.net.ssl.SSLException; import n9.b0; import n9.e0; import n9.g0; import n9.h0; import n9.x; import x9.l; import x9.n; /* loaded from: classes2.dex */ public class b implements com.vungle.warren.downloader.g { /* renamed from: p, reason: collision with root package name */ public static final long f8094p = TimeUnit.HOURS.toMillis(24); /* renamed from: q, reason: collision with root package name */ private static final String f8095q = b.class.getSimpleName(); /* renamed from: a, reason: collision with root package name */ private final com.vungle.warren.downloader.h f8096a; /* renamed from: b, reason: collision with root package name */ private final long f8097b; /* renamed from: f, reason: collision with root package name */ private final o f8101f; /* renamed from: g, reason: collision with root package name */ private final z f8102g; /* renamed from: h, reason: collision with root package name */ private final b0 f8103h; /* renamed from: i, reason: collision with root package name */ private final ExecutorService f8104i; /* renamed from: c, reason: collision with root package name */ int f8098c = 5; /* renamed from: d, reason: collision with root package name */ int f8099d = 10; /* renamed from: e, reason: collision with root package name */ int f8100e = 300; /* renamed from: j, reason: collision with root package name */ private Map f8105j = new ConcurrentHashMap(); /* renamed from: k, reason: collision with root package name */ private List f8106k = new ArrayList(); /* renamed from: l, reason: collision with root package name */ private final Object f8107l = new Object(); /* renamed from: m, reason: collision with root package name */ private volatile int f8108m = 5; /* renamed from: n, reason: collision with root package name */ private boolean f8109n = true; /* renamed from: o, reason: collision with root package name */ private final o.d f8110o = new e(); class a extends i { /* renamed from: e, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.f f8111e; /* renamed from: f, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.a f8112f; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ a(com.vungle.warren.downloader.c cVar, com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar) { super(cVar); this.f8111e = fVar; this.f8112f = aVar; } @Override // java.lang.Runnable public void run() { VungleLogger.i(true, b.f8095q, "ttDownloadContext", String.format("Start to download asset %1$s, at: %2$d", this.f8111e, Long.valueOf(System.currentTimeMillis()))); try { b.this.h0(this.f8111e, this.f8112f); } catch (IOException e10) { VungleLogger.c("AssetDownloader#download; loadAd sequence", "cannot launch request due to " + e10); Log.e(b.f8095q, "Error on launching request", e10); b.this.W(this.f8111e, this.f8112f, new a.C0121a(-1, e10, 1)); } } } /* renamed from: com.vungle.warren.downloader.b$b, reason: collision with other inner class name */ class RunnableC0122b implements Runnable { /* renamed from: a, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.f f8114a; /* renamed from: b, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.a f8115b; RunnableC0122b(com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar) { this.f8114a = fVar; this.f8115b = aVar; } @Override // java.lang.Runnable public void run() { b.this.W(this.f8114a, this.f8115b, new a.C0121a(-1, new com.vungle.warren.error.a(39), 1)); } } class c extends i { /* renamed from: e, reason: collision with root package name */ final /* synthetic */ DownloadRequestMediator f8117e; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ c(DownloadRequestMediator downloadRequestMediator, DownloadRequestMediator downloadRequestMediator2) { super(downloadRequestMediator); this.f8117e = downloadRequestMediator2; } /* JADX ERROR: Type inference failed jadx.core.utils.exceptions.JadxOverflowException: Type inference error: updates count limit reached at jadx.core.utils.ErrorsCounter.addError(ErrorsCounter.java:59) at jadx.core.utils.ErrorsCounter.error(ErrorsCounter.java:31) at jadx.core.dex.attributes.nodes.NotificationAttrNode.addError(NotificationAttrNode.java:19) at jadx.core.dex.visitors.typeinference.TypeInferenceVisitor.visit(TypeInferenceVisitor.java:77) */ @Override // java.lang.Runnable public void run() { /* Method dump skipped, instructions count: 3695 To view this dump change 'Code comments level' option to 'DEBUG' */ throw new UnsupportedOperationException("Method not decompiled: com.vungle.warren.downloader.b.c.run():void"); } } class d implements Runnable { /* renamed from: a, reason: collision with root package name */ final /* synthetic */ DownloadRequestMediator f8119a; d(DownloadRequestMediator downloadRequestMediator) { this.f8119a = downloadRequestMediator; } @Override // java.lang.Runnable public void run() { b.this.q0(new a.C0121a(-1, new com.vungle.warren.error.a(39), 1), this.f8119a); } } class e implements o.d { e() { } @Override // com.vungle.warren.utility.o.d public void a(int i10) { Log.d(b.f8095q, "Network changed: " + i10); b.this.r0(i10); } } class f implements Runnable { /* renamed from: a, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.a f8122a; /* renamed from: b, reason: collision with root package name */ final /* synthetic */ a.C0121a f8123b; /* renamed from: c, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.f f8124c; f(com.vungle.warren.downloader.a aVar, a.C0121a c0121a, com.vungle.warren.downloader.f fVar) { this.f8122a = aVar; this.f8123b = c0121a; this.f8124c = fVar; } @Override // java.lang.Runnable public void run() { this.f8122a.b(this.f8123b, this.f8124c); } } class g implements Runnable { /* renamed from: a, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.f f8126a; /* renamed from: b, reason: collision with root package name */ final /* synthetic */ com.vungle.warren.downloader.a f8127b; /* renamed from: c, reason: collision with root package name */ final /* synthetic */ a.b f8128c; g(com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar, a.b bVar) { this.f8126a = fVar; this.f8127b = aVar; this.f8128c = bVar; } @Override // java.lang.Runnable public void run() { Log.d(b.f8095q, "On progress " + this.f8126a); this.f8127b.c(this.f8128c, this.f8126a); } } class h implements Runnable { /* renamed from: a, reason: collision with root package name */ final /* synthetic */ DownloadRequestMediator f8130a; h(DownloadRequestMediator downloadRequestMediator) { this.f8130a = downloadRequestMediator; } @Override // java.lang.Runnable public void run() { b.this.q0(new a.C0121a(-1, new com.vungle.warren.error.a(39), 1), this.f8130a); } } public b(com.vungle.warren.downloader.h hVar, long j10, o oVar, z zVar, ExecutorService executorService) { this.f8096a = hVar; this.f8097b = j10; this.f8102g = zVar; this.f8101f = oVar; this.f8104i = executorService; b0.b bVar = new b0.b(); TimeUnit timeUnit = TimeUnit.SECONDS; this.f8103h = bVar.g(30L, timeUnit).d(30L, timeUnit).c(null).e(true).f(true).b(); } static /* synthetic */ boolean A(b bVar, DownloadRequestMediator downloadRequestMediator, a.b bVar2, a.C0121a c0121a) { return bVar.v0(downloadRequestMediator, bVar2, c0121a); } /* JADX INFO: Access modifiers changed from: private */ public void A0(long j10) { try { Thread.sleep(Math.max(0L, j10)); } catch (InterruptedException e10) { Log.e(f8095q, "InterruptedException ", e10); Thread.currentThread().interrupt(); } } static /* synthetic */ void B(b bVar, File file, DownloadRequestMediator downloadRequestMediator) { bVar.t0(file, downloadRequestMediator); } /* JADX INFO: Access modifiers changed from: private */ public boolean B0(DownloadRequestMediator downloadRequestMediator, File file, Map map, int i10) { return this.f8096a != null && downloadRequestMediator.isCacheable && i10 != 200 && i10 != 416 && i10 != 206 && Boolean.parseBoolean((String) map.get("DOWNLOAD_COMPLETE")) && file.exists() && file.length() > 0; } static /* synthetic */ void C(b bVar, a.C0121a c0121a, DownloadRequestMediator downloadRequestMediator) { bVar.q0(c0121a, downloadRequestMediator); } /* JADX INFO: Access modifiers changed from: private */ public boolean C0(DownloadRequestMediator downloadRequestMediator, File file, Map map) { String str; if (map == null || this.f8096a == null || !downloadRequestMediator.isCacheable || (str = (String) map.get("Last-Cache-Verification")) == null || !file.exists() || !Boolean.parseBoolean((String) map.get("DOWNLOAD_COMPLETE"))) { return false; } try { long parseLong = Long.parseLong(str); long j10 = this.f8097b; return j10 >= Long.MAX_VALUE - parseLong || parseLong + j10 >= System.currentTimeMillis(); } catch (NumberFormatException unused) { return false; } } static /* synthetic */ void D(b bVar, DownloadRequestMediator downloadRequestMediator) { bVar.p0(downloadRequestMediator); } static /* synthetic */ void E(b bVar, DownloadRequestMediator downloadRequestMediator) { bVar.w0(downloadRequestMediator); } static /* synthetic */ void F(b bVar) { bVar.x0(); } static /* synthetic */ com.vungle.warren.downloader.h H(b bVar) { return bVar.f8096a; } static /* synthetic */ String I(b bVar, DownloadRequestMediator downloadRequestMediator) { return bVar.T(downloadRequestMediator); } static /* synthetic */ boolean J(b bVar, DownloadRequestMediator downloadRequestMediator) { return bVar.e0(downloadRequestMediator); } static /* synthetic */ HashMap K(b bVar, File file) { return bVar.Z(file); } static /* synthetic */ boolean L(b bVar, DownloadRequestMediator downloadRequestMediator, File file, Map map) { return bVar.C0(downloadRequestMediator, file, map); } static /* synthetic */ void M(b bVar, long j10, File file, HashMap hashMap, e0.a aVar) { bVar.P(j10, file, hashMap, aVar); } static /* synthetic */ b0 N(b bVar) { return bVar.f8103h; } private void O() { Log.d(f8095q, "Adding network listner"); this.f8101f.d(this.f8110o); } /* JADX INFO: Access modifiers changed from: private */ public void P(long j10, File file, HashMap hashMap, e0.a aVar) { aVar.a("Accept-Encoding", "identity"); if (!file.exists() || hashMap.isEmpty()) { return; } String str = (String) hashMap.get("ETag"); String str2 = (String) hashMap.get("Last-Modified"); if (Boolean.parseBoolean((String) hashMap.get("DOWNLOAD_COMPLETE"))) { if (!TextUtils.isEmpty(str)) { aVar.a("If-None-Match", str); } if (TextUtils.isEmpty(str2)) { return; } aVar.a("If-Modified-Since", str2); return; } if ("bytes".equalsIgnoreCase((String) hashMap.get("Accept-Ranges"))) { if (hashMap.get("Content-Encoding") == null || "identity".equalsIgnoreCase((String) hashMap.get("Content-Encoding"))) { aVar.a("Range", "bytes=" + j10 + "-"); if (!TextUtils.isEmpty(str)) { aVar.a("If-Range", str); } else { if (TextUtils.isEmpty(str2)) { return; } aVar.a("If-Range", str2); } } } } /* JADX INFO: Access modifiers changed from: private */ public void Q(File file, File file2, x xVar) { String c10 = xVar.c("Content-Encoding"); if (c10 == null || "gzip".equalsIgnoreCase(c10) || "identity".equalsIgnoreCase(c10)) { return; } V(file, file2, false); VungleLogger.c("AssetDownloader#checkEncoding; loadAd sequence", String.format("unknown %1$s %2$s ", "Content-Encoding", c10)); throw new IOException("Unknown Content-Encoding"); } private void R(File file, File file2, y.d dVar) { FileOutputStream fileOutputStream; IOException e10; FileInputStream fileInputStream; if (file2.exists()) { com.vungle.warren.utility.j.c(file2); } if (file2.getParentFile() != null && !file2.getParentFile().exists()) { file2.getParentFile().mkdirs(); } FileInputStream fileInputStream2 = null; try { try { fileInputStream = new FileInputStream(file); try { fileOutputStream = new FileOutputStream(file2); } catch (IOException e11) { fileOutputStream = null; e10 = e11; } catch (Throwable th) { th = th; fileOutputStream = null; fileInputStream2 = fileInputStream; com.vungle.warren.utility.j.a(fileInputStream2); com.vungle.warren.utility.j.a(fileOutputStream); throw th; } } catch (IOException e12) { fileOutputStream = null; e10 = e12; fileInputStream = null; } catch (Throwable th2) { th = th2; fileOutputStream = null; com.vungle.warren.utility.j.a(fileInputStream2); com.vungle.warren.utility.j.a(fileOutputStream); throw th; } try { FileChannel channel = fileInputStream.getChannel(); channel.transferTo(0L, channel.size(), fileOutputStream.getChannel()); Log.d(f8095q, "Copying: finished " + ((com.vungle.warren.downloader.f) dVar.f15524a).f8147b + " copying to " + file2.getPath()); } catch (IOException e13) { e10 = e13; VungleLogger.c("AssetDownloader#copyToDestination; loadAd sequence", String.format("cannot copy from %1$s(%2$s) to %3$s due to %4$s", file.getPath(), ((com.vungle.warren.downloader.f) dVar.f15524a).f8147b, file2.getPath(), e10)); W((com.vungle.warren.downloader.f) dVar.f15524a, (com.vungle.warren.downloader.a) dVar.f15525b, new a.C0121a(-1, e10, 2)); Log.d(f8095q, "Copying: error" + ((com.vungle.warren.downloader.f) dVar.f15524a).f8147b + " copying to " + file2.getPath()); com.vungle.warren.utility.j.a(fileInputStream); com.vungle.warren.utility.j.a(fileOutputStream); } com.vungle.warren.utility.j.a(fileInputStream); com.vungle.warren.utility.j.a(fileOutputStream); } catch (Throwable th3) { th = th3; } } private String S(com.vungle.warren.downloader.f fVar) { return ", single request url - " + fVar.f8147b + ", path - " + fVar.f8148c + ", th - " + Thread.currentThread().getName() + "id " + fVar.f8151f; } /* JADX INFO: Access modifiers changed from: private */ public String T(DownloadRequestMediator downloadRequestMediator) { return ", mediator url - " + downloadRequestMediator.url + ", path - " + downloadRequestMediator.filePath + ", th - " + Thread.currentThread().getName() + "id " + downloadRequestMediator; } /* JADX INFO: Access modifiers changed from: private */ public h0 U(g0 g0Var) { if (!"gzip".equalsIgnoreCase(g0Var.O("Content-Encoding")) || !r9.e.c(g0Var) || g0Var.c() == null) { return g0Var.c(); } return new r9.h(g0Var.O("Content-Type"), -1L, n.c(new l(g0Var.c().S()))); } /* JADX INFO: Access modifiers changed from: private */ public void V(File file, File file2, boolean z10) { if (file == null) { return; } com.vungle.warren.utility.j.c(file); if (file2 != null) { com.vungle.warren.utility.j.c(file2); } if (this.f8096a == null || !f0()) { return; } if (z10) { this.f8096a.j(file); } else { this.f8096a.a(file); } } /* JADX INFO: Access modifiers changed from: private */ public void W(com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar, a.C0121a c0121a) { Object[] objArr = new Object[2]; objArr[0] = c0121a; objArr[1] = fVar != null ? S(fVar) : "null"; VungleLogger.c("AssetDownloader#deliverError; loadAd sequence", String.format("Delivering error %1$s; request %2$s", objArr)); if (aVar != null) { this.f8104i.execute(new f(aVar, c0121a, fVar)); } } private void X(a.b bVar, com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar) { if (aVar != null) { this.f8104i.execute(new g(fVar, aVar, bVar)); } } private void Y(y.d dVar, File file) { Object obj = dVar.f15525b; if (obj != null) { ((com.vungle.warren.downloader.a) obj).a(file, (com.vungle.warren.downloader.f) dVar.f15524a); } } /* JADX INFO: Access modifiers changed from: private */ public HashMap Z(File file) { return com.vungle.warren.utility.j.f(file.getPath()); } private synchronized DownloadRequestMediator a0(com.vungle.warren.downloader.f fVar) { ArrayList arrayList = new ArrayList(2); arrayList.add(this.f8105j.get(b0(fVar))); arrayList.add(this.f8105j.get(d0(fVar))); for (DownloadRequestMediator downloadRequestMediator : arrayList) { if (downloadRequestMediator != null) { Iterator it = downloadRequestMediator.requests().iterator(); while (it.hasNext()) { if (it.next().equals(fVar)) { return downloadRequestMediator; } } } } return null; } private String b0(com.vungle.warren.downloader.f fVar) { return fVar.f8147b; } /* JADX INFO: Access modifiers changed from: private */ public long c0(g0 g0Var) { if (g0Var == null) { return -1L; } String c10 = g0Var.R().c("Content-Length"); if (TextUtils.isEmpty(c10)) { return -1L; } try { return Long.parseLong(c10); } catch (Throwable unused) { return -1L; } } private String d0(com.vungle.warren.downloader.f fVar) { return fVar.f8147b + " " + fVar.f8148c; } /* JADX INFO: Access modifiers changed from: private */ public boolean e0(DownloadRequestMediator downloadRequestMediator) { for (com.vungle.warren.downloader.f fVar : downloadRequestMediator.requests()) { if (fVar == null) { Log.d(f8095q, "Request is null"); } else if (g0(fVar)) { return true; } } return false; } /* JADX WARN: Removed duplicated region for block: B:21:0x002b */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct code enable 'Show inconsistent code' option in preferences */ private boolean g0(com.vungle.warren.downloader.f r6) { /* r5 = this; com.vungle.warren.utility.o r0 = r5.f8101f int r0 = r0.e() r1 = 1 if (r0 < 0) goto Lf int r2 = r6.f8146a r3 = 3 if (r2 != r3) goto Lf return r1 Lf: if (r0 == 0) goto L28 if (r0 == r1) goto L26 r2 = 4 if (r0 == r2) goto L28 r2 = 9 if (r0 == r2) goto L26 r2 = 17 if (r0 == r2) goto L28 r2 = 6 if (r0 == r2) goto L26 r2 = 7 if (r0 == r2) goto L28 r2 = -1 goto L29 L26: r2 = 2 goto L29 L28: r2 = 1 L29: if (r2 <= 0) goto L31 int r3 = r6.f8146a r3 = r3 & r2 if (r3 != r2) goto L31 goto L32 L31: r1 = 0 L32: java.lang.String r2 = com.vungle.warren.downloader.b.f8095q java.lang.StringBuilder r3 = new java.lang.StringBuilder r3.() java.lang.String r4 = "checking pause for type: " r3.append(r4) r3.append(r0) java.lang.String r0 = " connected " r3.append(r0) r3.append(r1) java.lang.String r6 = r5.S(r6) r3.append(r6) java.lang.String r6 = r3.toString() android.util.Log.d(r2, r6) return r1 */ throw new UnsupportedOperationException("Method not decompiled: com.vungle.warren.downloader.b.g0(com.vungle.warren.downloader.f):boolean"); } /* JADX INFO: Access modifiers changed from: private */ public void h0(com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar) { synchronized (this.f8107l) { synchronized (this) { if (fVar.c()) { this.f8106k.remove(fVar); Log.d(f8095q, "Request " + fVar.f8147b + " is cancelled before starting"); new a.b().f8089a = 3; W(fVar, aVar, new a.C0121a(-1, new IOException("Cancelled"), 1)); return; } DownloadRequestMediator downloadRequestMediator = (DownloadRequestMediator) this.f8105j.get(m0(fVar)); if (downloadRequestMediator == null) { this.f8106k.remove(fVar); DownloadRequestMediator k02 = k0(fVar, aVar); this.f8105j.put(k02.key, k02); i0(k02); return; } try { downloadRequestMediator.lock(); synchronized (this) { this.f8106k.remove(fVar); if (!downloadRequestMediator.is(6) && (!downloadRequestMediator.is(3) || fVar.c())) { if (downloadRequestMediator.isCacheable) { downloadRequestMediator.add(fVar, aVar); if (downloadRequestMediator.is(2)) { i0(downloadRequestMediator); } } else { VungleLogger.j("AssetDownloader#launchRequest; loadAd sequence", "request " + fVar + " is already running"); W(fVar, aVar, new a.C0121a(-1, new IllegalArgumentException("DownloadRequest is already running"), 1)); } } DownloadRequestMediator k03 = k0(fVar, aVar); this.f8105j.put(downloadRequestMediator.key, k03); i0(k03); } } finally { downloadRequestMediator.unlock(); } } } } private synchronized void i0(DownloadRequestMediator downloadRequestMediator) { O(); downloadRequestMediator.set(1); this.f8102g.a(new c(downloadRequestMediator, downloadRequestMediator), new d(downloadRequestMediator)); } /* JADX INFO: Access modifiers changed from: private */ public HashMap j0(File file, x xVar, String str) { HashMap hashMap = new HashMap(); hashMap.put("Download_URL", str); hashMap.put("ETag", xVar.c("ETag")); hashMap.put("Last-Modified", xVar.c("Last-Modified")); hashMap.put("Accept-Ranges", xVar.c("Accept-Ranges")); hashMap.put("Content-Encoding", xVar.c("Content-Encoding")); z0(file, hashMap); return hashMap; } static /* synthetic */ String k() { return f8095q; } private DownloadRequestMediator k0(com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar) { File b10; File f10; String str; boolean z10; if (f0()) { b10 = this.f8096a.b(fVar.f8147b); f10 = this.f8096a.f(b10); str = fVar.f8147b; z10 = true; } else { b10 = new File(fVar.f8148c); f10 = new File(b10.getPath() + ".vng_meta"); str = fVar.f8147b + " " + fVar.f8148c; z10 = false; } Log.d(f8095q, "Destination file " + b10.getPath()); return new DownloadRequestMediator(fVar, aVar, b10.getPath(), f10.getPath(), z10, str); } /* JADX INFO: Access modifiers changed from: private */ public int l0(Throwable th, boolean z10) { if (th instanceof RuntimeException) { return 4; } if (!z10 || (th instanceof SocketException) || (th instanceof SocketTimeoutException)) { return 0; } return ((th instanceof UnknownHostException) || (th instanceof SSLException)) ? 1 : 2; } static /* synthetic */ long m(b bVar, g0 g0Var) { return bVar.c0(g0Var); } private String m0(com.vungle.warren.downloader.f fVar) { return f0() ? b0(fVar) : d0(fVar); } static /* synthetic */ boolean n(b bVar, File file, g0 g0Var, DownloadRequestMediator downloadRequestMediator, HashMap hashMap) { return bVar.n0(file, g0Var, downloadRequestMediator, hashMap); } /* JADX INFO: Access modifiers changed from: private */ public boolean n0(File file, g0 g0Var, DownloadRequestMediator downloadRequestMediator, HashMap hashMap) { if (g0Var != null && file.exists() && file.length() > 0 && downloadRequestMediator.isCacheable) { int G = g0Var.G(); if (Boolean.parseBoolean((String) hashMap.get("DOWNLOAD_COMPLETE")) && G == 304) { Log.d(f8095q, "304 code, data size matches file size " + T(downloadRequestMediator)); return true; } } return false; } static /* synthetic */ boolean o(b bVar, DownloadRequestMediator downloadRequestMediator, File file, Map map, int i10) { return bVar.B0(downloadRequestMediator, file, map, i10); } private void o0(com.vungle.warren.downloader.f fVar) { if (fVar.c()) { return; } fVar.a(); DownloadRequestMediator a02 = a0(fVar); if (a02 != null && a02.getStatus() != 3) { y.d remove = a02.remove(fVar); com.vungle.warren.downloader.f fVar2 = remove == null ? null : (com.vungle.warren.downloader.f) remove.f15524a; com.vungle.warren.downloader.a aVar = remove != null ? (com.vungle.warren.downloader.a) remove.f15525b : null; if (a02.values().isEmpty()) { a02.set(3); } if (fVar2 == null) { return; } a.b bVar = new a.b(); bVar.f8089a = 3; X(bVar, fVar2, aVar); } x0(); } static /* synthetic */ void p(b bVar, File file, HashMap hashMap) { bVar.z0(file, hashMap); } /* JADX INFO: Access modifiers changed from: private */ public synchronized void p0(DownloadRequestMediator downloadRequestMediator) { Iterator it = downloadRequestMediator.requests().iterator(); while (it.hasNext()) { o0(it.next()); } } static /* synthetic */ boolean q(b bVar, long j10, int i10, g0 g0Var, DownloadRequestMediator downloadRequestMediator) { return bVar.u0(j10, i10, g0Var, downloadRequestMediator); } /* JADX INFO: Access modifiers changed from: private */ public void q0(a.C0121a c0121a, DownloadRequestMediator downloadRequestMediator) { VungleLogger.c("AssetDownloader#onErrorMediator; loadAd sequence", String.format("Error %1$s occured; mediator %2$s", c0121a, T(downloadRequestMediator))); if (c0121a == null) { c0121a = new a.C0121a(-1, new RuntimeException(), 4); } try { downloadRequestMediator.lock(); for (y.d dVar : downloadRequestMediator.values()) { W((com.vungle.warren.downloader.f) dVar.f15524a, (com.vungle.warren.downloader.a) dVar.f15525b, c0121a); } w0(downloadRequestMediator); downloadRequestMediator.set(6); } finally { downloadRequestMediator.unlock(); } } static /* synthetic */ void r(b bVar, File file, File file2, boolean z10) { bVar.V(file, file2, z10); } /* JADX INFO: Access modifiers changed from: private */ public synchronized void r0(int i10) { Log.d(f8095q, "Num of connections: " + this.f8105j.values().size()); for (DownloadRequestMediator downloadRequestMediator : this.f8105j.values()) { if (downloadRequestMediator.is(3)) { Log.d(f8095q, "Result cancelled"); } else { boolean e02 = e0(downloadRequestMediator); String str = f8095q; Log.d(str, "Connected = " + e02 + " for " + i10); downloadRequestMediator.setConnected(e02); if (downloadRequestMediator.isPausable() && e02 && downloadRequestMediator.is(2)) { i0(downloadRequestMediator); Log.d(str, "resumed " + downloadRequestMediator.key + " " + downloadRequestMediator); } } } } static /* synthetic */ void s(b bVar, File file, File file2, x xVar) { bVar.Q(file, file2, xVar); } /* JADX INFO: Access modifiers changed from: private */ public void s0(DownloadRequestMediator downloadRequestMediator, a.b bVar) { if (downloadRequestMediator == null) { return; } a.b a10 = a.b.a(bVar); Log.d(f8095q, "Progress " + bVar.f8090b + " status " + bVar.f8089a + " " + downloadRequestMediator + " " + downloadRequestMediator.filePath); for (y.d dVar : downloadRequestMediator.values()) { X(a10, (com.vungle.warren.downloader.f) dVar.f15524a, (com.vungle.warren.downloader.a) dVar.f15525b); } } static /* synthetic */ HashMap t(b bVar, File file, x xVar, String str) { return bVar.j0(file, xVar, str); } /* JADX INFO: Access modifiers changed from: private */ public void t0(File file, DownloadRequestMediator downloadRequestMediator) { Log.d(f8095q, "OnComplete - Removing connections and listener " + downloadRequestMediator); try { downloadRequestMediator.lock(); List values = downloadRequestMediator.values(); if (!file.exists()) { VungleLogger.c("AssetDownloader#onSuccessMediator; loadAd sequence", String.format("File %1$s does not exist; mediator %2$s ", file.getPath(), T(downloadRequestMediator))); q0(new a.C0121a(-1, new IOException("File is deleted"), 2), downloadRequestMediator); return; } com.vungle.warren.downloader.h hVar = this.f8096a; if (hVar != null && downloadRequestMediator.isCacheable) { hVar.e(file, values.size()); this.f8096a.d(file, System.currentTimeMillis()); } for (y.d dVar : values) { File file2 = new File(((com.vungle.warren.downloader.f) dVar.f15524a).f8148c); if (file2.equals(file)) { file2 = file; } else { R(file, file2, dVar); } Log.d(f8095q, "Deliver success:" + ((com.vungle.warren.downloader.f) dVar.f15524a).f8147b + " dest file: " + file2.getPath()); Y(dVar, file2); } w0(downloadRequestMediator); downloadRequestMediator.set(6); Log.d(f8095q, "Finished " + T(downloadRequestMediator)); } finally { downloadRequestMediator.unlock(); } } static /* synthetic */ h0 u(b bVar, g0 g0Var) { return bVar.U(g0Var); } /* JADX INFO: Access modifiers changed from: private */ public boolean u0(long j10, int i10, g0 g0Var, DownloadRequestMediator downloadRequestMediator) { return (i10 == 206 && !y0(g0Var, j10, downloadRequestMediator)) || i10 == 416; } static /* synthetic */ void v(b bVar, DownloadRequestMediator downloadRequestMediator, a.b bVar2) { bVar.s0(downloadRequestMediator, bVar2); } /* JADX INFO: Access modifiers changed from: private */ public boolean v0(DownloadRequestMediator downloadRequestMediator, a.b bVar, a.C0121a c0121a) { if (downloadRequestMediator.is(3) || e0(downloadRequestMediator)) { return false; } bVar.f8089a = 2; a.b a10 = a.b.a(bVar); boolean z10 = false; for (y.d dVar : downloadRequestMediator.values()) { com.vungle.warren.downloader.f fVar = (com.vungle.warren.downloader.f) dVar.f15524a; if (fVar != null) { if (fVar.f8149d) { downloadRequestMediator.set(2); Log.d(f8095q, "Pausing download " + S(fVar)); X(a10, (com.vungle.warren.downloader.f) dVar.f15524a, (com.vungle.warren.downloader.a) dVar.f15525b); z10 = true; } else { downloadRequestMediator.remove(fVar); W(fVar, (com.vungle.warren.downloader.a) dVar.f15525b, c0121a); } } } if (!z10) { downloadRequestMediator.set(5); } String str = f8095q; StringBuilder sb = new StringBuilder(); sb.append("Attempted to pause - "); sb.append(downloadRequestMediator.getStatus() == 2); Log.d(str, sb.toString()); return z10; } /* JADX INFO: Access modifiers changed from: private */ public synchronized void w0(DownloadRequestMediator downloadRequestMediator) { this.f8105j.remove(downloadRequestMediator.key); } static /* synthetic */ int x(b bVar) { return bVar.f8108m; } /* JADX INFO: Access modifiers changed from: private */ public void x0() { if (this.f8105j.isEmpty()) { Log.d(f8095q, "Removing listener"); this.f8101f.j(this.f8110o); } } static /* synthetic */ int y(b bVar, Throwable th, boolean z10) { return bVar.l0(th, z10); } private boolean y0(g0 g0Var, long j10, DownloadRequestMediator downloadRequestMediator) { boolean z10; j jVar = new j(g0Var.R().c("Content-Range")); if (g0Var.G() == 206 && "bytes".equalsIgnoreCase(jVar.f8157a)) { long j11 = jVar.f8158b; if (j11 >= 0 && j10 == j11) { z10 = true; Log.d(f8095q, "satisfies partial download: " + z10 + " " + T(downloadRequestMediator)); return z10; } } z10 = false; Log.d(f8095q, "satisfies partial download: " + z10 + " " + T(downloadRequestMediator)); return z10; } static /* synthetic */ void z(b bVar, long j10) { bVar.A0(j10); } /* JADX INFO: Access modifiers changed from: private */ public void z0(File file, HashMap hashMap) { com.vungle.warren.utility.j.i(file.getPath(), hashMap); } @Override // com.vungle.warren.downloader.g public synchronized void a() { Log.d(f8095q, "Cancelling all"); for (com.vungle.warren.downloader.f fVar : this.f8106k) { Log.d(f8095q, "Cancel in transtiotion " + fVar.f8147b); i(fVar); } Log.d(f8095q, "Cancel in mediator " + this.f8105j.values().size()); for (DownloadRequestMediator downloadRequestMediator : this.f8105j.values()) { Log.d(f8095q, "Cancel in mediator " + downloadRequestMediator.key); p0(downloadRequestMediator); } } @Override // com.vungle.warren.downloader.g public synchronized void b() { com.vungle.warren.downloader.h hVar = this.f8096a; if (hVar != null) { hVar.clear(); } } @Override // com.vungle.warren.downloader.g public synchronized void c() { com.vungle.warren.downloader.h hVar = this.f8096a; if (hVar != null) { hVar.c(); } } @Override // com.vungle.warren.downloader.g public synchronized void d(com.vungle.warren.downloader.f fVar, com.vungle.warren.downloader.a aVar) { if (fVar == null) { VungleLogger.c("AssetDownloader#download; loadAd sequence", "downloadRequest is null"); if (aVar != null) { W(null, aVar, new a.C0121a(-1, new IllegalArgumentException("DownloadRequest is null"), 1)); } } else { VungleLogger.i(true, f8095q, "ttDownloadContext", String.format("Waiting for download asset %1$s, at: %2$d", fVar, Long.valueOf(System.currentTimeMillis()))); this.f8106k.add(fVar); this.f8102g.a(new a(new com.vungle.warren.downloader.c(-2147483647, 0), fVar, aVar), new RunnableC0122b(fVar, aVar)); } } @Override // com.vungle.warren.downloader.g public synchronized void e(boolean z10) { this.f8109n = z10; } @Override // com.vungle.warren.downloader.g public boolean f(String str) { com.vungle.warren.downloader.h hVar = this.f8096a; if (hVar != null && str != null) { try { File b10 = hVar.b(str); Log.d(f8095q, "Deleting " + b10.getPath()); return this.f8096a.j(b10); } catch (IOException e10) { VungleLogger.c("AssetDownloader#dropCache; loadAd sequence", String.format("Error %1$s occured", e10)); Log.e(f8095q, "There was an error to get file", e10); } } return false; } public synchronized boolean f0() { boolean z10; if (this.f8096a != null) { z10 = this.f8109n; } return z10; } @Override // com.vungle.warren.downloader.g public synchronized List g() { ArrayList arrayList; arrayList = new ArrayList(); Iterator it = new ArrayList(this.f8105j.values()).iterator(); while (it.hasNext()) { arrayList.addAll(((DownloadRequestMediator) it.next()).requests()); } arrayList.addAll(this.f8106k); return arrayList; } @Override // com.vungle.warren.downloader.g public boolean h(com.vungle.warren.downloader.f fVar, long j10) { if (fVar == null) { return false; } i(fVar); long currentTimeMillis = System.currentTimeMillis() + Math.max(0L, j10); while (System.currentTimeMillis() < currentTimeMillis) { DownloadRequestMediator a02 = a0(fVar); synchronized (this) { if (!this.f8106k.contains(fVar) && (a02 == null || !a02.requests().contains(fVar))) { return true; } } A0(10L); } return false; } @Override // com.vungle.warren.downloader.g public synchronized void i(com.vungle.warren.downloader.f fVar) { if (fVar == null) { return; } o0(fVar); } @Override // com.vungle.warren.downloader.g public void j(com.vungle.warren.downloader.f fVar) { Runnable runnable; DownloadRequestMediator a02 = a0(fVar); if (a02 == null || (runnable = a02.getRunnable()) == null || !this.f8102g.remove(runnable)) { return; } Log.d(f8095q, "prio: updated to " + a02.getPriority()); this.f8102g.a(runnable, new h(a02)); } public static abstract class i implements Comparable, Runnable { /* renamed from: d, reason: collision with root package name */ private static final AtomicInteger f8132d = new AtomicInteger(); /* renamed from: a, reason: collision with root package name */ private final int f8133a; /* renamed from: b, reason: collision with root package name */ private final DownloadRequestMediator f8134b; /* renamed from: c, reason: collision with root package name */ private final com.vungle.warren.downloader.c f8135c; i(DownloadRequestMediator downloadRequestMediator) { this.f8133a = f8132d.incrementAndGet(); this.f8134b = downloadRequestMediator; this.f8135c = downloadRequestMediator.priority; downloadRequestMediator.setRunnable(this); } com.vungle.warren.downloader.c a() { DownloadRequestMediator downloadRequestMediator = this.f8134b; return downloadRequestMediator != null ? downloadRequestMediator.getPriority() : this.f8135c; } @Override // java.lang.Comparable public int compareTo(Object obj) { if (!(obj instanceof i)) { return -1; } i iVar = (i) obj; int compareTo = a().compareTo(iVar.a()); return compareTo == 0 ? Integer.valueOf(this.f8133a).compareTo(Integer.valueOf(iVar.f8133a)) : compareTo; } i(com.vungle.warren.downloader.c cVar) { this.f8133a = f8132d.incrementAndGet(); this.f8135c = cVar; this.f8134b = null; } } }