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

import androidx.annotation.Nullable;
import java.util.ArrayDeque;

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

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

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public pc1 f13217d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public int f13218e = 1;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final ArrayDeque f13216c = new ArrayDeque();

    public kc1(yb1 yb1Var, vb1 vb1Var, dh0 dh0Var) {
        this.f13214a = yb1Var;
        this.f13215b = dh0Var;
        vb1Var.f17590a = new jc1(this, 0);
    }

    public final synchronized void a() {
        ic1 ic1Var;
        if (((Boolean) n7.y.f31093e.f31096c.b(ao.Z6)).booleanValue() && !m7.n.C.f30469h.g().t().f15245j) {
            this.f13216c.clear();
            return;
        }
        synchronized (this) {
            if (this.f13217d == null) {
                while (true) {
                    ArrayDeque arrayDeque = this.f13216c;
                    if (arrayDeque.isEmpty()) {
                        break;
                    }
                    ic1Var = (ic1) arrayDeque.pollFirst();
                    if (ic1Var == null) {
                        break;
                    }
                    if (((z81) ic1Var).f19142g != null) {
                        xb1 xb1Var = this.f13214a;
                        cc1 cc1Var = ((z81) ic1Var).f19142g;
                        yb1 yb1Var = (yb1) xb1Var;
                        synchronized (yb1Var) {
                            wb1 wb1Var = (wb1) yb1Var.f18789a.get(cc1Var);
                            if (wb1Var == null) {
                                break;
                            }
                            ac1 ac1Var = yb1Var.f18790b;
                            wb1Var.a();
                            if (wb1Var.f18024a.size() < ac1Var.f8634e) {
                                break;
                            }
                        }
                    }
                }
                pc1 pc1Var = new pc1(this.f13214a, this.f13215b, ic1Var);
                this.f13217d = pc1Var;
                uz0 uz0Var = new uz0(this, ic1Var);
                synchronized (pc1Var) {
                    ih1.z1(ih1.e1(pc1Var.f15367b, nc1.f14528a, ((z81) ic1Var).f19140e), uz0Var, ((z81) ic1Var).f19140e);
                }
            }
        }
    }

    @Nullable
    public final synchronized com.google.common.util.concurrent.w zzb(ic1 ic1Var) {
        this.f13218e = 2;
        synchronized (this) {
            pc1 pc1Var = this.f13217d;
            if (pc1Var == null) {
                return null;
            }
            return pc1Var.a(ic1Var);
        }
    }
}