package com.google.android.gms.internal.ads; import android.net.Uri; import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; import tv.danmaku.ijk.media.player.IjkMediaPlayer; /* JADX INFO: loaded from: classes2.dex */ public final class c50 extends w40 implements u92 { public static final AtomicInteger R = new AtomicInteger(0); public boolean Q; /* JADX INFO: renamed from: d, reason: collision with root package name */ public String f9732d; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final b40 f9733e; /* JADX INFO: renamed from: f, reason: collision with root package name */ public boolean f9734f; /* JADX INFO: renamed from: g, reason: collision with root package name */ public final b50 f9735g; /* JADX INFO: renamed from: h, reason: collision with root package name */ public final androidx.media3.extractor.f0 f9736h; /* JADX INFO: renamed from: i, reason: collision with root package name */ public ByteBuffer f9737i; /* JADX INFO: renamed from: j, reason: collision with root package name */ public boolean f9738j; /* JADX INFO: renamed from: k, reason: collision with root package name */ public final Object f9739k; /* JADX INFO: renamed from: l, reason: collision with root package name */ public final String f9740l; /* JADX INFO: renamed from: m, reason: collision with root package name */ public final int f9741m; public c50(c40 c40Var, b40 b40Var) { super(c40Var); this.f9733e = b40Var; this.f9735g = new b50(); this.f9736h = new androidx.media3.extractor.f0(); this.f9739k = new Object(); String strZzn = c40Var.zzn(); this.f9740l = (String) (strZzn == null ? zzgqj.f19747a : new zzgrh(strZzn)).a(); this.f9741m = c40Var.zzp(); R.incrementAndGet(); } @Override // com.google.android.gms.internal.ads.u92 public final void a(dy1 dy1Var, boolean z10, int i10) { } @Override // com.google.android.gms.internal.ads.w40 public final void b() { R.decrementAndGet(); } @Override // com.google.android.gms.internal.ads.u92 public final void g(sv1 sv1Var, dy1 dy1Var, boolean z10) { if (sv1Var instanceof z12) { ((ArrayList) this.f9735g.f9401b).add((z12) sv1Var); } } /* JADX WARN: Code restructure failed: missing block: B:15:0x00bd, code lost: r25.Q = true; q7.e.f32222b.post(new com.google.android.gms.internal.ads.u40(r25, r26, r10, (int) r25.f9736h.a(r25.f9737i))); */ /* JADX WARN: Code restructure failed: missing block: B:35:0x0107, code lost: return true; */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:65:? -> B:54:0x017f). Please report as a decompilation issue!!! */ @Override // com.google.android.gms.internal.ads.w40 /* Code decompiled incorrectly, please refer to instructions dump. */ public final boolean i(String str) throws Throwable { String str2; Object obj; this.f9732d = str; String str3 = IjkMediaPlayer.OnNativeInvokeListener.ARG_ERROR; String strConcat = "cache:".concat(String.valueOf(q7.e.zzf(str))); try { kz1 kz1Var = new kz1(); kz1Var.zzb(this.f17862b); b40 b40Var = this.f9733e; kz1Var.f13438b = b40Var.f9385d; kz1Var.f13439c = b40Var.f9386e; kz1Var.f13440d = true; kz1Var.zzf(this); z12 z12VarZza = kz1Var.zza(); sv1 j40Var = z12VarZza; if (b40Var.f9390i) { j40Var = new j40(this.f17861a, z12VarZza, this.f9740l, this.f9741m); } j40Var.b(new dy1(Uri.parse(str), 0L, -1L, null)); c40 c40Var = (c40) this.f17863c.get(); if (c40Var != null) { c40Var.r(strConcat, this); } m7.n.C.f30472k.getClass(); long jCurrentTimeMillis = System.currentTimeMillis(); tn tnVar = ao.Z; n7.y yVar = n7.y.f31093e; long jLongValue = ((Long) yVar.f31096c.b(tnVar)).longValue(); long jLongValue2 = ((Long) yVar.f31096c.b(ao.Y)).longValue(); this.f9737i = ByteBuffer.allocate(b40Var.f9384c); int i10 = 8192; byte[] bArr = new byte[8192]; long j10 = jCurrentTimeMillis; sv1 sv1Var = j40Var; while (true) { int iD = sv1Var.d(bArr, 0, Math.min(this.f9737i.remaining(), i10)); if (iD == -1) { break; } Object obj2 = this.f9739k; synchronized (obj2) { sv1 sv1Var2 = sv1Var; try { if (this.f9734f) { str2 = str3; obj = obj2; } else { str2 = str3; str3 = null; try { this.f9737i.put(bArr, 0, iD); obj = obj2; } catch (Throwable th) { th = th; obj = obj2; throw th; } } } catch (Throwable th2) { th = th2; } try { try { if (this.f9737i.remaining() <= 0) { s(); break; } try { if (this.f9734f) { int iLimit = this.f9737i.limit(); StringBuilder sb = new StringBuilder(String.valueOf(iLimit).length() + 24); sb.append("Precache abort at "); sb.append(iLimit); sb.append(" bytes"); throw new IOException(sb.toString()); } long jCurrentTimeMillis2 = System.currentTimeMillis(); if (jCurrentTimeMillis2 - j10 >= jLongValue) { s(); j10 = jCurrentTimeMillis2; } if (jCurrentTimeMillis2 - jCurrentTimeMillis > 1000 * jLongValue2) { StringBuilder sb2 = new StringBuilder(String.valueOf(jLongValue2).length() + 29); sb2.append("Timeout exceeded. Limit: "); sb2.append(jLongValue2); sb2.append(" sec"); throw new IOException(sb2.toString()); } sv1Var = sv1Var2; str3 = str2; i10 = 8192; } catch (Exception e10) { e = e10; String canonicalName = e.getClass().getCanonicalName(); String message = e.getMessage(); String strP = defpackage.e.p(new StringBuilder(String.valueOf(canonicalName).length() + 1 + String.valueOf(message).length()), canonicalName, ":", message); StringBuilder sb3 = new StringBuilder(strP.length() + String.valueOf(str).length() + 34); sb3.append("Failed to preload url "); sb3.append(str); sb3.append(" Exception: "); sb3.append(strP); q7.j.d(sb3.toString()); zzq(str, strConcat, str3, strP); return false; } } catch (Exception e11) { e = e11; str3 = str2; String canonicalName2 = e.getClass().getCanonicalName(); String message2 = e.getMessage(); String strP2 = defpackage.e.p(new StringBuilder(String.valueOf(canonicalName2).length() + 1 + String.valueOf(message2).length()), canonicalName2, ":", message2); StringBuilder sb32 = new StringBuilder(strP2.length() + String.valueOf(str).length() + 34); sb32.append("Failed to preload url "); sb32.append(str); sb32.append(" Exception: "); sb32.append(strP2); q7.j.d(sb32.toString()); zzq(str, strConcat, str3, strP2); return false; } } catch (Throwable th3) { th = th3; throw th; } } } } catch (Exception e12) { e = e12; str2 = str3; } } @Override // com.google.android.gms.internal.ads.u92 public final void k(dy1 dy1Var, boolean z10) { } @Override // com.google.android.gms.internal.ads.w40 public final void q() { this.f9734f = true; } public final void s() { b50 b50Var = this.f9735g; Iterator it = ((ArrayList) b50Var.f9401b).iterator(); while (it.hasNext()) { for (Map.Entry entry : ((z12) it.next()).zzj().entrySet()) { try { if ("content-length".equalsIgnoreCase((String) entry.getKey())) { b50Var.f9400a = Math.max(b50Var.f9400a, Long.parseLong((String) ((List) entry.getValue()).get(0))); } } catch (RuntimeException unused) { } } it.remove(); } int i10 = (int) b50Var.f9400a; int iA = (int) this.f9736h.a(this.f9737i); int iPosition = this.f9737i.position(); int iRound = Math.round((iPosition / i10) * iA); int i11 = v30.f17495a.get(); int i12 = v30.f17496b.get(); String str = this.f9732d; q7.e.f32222b.post(new t40(this, str, "cache:".concat(String.valueOf(q7.e.zzf(str))), iPosition, i10, iRound, iA, iRound > 0, i11, i12)); } @Override // com.google.android.gms.internal.ads.u92 public final void zza() { } }