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

import android.util.Pair;
import androidx.annotation.Nullable;
import java.util.Iterator;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes2.dex */
public final class d11 implements h7.d, gh0, wf0, xe0, hf0, n7.a, ue0, sg0, ef0, fk0 {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final AtomicReference f10139a = new AtomicReference();

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final AtomicReference f10140b = new AtomicReference();

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final AtomicReference f10142d = new AtomicReference();

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final AtomicReference f10143e = new AtomicReference();

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

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

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

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final ArrayBlockingQueue f10147i = new ArrayBlockingQueue(((Integer) n7.y.f31093e.f31096c.b(ao.f8805ca)).intValue());

    @Nullable
    final cr0 zza;

    public d11(@Nullable cr0 cr0Var) {
        this.zza = cr0Var;
    }

    public final synchronized n7.e0 a() {
        return (n7.e0) this.f10139a.get();
    }

    @Override // com.google.android.gms.internal.ads.ef0
    public final void d(n7.l2 l2Var) {
        ni.m(this.f10143e, new ve0(7, l2Var));
    }

    @Override // com.google.android.gms.internal.ads.gh0
    public final void e(eb1 eb1Var) {
        this.f10144f.set(true);
        this.f10146h.set(false);
    }

    @Override // h7.d
    public final synchronized void f(String str, String str2) {
        if (!this.f10144f.get()) {
            ni.m(this.f10140b, new lo(str, str2, 4));
            return;
        }
        if (!this.f10147i.offer(new Pair(str, str2))) {
            q7.j.a("The queue for app events is full, dropping the new event.");
            cr0 cr0Var = this.zza;
            if (cr0Var != null) {
                br0 br0VarA = cr0Var.a();
                br0VarA.zzc("action", "dae_action");
                br0VarA.zzc("dae_name", str);
                br0VarA.zzc("dae_data", str2);
                br0VarA.b();
            }
        }
    }

    @Override // com.google.android.gms.internal.ads.sg0
    public final void g(n7.g4 g4Var) {
        ni.m(this.f10141c, new qg0(g4Var, 5));
    }

    @Override // com.google.android.gms.internal.ads.hf0
    public final void h() {
        ni.m(this.f10139a, w01.f17840a);
    }

    public final void i(n7.g1 g1Var) {
        this.f10140b.set(g1Var);
        this.f10145g.set(true);
        j();
    }

    public final void j() {
        if (this.f10145g.get() && this.f10146h.get()) {
            ArrayBlockingQueue arrayBlockingQueue = this.f10147i;
            Iterator it = arrayBlockingQueue.iterator();
            while (it.hasNext()) {
                ni.m(this.f10140b, new dh0((Pair) it.next(), 20));
            }
            arrayBlockingQueue.clear();
            this.f10144f.set(false);
        }
    }

    @Override // com.google.android.gms.internal.ads.gh0
    public final void k(tz tzVar) {
    }

    @Override // com.google.android.gms.internal.ads.fk0
    public final void l0() {
        ni.m(this.f10139a, u01.f17052a);
    }

    @Override // com.google.android.gms.internal.ads.ue0
    public final void m() {
        ni.m(this.f10139a, q01.f15561a);
    }

    @Override // com.google.android.gms.internal.ads.ue0
    public final void n() {
        ni.m(this.f10139a, x01.f18281a);
        ni.m(this.f10143e, c11.f9697a);
    }

    @Override // n7.a
    public final void onAdClicked() {
        if (((Boolean) n7.y.f31093e.f31096c.b(ao.Xb)).booleanValue()) {
            return;
        }
        ni.m(this.f10139a, t01.f16663a);
    }

    @Override // com.google.android.gms.internal.ads.xe0
    public final void q(n7.l2 l2Var) {
        ve0 ve0Var = new ve0(8, l2Var);
        AtomicReference atomicReference = this.f10139a;
        ni.m(atomicReference, ve0Var);
        ni.m(atomicReference, new ve0(5, l2Var));
        ni.m(this.f10142d, new ve0(6, l2Var));
        this.f10144f.set(false);
        this.f10147i.clear();
    }

    @Override // com.google.android.gms.internal.ads.ue0
    public final void s() {
        ni.m(this.f10139a, s01.f16271a);
        AtomicReference atomicReference = this.f10143e;
        ni.m(atomicReference, z01.f19028a);
        ni.m(atomicReference, a11.f8452a);
    }

    @Override // com.google.android.gms.internal.ads.ue0
    public final void t(d00 d00Var, String str, String str2) {
    }

    @Override // com.google.android.gms.internal.ads.fk0
    public final void w() {
        if (((Boolean) n7.y.f31093e.f31096c.b(ao.Xb)).booleanValue()) {
            ni.m(this.f10139a, v01.f17464a);
        }
        ni.m(this.f10143e, b11.f9338a);
    }

    @Override // com.google.android.gms.internal.ads.ue0
    public final void zze() {
    }

    @Override // com.google.android.gms.internal.ads.ue0
    public final void zzf() {
    }

    @Override // com.google.android.gms.internal.ads.wf0
    public final synchronized void zzg() {
        ni.m(this.f10139a, r01.f15943a);
        ni.m(this.f10142d, y01.f18625a);
        this.f10146h.set(true);
        j();
    }
}