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

import android.content.Context;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicBoolean;

/* JADX INFO: loaded from: classes2.dex */
public final class ml1 implements fl1, cl1, sl1 {
    public static final vc2 W;

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final ExecutorService f14248c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final sk1 f14249d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final boolean f14250e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final String f14251f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final long f14252g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final long f14253h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final double f14254i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final String f14255j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final long f14256k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public final AtomicBoolean f14257l = new AtomicBoolean(false);

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final Object f14258m = new Object();
    public final Object Q = new Object();
    public final Object R = new Object();
    public final ee S = fe.B();
    public final ArrayList T = new ArrayList();
    public boolean U = false;
    public final HashMap V = new HashMap();

    static {
        uc2 uc2VarB = vc2.B();
        uc2VarB.c();
        ((vc2) uc2VarB.f8617b).C(17);
        W = (vc2) uc2VarB.e();
    }

    public ml1(Context context, tk1 tk1Var, ExecutorService executorService, sk1 sk1Var, Random random, String str, long j10, long j11, double d10, String str2, long j12) {
        this.f14246a = context;
        this.f14247b = tk1Var;
        this.f14248c = executorService;
        this.f14249d = sk1Var;
        this.f14251f = str;
        this.f14252g = j10;
        this.f14253h = j11;
        this.f14254i = d10;
        this.f14255j = str2;
        this.f14256k = j12;
        this.f14250e = random.nextDouble() < d10;
    }

    public final void a(int i10, long j10, Throwable th, String str) {
        Long lValueOf;
        if (this.f14250e) {
            synchronized (this.Q) {
                try {
                    ArrayList arrayList = this.T;
                    synchronized (this.R) {
                        try {
                            HashMap map = this.V;
                            Integer numValueOf = Integer.valueOf(i10);
                            Long l10 = (Long) map.get(numValueOf);
                            if (l10 == null) {
                                l10 = 0L;
                            }
                            lValueOf = Long.valueOf(l10.longValue() + 1);
                            map.put(numValueOf, lValueOf);
                        } finally {
                        }
                    }
                    arrayList.add(new kl1(i10, j10, th, str, lValueOf.longValue()));
                    if (!this.U) {
                        this.U = true;
                        this.f14247b.a(new ll1(this, 1), this.f14253h);
                    }
                } catch (Throwable th2) {
                    throw th2;
                }
            }
        }
    }

    public final void b(fe feVar) {
        try {
            il1 il1VarB = jl1.B();
            vc2 vc2Var = W;
            il1VarB.c();
            ((jl1) il1VarB.f8617b).D(vc2Var);
            gl1 gl1VarB = hl1.B();
            gl1VarB.c();
            ((hl1) gl1VarB.f8617b).C(feVar);
            hl1 hl1Var = (hl1) gl1VarB.e();
            il1VarB.c();
            ((jl1) il1VarB.f8617b).C(hl1Var);
            jl1 jl1Var = (jl1) il1VarB.e();
            sk1 sk1Var = this.f14249d;
            String str = this.f14251f;
            byte[] bArrB = jl1Var.b();
            sk1Var.getClass();
            kotlinx.coroutines.y.y(new n5.r(sk1Var, str, true, "application/x-protobuf", bArrB));
        } catch (RuntimeException unused) {
        }
    }

    @Override // com.google.android.gms.internal.ads.cl1
    public final com.google.common.util.concurrent.w zza() {
        ov1 ov1Var = new ov1(Executors.callable(new ll1(this, 0), null));
        this.f14248c.execute(ov1Var);
        return ov1Var;
    }
}