package com.google.android.gms.internal.ads; import android.content.Context; import android.os.SystemClock; import android.text.TextUtils; import androidx.annotation.Nullable; import androidx.media3.exoplayer.rtsp.RtspHeaders; import java.io.BufferedOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URI; import java.net.URISyntaxException; import java.net.URL; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; /* JADX INFO: loaded from: classes2.dex */ public final class hv0 implements rc1 { /* JADX INFO: renamed from: a, reason: collision with root package name */ public final Context f12261a; /* JADX INFO: renamed from: b, reason: collision with root package name */ public final String f12262b; @Nullable private final String zzc; public hv0(Context context, String str, a00 a00Var, int i10, @Nullable String str2) { this.f12261a = context; this.f12262b = str; this.zzc = str2; } /* JADX WARN: Code restructure failed: missing block: B:100:0x02ab, code lost: throw new com.google.android.gms.internal.ads.zzecr(1, r3.toString()); */ /* JADX WARN: Code restructure failed: missing block: B:69:0x01e9, code lost: r13.disconnect(); */ /* JADX WARN: Code restructure failed: missing block: B:99:0x0270, code lost: r2 = new java.lang.StringBuilder(java.lang.String.valueOf(r0).length() + 35); r2.append("Received error HTTP response code: "); r2.append(r0); q7.j.d(r2.toString()); r3 = new java.lang.StringBuilder(java.lang.String.valueOf(r0).length() + 35); r3.append("Received error HTTP response code: "); r3.append(r0); */ @Override // com.google.android.gms.internal.ads.rc1 /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final gv0 zza(fv0 fv0Var) { int i10; InputStreamReader inputStreamReader; BufferedOutputStream bufferedOutputStream; hv0 hv0Var = this; String str = fv0Var.f11396a; int i11 = fv0Var.f11397b; Map map = fv0Var.f11398c; byte[] bArr = fv0Var.f11399d; String str2 = fv0Var.f11400e; m7.n.C.f30472k.getClass(); long jElapsedRealtime = SystemClock.elapsedRealtime(); try { gv0 gv0Var = new gv0(); gv0Var.f11893a = 0; gv0Var.f11894b = new HashMap(); gv0Var.f11895c = ""; gv0Var.f11896d = -1L; if (((Boolean) n7.y.f31093e.f31096c.b(ao.Q2)).booleanValue() && n7.x.f31085g.f31088c) { gv0Var.f11893a = 410; } else { String str3 = hv0Var.f12262b; StringBuilder sb = new StringBuilder(String.valueOf(str3).length() + 13); sb.append("SDK version: "); sb.append(str3); q7.j.c(sb.toString()); StringBuilder sb2 = new StringBuilder(String.valueOf(str).length() + 39); sb2.append("AdRequestServiceImpl: Sending request: "); sb2.append(str); q7.j.a(sb2.toString()); URL url = new URL(str); HashMap map2 = new HashMap(); int i12 = 0; while (true) { HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection(); String str4 = hv0Var.zzc; if (str4 != null) { httpURLConnection.setRequestMethod(str4); } try { try { m7.n.C.f30464c.x(hv0Var.f12261a, str3, httpURLConnection, i11); for (Iterator it = map.entrySet().iterator(); it.hasNext(); it = it) { Map.Entry entry = (Map.Entry) it.next(); httpURLConnection.addRequestProperty((String) entry.getKey(), (String) entry.getValue()); } if (!TextUtils.isEmpty(str2)) { httpURLConnection.setRequestProperty(RtspHeaders.CONTENT_TYPE, str2); } q7.g gVar = new q7.g(null); try { gVar.zza(httpURLConnection, bArr); i10 = i11; } catch (Throwable th) { i10 = i11; m7.n.C.f30469h.e("HttpRequestFunction.logAdRequest", th); } int length = bArr.length; if (length > 0) { httpURLConnection.setDoOutput(true); httpURLConnection.setFixedLengthStreamingMode(length); try { BufferedOutputStream bufferedOutputStream2 = new BufferedOutputStream(httpURLConnection.getOutputStream()); try { bufferedOutputStream2.write(bArr); hb.a.d(bufferedOutputStream2); } catch (Throwable th2) { th = th2; bufferedOutputStream = bufferedOutputStream2; hb.a.d(bufferedOutputStream); throw th; } } catch (Throwable th3) { th = th3; bufferedOutputStream = null; } } int responseCode = httpURLConnection.getResponseCode(); Iterator>> it2 = httpURLConnection.getHeaderFields().entrySet().iterator(); while (it2.hasNext()) { Map.Entry> next = it2.next(); String key = next.getKey(); Iterator>> it3 = it2; List value = next.getValue(); if (map2.containsKey(key)) { ((List) map2.get(key)).addAll(value); } else { map2.put(key, new ArrayList(value)); map = map; } it2 = it3; } Map map3 = map; gVar.a(httpURLConnection, responseCode); gv0Var.f11893a = responseCode; gv0Var.f11894b = map2; gv0Var.f11895c = ""; if (responseCode >= 200 && responseCode < 300) { try { inputStreamReader = new InputStreamReader(httpURLConnection.getInputStream()); } catch (Throwable th4) { th = th4; inputStreamReader = null; } try { p7.r0 r0Var = m7.n.C.f30464c; StringBuilder sb3 = new StringBuilder(8192); char[] cArr = new char[2048]; while (true) { int i13 = inputStreamReader.read(cArr); if (i13 == -1) { break; } sb3.append(cArr, 0, i13); } String string = sb3.toString(); hb.a.d(inputStreamReader); gVar.zze(string); gv0Var.f11895c = string; if (TextUtils.isEmpty(string)) { if (!((Boolean) n7.y.f31093e.f31096c.b(ao.f9034q6)).booleanValue()) { throw new zzecr(3); } } m7.n.C.f30472k.getClass(); gv0Var.f11896d = SystemClock.elapsedRealtime() - jElapsedRealtime; } catch (Throwable th5) { th = th5; hb.a.d(inputStreamReader); throw th; } } else { if (responseCode < 300 || responseCode >= 400) { break; } String headerField = httpURLConnection.getHeaderField(RtspHeaders.LOCATION); if (TextUtils.isEmpty(headerField)) { q7.j.d("No location header to follow redirect."); throw new zzecr(1, "No location header to follow redirect"); } tn tnVar = ao.R8; n7.y yVar = n7.y.f31093e; if (((Boolean) yVar.f31096c.b(tnVar)).booleanValue()) { try { url = new URI(headerField).toURL(); } catch (URISyntaxException e10) { throw new zzecr(e10.getMessage(), e10); } } else { url = new URL(headerField); } i12++; if (i12 > ((Integer) yVar.f31096c.b(ao.Z5)).intValue()) { q7.j.d("Too many redirects."); throw new zzecr(1, "Too many redirects"); } httpURLConnection.disconnect(); hv0Var = this; i11 = i10; map = map3; } } catch (zzecr e11) { if (!((Boolean) n7.y.f31093e.f31096c.b(ao.f9086t9)).booleanValue()) { throw e11; } m7.n.C.f30472k.getClass(); gv0Var.f11896d = SystemClock.elapsedRealtime() - jElapsedRealtime; } } catch (Throwable th6) { httpURLConnection.disconnect(); throw th6; } } } return gv0Var; } catch (IOException e12) { String strConcat = "Error while connecting to ad server: ".concat(String.valueOf(e12.getMessage())); q7.j.d(strConcat); throw new zzecr(strConcat, e12); } } }