package com.bumptech.glide.load.engine;

import com.bumptech.glide.load.DataSource;
import java.util.ArrayList;
import java.util.Map;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: loaded from: classes.dex */
public final class u implements j, u5.b {

    /* JADX INFO: renamed from: c0, reason: collision with root package name */
    public static final com.google.android.gms.measurement.internal.a0 f5777c0 = new com.google.android.gms.measurement.internal.a0(7);
    public boolean Q;
    public boolean R;
    public boolean S;
    public e0 T;
    public DataSource U;
    public boolean V;
    public GlideException W;
    public boolean X;
    public y Y;
    public l Z;

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

    /* JADX INFO: renamed from: a0, reason: collision with root package name */
    public volatile boolean f5779a0;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final u5.e f5780b;

    /* JADX INFO: renamed from: b0, reason: collision with root package name */
    public boolean f5781b0;

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final p0.e f5783d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final com.google.android.gms.measurement.internal.a0 f5784e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final v f5785f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final e5.d f5786g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final e5.d f5787h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final e5.d f5788i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final e5.d f5789j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final AtomicInteger f5790k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public a5.h f5791l;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public boolean f5792m;

    public u(e5.d dVar, e5.d dVar2, e5.d dVar3, e5.d dVar4, v vVar, x xVar, p0.e eVar) {
        com.google.android.gms.measurement.internal.a0 a0Var = f5777c0;
        this.f5778a = new t(new ArrayList(2));
        this.f5780b = new u5.e();
        this.f5790k = new AtomicInteger();
        this.f5786g = dVar;
        this.f5787h = dVar2;
        this.f5788i = dVar3;
        this.f5789j = dVar4;
        this.f5785f = vVar;
        this.f5782c = xVar;
        this.f5783d = eVar;
        this.f5784e = a0Var;
    }

    public final synchronized void a(q5.g gVar, Executor executor) {
        try {
            this.f5780b.a();
            t tVar = this.f5778a;
            tVar.getClass();
            tVar.f5776a.add(new s(gVar, executor));
            int i10 = 1;
            if (this.V) {
                e(1);
                executor.execute(new r(this, gVar, i10));
            } else {
                int i11 = 0;
                if (this.X) {
                    e(1);
                    executor.execute(new r(this, gVar, i11));
                } else {
                    t5.n.a("Cannot add callbacks to a cancelled EngineJob", !this.f5779a0);
                }
            }
        } catch (Throwable th) {
            throw th;
        }
    }

    public final void b() {
        if (f()) {
            return;
        }
        this.f5779a0 = true;
        l lVar = this.Z;
        lVar.f5737g0 = true;
        h hVar = lVar.f5733e0;
        if (hVar != null) {
            hVar.cancel();
        }
        v vVar = this.f5785f;
        a5.h hVar2 = this.f5791l;
        q qVar = (q) vVar;
        synchronized (qVar) {
            b0 b0Var = qVar.f5764a;
            b0Var.getClass();
            Map map = this.S ? b0Var.f5646b : b0Var.f5645a;
            if (equals(map.get(hVar2))) {
                map.remove(hVar2);
            }
        }
    }

    public final void c() {
        y yVar;
        synchronized (this) {
            try {
                this.f5780b.a();
                t5.n.a("Not yet complete!", f());
                int iDecrementAndGet = this.f5790k.decrementAndGet();
                t5.n.a("Can't decrement below 0", iDecrementAndGet >= 0);
                if (iDecrementAndGet == 0) {
                    yVar = this.Y;
                    g();
                } else {
                    yVar = null;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        if (yVar != null) {
            yVar.d();
        }
    }

    @Override // u5.b
    public final u5.e d() {
        return this.f5780b;
    }

    public final synchronized void e(int i10) {
        y yVar;
        t5.n.a("Not yet complete!", f());
        if (this.f5790k.getAndAdd(i10) == 0 && (yVar = this.Y) != null) {
            yVar.c();
        }
    }

    public final boolean f() {
        return this.X || this.V || this.f5779a0;
    }

    public final synchronized void g() {
        boolean zA;
        if (this.f5791l == null) {
            throw new IllegalArgumentException();
        }
        this.f5778a.f5776a.clear();
        this.f5791l = null;
        this.Y = null;
        this.T = null;
        this.X = false;
        this.f5779a0 = false;
        this.V = false;
        this.f5781b0 = false;
        l lVar = this.Z;
        l2.f fVar = lVar.f5736g;
        synchronized (fVar) {
            fVar.f29989b = true;
            zA = fVar.a();
        }
        if (zA) {
            lVar.l();
        }
        this.Z = null;
        this.W = null;
        this.U = null;
        this.f5783d.a(this);
    }

    public final synchronized void h(q5.g gVar) {
        try {
            this.f5780b.a();
            t tVar = this.f5778a;
            tVar.f5776a.remove(new s(gVar, t5.g.f32965b));
            if (this.f5778a.f5776a.isEmpty()) {
                b();
                if (this.V || this.X) {
                    if (this.f5790k.get() == 0) {
                        g();
                    }
                }
            }
        } catch (Throwable th) {
            throw th;
        }
    }
}