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

import android.content.Context;
import android.os.Bundle;
import android.os.SystemClock;
import androidx.annotation.Nullable;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;

/* JADX INFO: loaded from: classes2.dex */
public final class p61 {

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

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

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

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

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public long f15277f = 0;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public int f15278g = 0;

    public p61(Context context, a30 a30Var, Set set, md1 md1Var, cr0 cr0Var) {
        this.f15272a = context;
        this.f15274c = a30Var;
        this.f15273b = set;
        this.f15275d = md1Var;
        this.f15276e = cr0Var;
    }

    public final com.google.common.util.concurrent.w zza(final Object obj, @Nullable final Bundle bundle, final boolean z10) {
        id1 id1VarD = id1.d(this.f15272a, 8);
        id1VarD.zza();
        Set<n61> set = this.f15273b;
        final ArrayList arrayList = new ArrayList(set.size());
        List arrayList2 = new ArrayList();
        tn tnVar = ao.Vc;
        n7.y yVar = n7.y.f31093e;
        boolean zIsEmpty = ((String) yVar.f31096c.b(tnVar)).isEmpty();
        yn ynVar = yVar.f31096c;
        if (!zIsEmpty) {
            arrayList2 = Arrays.asList(((String) ynVar.b(tnVar)).split(","));
        }
        List list = arrayList2;
        m7.n nVar = m7.n.C;
        nVar.f30472k.getClass();
        this.f15277f = SystemClock.elapsedRealtime();
        final Bundle bundle2 = new Bundle();
        if (((Boolean) ynVar.b(ao.B2)).booleanValue() && bundle != null) {
            nVar.f30472k.getClass();
            long jCurrentTimeMillis = System.currentTimeMillis();
            if (obj instanceof zd0) {
                bundle.putLong(zzdxh.CLIENT_SIGNALS_START.a(), jCurrentTimeMillis);
            } else {
                bundle.putLong(zzdxh.GMS_SIGNALS_START.a(), jCurrentTimeMillis);
            }
        }
        for (n61 n61Var : set) {
            if (!list.contains(String.valueOf(n61Var.zzb()))) {
                m7.n.C.f30472k.getClass();
                long jElapsedRealtime = SystemClock.elapsedRealtime();
                com.google.common.util.concurrent.w wVarZza = n61Var.zza();
                wVarZza.g(new u40(this, jElapsedRealtime, n61Var, bundle2), b30.f9365g);
                arrayList.add(wVarZza);
            }
        }
        uu1 uu1VarC = ih1.x1(arrayList).c(new Callable() { // from class: com.google.android.gms.internal.ads.o61
            @Override // java.util.concurrent.Callable
            public final Object call() {
                Object obj2;
                Bundle bundle3;
                Iterator it = arrayList.iterator();
                while (true) {
                    boolean zHasNext = it.hasNext();
                    obj2 = obj;
                    if (!zHasNext) {
                        break;
                    }
                    m61 m61Var = (m61) ((com.google.common.util.concurrent.w) it.next()).get();
                    if (m61Var != null) {
                        m61Var.zza(obj2);
                        if (z10) {
                            m61Var.zzb(obj2);
                        }
                    }
                }
                if (((Boolean) n7.y.f31093e.f31096c.b(ao.B2)).booleanValue() && (bundle3 = bundle) != null) {
                    m7.n.C.f30472k.getClass();
                    long jCurrentTimeMillis2 = System.currentTimeMillis();
                    boolean z11 = obj2 instanceof zd0;
                    Bundle bundle4 = bundle2;
                    if (z11) {
                        bundle3.putLong(zzdxh.CLIENT_SIGNALS_END.a(), jCurrentTimeMillis2);
                        bundle3.putBundle("client_sig_latency_key", bundle4);
                    } else {
                        bundle3.putLong(zzdxh.GMS_SIGNALS_END.a(), jCurrentTimeMillis2);
                        bundle3.putBundle("gms_sig_latency_key", bundle4);
                    }
                }
                return obj2;
            }
        }, this.f15274c);
        if (nd1.a()) {
            ni.L(uu1VarC, this.f15275d, id1VarD, false);
        }
        return uu1VarC;
    }
}
