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

import androidx.annotation.Nullable;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Executor;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;

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

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

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

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

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

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final lv1 f11914f = new lv1();

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

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public hy0 f11916h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public eb1 f11917i;

    public gy0(a30 a30Var, ScheduledExecutorService scheduledExecutorService, oc0 oc0Var, qy0 qy0Var, qe1 qe1Var) {
        this.f11909a = a30Var;
        this.f11910b = scheduledExecutorService;
        this.f11911c = oc0Var;
        this.f11912d = qy0Var;
        this.f11913e = qe1Var;
    }

    /* JADX INFO: Access modifiers changed from: private */
    /* JADX INFO: renamed from: zze, reason: merged with bridge method [inline-methods] */
    public final void b(@Nullable wa1 wa1Var) {
        com.google.common.util.concurrent.w wVarQ0;
        synchronized (this) {
            Iterator it = wa1Var.f17971a.iterator();
            while (true) {
                if (!it.hasNext()) {
                    wVarQ0 = ih1.q0(new zzecr(3));
                    break;
                }
                vw0 vw0VarZza = this.f11911c.zza(wa1Var.f17973b, (String) it.next());
                if (vw0VarZza != null && vw0VarZza.a(this.f11917i, wa1Var)) {
                    wVarQ0 = ih1.Z0(vw0VarZza.b(this.f11917i, wa1Var), wa1Var.O, TimeUnit.MILLISECONDS, this.f11910b);
                    break;
                }
            }
        }
        this.f11912d.b(this.f11917i, wa1Var, wVarQ0, this.f11913e);
        ih1.z1(wVarQ0, new zv1(this, wa1Var), this.f11909a);
    }

    public final synchronized lv1 a(eb1 eb1Var) {
        try {
            if (!this.f11915g.getAndSet(true)) {
                List list = eb1Var.f10746b.f10363a;
                if (list.isEmpty()) {
                    this.f11914f.d(new zzenv(3, uy0.a(eb1Var)));
                } else {
                    this.f11917i = eb1Var;
                    qy0 qy0Var = this.f11912d;
                    this.f11916h = new hy0(eb1Var, qy0Var, this.f11914f);
                    qy0Var.a(list);
                    wa1 wa1VarA = this.f11916h.a();
                    while (wa1VarA != null) {
                        b(wa1VarA);
                        wa1VarA = this.f11916h.a();
                    }
                }
            }
        } catch (Throwable th) {
            throw th;
        }
        return this.f11914f;
    }
}