package com.google.android.gms.internal.ads;

import android.content.Context;
import android.os.Parcel;
import android.os.ParcelFileDescriptor;
import android.os.Parcelable;
import android.os.SystemClock;
import androidx.annotation.Nullable;
import java.io.DataInputStream;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes2.dex */
public final class yt implements dc {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public volatile qt f18971a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Context f18972b;

    public yt(Context context) {
        this.f18972b = context;
    }

    /* JADX WARN: Removed duplicated region for block: B:26:0x0127 A[RETURN] */
    /* JADX WARN: Removed duplicated region for block: B:28:0x0129  */
    @Override // com.google.android.gms.internal.ads.dc
    @Nullable
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final fc zza(gc gcVar) throws zzash {
        f8.b bVar;
        st stVar;
        Map mapF = gcVar.f();
        int size = mapF.size();
        String[] strArr = new String[size];
        String[] strArr2 = new String[size];
        int i10 = 0;
        for (Map.Entry entry : mapF.entrySet()) {
            strArr[i10] = (String) entry.getKey();
            strArr2[i10] = (String) entry.getValue();
            i10++;
        }
        rt rtVar = new rt(gcVar.f11697c, strArr, strArr2);
        m7.n nVar = m7.n.C;
        nVar.f30472k.getClass();
        long jElapsedRealtime = SystemClock.elapsedRealtime();
        try {
            e30 e30Var = new e30();
            this.f18971a = new qt(this.f18972b, nVar.f30481t.e(), new xt(this, e30Var), new tk(this, e30Var), 0);
            this.f18971a.checkAvailabilityAndConnect();
            wt wtVar = new wt(this, rtVar);
            a30 a30Var = b30.f9359a;
            com.google.common.util.concurrent.w wVarZ0 = ih1.Z0(ih1.e1(e30Var, wtVar, a30Var), ((Integer) n7.y.f31093e.f31096c.b(ao.f8900i5)).intValue(), TimeUnit.MILLISECONDS, b30.f9362d);
            wVarZ0.g(new mv1(this), a30Var);
            ParcelFileDescriptor parcelFileDescriptor = (ParcelFileDescriptor) wVarZ0.get();
            nVar.f30472k.getClass();
            long jElapsedRealtime2 = SystemClock.elapsedRealtime() - jElapsedRealtime;
            StringBuilder sb = new StringBuilder(String.valueOf(jElapsedRealtime2).length() + 32);
            sb.append("Http assets remote cache took ");
            sb.append(jElapsedRealtime2);
            sb.append("ms");
            p7.l0.g(sb.toString());
            sz szVar = new sz(parcelFileDescriptor);
            Parcelable.Creator<st> creator = st.CREATOR;
            if (parcelFileDescriptor != null) {
                DataInputStream dataInputStream = new DataInputStream(new ParcelFileDescriptor.AutoCloseInputStream(szVar.f16626a));
                try {
                    int i11 = dataInputStream.readInt();
                    byte[] bArr = new byte[i11];
                    dataInputStream.readFully(bArr, 0, i11);
                    hb.a.d(dataInputStream);
                    Parcel parcelObtain = Parcel.obtain();
                    try {
                        parcelObtain.unmarshall(bArr, 0, i11);
                        parcelObtain.setDataPosition(0);
                        szVar.f16627b = creator.createFromParcel(parcelObtain);
                        parcelObtain.recycle();
                        bVar = (f8.b) szVar.f16627b;
                    } catch (Throwable th) {
                        parcelObtain.recycle();
                        throw th;
                    }
                } catch (IOException unused) {
                    hb.a.d(dataInputStream);
                    bVar = null;
                } catch (Throwable th2) {
                    hb.a.d(dataInputStream);
                    throw th2;
                }
                stVar = (st) bVar;
                if (stVar != null) {
                    return null;
                }
                if (stVar.f16573a) {
                    throw new zzash(stVar.f16574b);
                }
                String[] strArr3 = stVar.f16577e;
                String[] strArr4 = stVar.f16578f;
                if (strArr3.length != strArr4.length) {
                    return null;
                }
                HashMap map = new HashMap();
                for (int i12 = 0; i12 < strArr3.length; i12++) {
                    map.put(strArr3[i12], strArr4[i12]);
                }
                return new fc(stVar.f16575c, stVar.f16576d, map, stVar.f16579g, stVar.f16580h);
            }
            q7.j.b("File descriptor is empty, returning null.");
            bVar = null;
            stVar = (st) bVar;
            if (stVar != null) {
            }
        } catch (InterruptedException | ExecutionException unused2) {
            m7.n.C.f30472k.getClass();
            long jElapsedRealtime3 = SystemClock.elapsedRealtime() - jElapsedRealtime;
            StringBuilder sb2 = new StringBuilder(String.valueOf(jElapsedRealtime3).length() + 32);
            sb2.append("Http assets remote cache took ");
            sb2.append(jElapsedRealtime3);
            sb2.append("ms");
            p7.l0.g(sb2.toString());
            return null;
        } catch (Throwable th3) {
            m7.n.C.f30472k.getClass();
            long jElapsedRealtime4 = SystemClock.elapsedRealtime() - jElapsedRealtime;
            StringBuilder sb3 = new StringBuilder(String.valueOf(jElapsedRealtime4).length() + 32);
            sb3.append("Http assets remote cache took ");
            sb3.append(jElapsedRealtime4);
            sb3.append("ms");
            p7.l0.g(sb3.toString());
            throw th3;
        }
    }
}