package m4;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.LinkedHashSet;
import java.util.concurrent.Executor;
import k4.AbstractC2400m;
import k4.C2394g;
import k4.C2407u;

/* JADX INFO: loaded from: classes3.dex */
public final class M implements InterfaceC2490a1 {

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final k4.w0 f20672d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public K f20673e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public K f20674f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public K f20675g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public l2.c f20676h;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public k4.r0 f20678j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public k4.Q f20679k;
    public long l;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final k4.J f20669a = k4.J.a(M.class, null);

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

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public Collection f20677i = new LinkedHashSet();

    public M(Executor executor, k4.w0 w0Var) {
        this.f20671c = executor;
        this.f20672d = w0Var;
    }

    @Override // m4.InterfaceC2490a1
    public final void a(k4.r0 r0Var) {
        Collection<L> collection;
        K k6;
        d(r0Var);
        synchronized (this.f20670b) {
            try {
                collection = this.f20677i;
                k6 = this.f20675g;
                this.f20675g = null;
                if (!collection.isEmpty()) {
                    this.f20677i = Collections.EMPTY_LIST;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        if (k6 != null) {
            for (L l : collection) {
                O oS = l.s(new X(r0Var, EnumC2550v.f21202b, l.l));
                if (oS != null) {
                    oS.run();
                }
            }
            this.f20672d.execute(k6);
        }
    }

    @Override // m4.InterfaceC2556x
    public final InterfaceC2547u c(k4.i0 i0Var, k4.g0 g0Var, C2394g c2394g, AbstractC2400m[] abstractC2400mArr) {
        InterfaceC2547u x6;
        try {
            C2546t1 c2546t1 = new C2546t1(i0Var, g0Var, c2394g);
            k4.Q q6 = null;
            long j4 = -1;
            while (true) {
                synchronized (this.f20670b) {
                    k4.r0 r0Var = this.f20678j;
                    if (r0Var == null) {
                        k4.Q q7 = this.f20679k;
                        if (q7 != null) {
                            if (q6 != null && j4 == this.l) {
                                x6 = g(c2546t1, abstractC2400mArr);
                                break;
                            }
                            j4 = this.l;
                            InterfaceC2556x interfaceC2556xF = AbstractC2504f0.f(q7.a(c2546t1), Boolean.TRUE.equals(c2394g.f19863f));
                            if (interfaceC2556xF != null) {
                                x6 = interfaceC2556xF.c(c2546t1.f21171c, c2546t1.f21170b, c2546t1.f21169a, abstractC2400mArr);
                                break;
                            }
                            q6 = q7;
                        } else {
                            x6 = g(c2546t1, abstractC2400mArr);
                            break;
                        }
                    } else {
                        x6 = new X(r0Var, EnumC2550v.f21201a, abstractC2400mArr);
                        break;
                    }
                }
            }
            return x6;
        } finally {
            this.f20672d.a();
        }
    }

    @Override // m4.InterfaceC2490a1
    public final void d(k4.r0 r0Var) {
        K k6;
        synchronized (this.f20670b) {
            try {
                if (this.f20678j != null) {
                    return;
                }
                this.f20678j = r0Var;
                this.f20672d.b(new E(5, this, r0Var));
                if (!h() && (k6 = this.f20675g) != null) {
                    this.f20672d.b(k6);
                    this.f20675g = null;
                }
                this.f20672d.a();
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @Override // k4.I
    public final k4.J e() {
        return this.f20669a;
    }

    @Override // m4.InterfaceC2490a1
    public final Runnable f(Z0 z02) {
        l2.c cVar = (l2.c) z02;
        this.f20676h = cVar;
        this.f20673e = new K(cVar, 0);
        this.f20674f = new K(cVar, 1);
        this.f20675g = new K(cVar, 2);
        return null;
    }

    public final L g(C2546t1 c2546t1, AbstractC2400m[] abstractC2400mArr) {
        int size;
        L l = new L(this, c2546t1, abstractC2400mArr);
        this.f20677i.add(l);
        synchronized (this.f20670b) {
            size = this.f20677i.size();
        }
        if (size == 1) {
            this.f20672d.b(this.f20673e);
        }
        for (AbstractC2400m abstractC2400m : abstractC2400mArr) {
            abstractC2400m.a();
        }
        return l;
    }

    public final boolean h() {
        boolean z6;
        synchronized (this.f20670b) {
            z6 = !this.f20677i.isEmpty();
        }
        return z6;
    }

    public final void i(k4.Q q6) {
        K k6;
        synchronized (this.f20670b) {
            this.f20679k = q6;
            this.l++;
            if (q6 != null && h()) {
                ArrayList<L> arrayList = new ArrayList(this.f20677i);
                ArrayList arrayList2 = new ArrayList();
                for (L l : arrayList) {
                    k4.O oA = q6.a(l.f20662j);
                    C2394g c2394g = l.f20662j.f21169a;
                    InterfaceC2556x interfaceC2556xF = AbstractC2504f0.f(oA, Boolean.TRUE.equals(c2394g.f19863f));
                    if (interfaceC2556xF != null) {
                        Executor executor = this.f20671c;
                        Executor executor2 = c2394g.f19859b;
                        if (executor2 != null) {
                            executor = executor2;
                        }
                        C2407u c2407u = l.f20663k;
                        C2407u c2407uA = c2407u.a();
                        try {
                            C2546t1 c2546t1 = l.f20662j;
                            InterfaceC2547u interfaceC2547uC = interfaceC2556xF.c(c2546t1.f21171c, c2546t1.f21170b, c2546t1.f21169a, l.l);
                            c2407u.c(c2407uA);
                            O oS = l.s(interfaceC2547uC);
                            if (oS != null) {
                                executor.execute(oS);
                            }
                            arrayList2.add(l);
                        } catch (Throwable th) {
                            c2407u.c(c2407uA);
                            throw th;
                        }
                    }
                }
                synchronized (this.f20670b) {
                    try {
                        if (h()) {
                            this.f20677i.removeAll(arrayList2);
                            if (this.f20677i.isEmpty()) {
                                this.f20677i = new LinkedHashSet();
                            }
                            if (!h()) {
                                this.f20672d.b(this.f20674f);
                                if (this.f20678j != null && (k6 = this.f20675g) != null) {
                                    this.f20672d.b(k6);
                                    this.f20675g = null;
                                }
                            }
                            this.f20672d.a();
                        }
                    } finally {
                    }
                }
            }
        }
    }
}