package p138.p145.p146.p151.p154;

import com.bumptech.glide.load.engine.GlideException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicInteger;
import p000.p001.p002.p003.p004.C0567;
import p037.p065.p077.InterfaceC1902;
import p138.p145.p146.p151.EnumC2840;
import p138.p145.p146.p151.InterfaceC2844;
import p138.p145.p146.p151.p154.C2925;
import p138.p145.p146.p151.p154.RunnableC2895;
import p138.p145.p146.p151.p154.p157.ExecutorServiceC2982;
import p138.p145.p146.p170.C3205;
import p138.p145.p146.p170.InterfaceC3204;
import p138.p145.p146.p174.C3233;
import p138.p145.p146.p174.p175.AbstractC3250;
import p138.p145.p146.p174.p175.C3242;

/* JADX INFO: renamed from: ދ.ؠ.֏.ތ.ފ.ފ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C2916<R> implements RunnableC2895.InterfaceC2896<R>, C3242.InterfaceC3246 {

    /* JADX INFO: renamed from: ޛ, reason: contains not printable characters */
    public static final C2919 f8988 = new C2919();

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public final C2921 f8989;

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public final AbstractC3250 f8990;

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public final C2925.InterfaceC2926 f8991;

    /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
    public final InterfaceC1902<C2916<?>> f8992;

    /* JADX INFO: renamed from: އ, reason: contains not printable characters */
    public final C2919 f8993;

    /* JADX INFO: renamed from: ވ, reason: contains not printable characters */
    public final InterfaceC2922 f8994;

    /* JADX INFO: renamed from: މ, reason: contains not printable characters */
    public final ExecutorServiceC2982 f8995;

    /* JADX INFO: renamed from: ފ, reason: contains not printable characters */
    public final ExecutorServiceC2982 f8996;

    /* JADX INFO: renamed from: ދ, reason: contains not printable characters */
    public final ExecutorServiceC2982 f8997;

    /* JADX INFO: renamed from: ތ, reason: contains not printable characters */
    public final ExecutorServiceC2982 f8998;

    /* JADX INFO: renamed from: ލ, reason: contains not printable characters */
    public final AtomicInteger f8999;

    /* JADX INFO: renamed from: ގ, reason: contains not printable characters */
    public InterfaceC2844 f9000;

    /* JADX INFO: renamed from: ޏ, reason: contains not printable characters */
    public boolean f9001;

    /* JADX INFO: renamed from: ސ, reason: contains not printable characters */
    public boolean f9002;

    /* JADX INFO: renamed from: ޑ, reason: contains not printable characters */
    public boolean f9003;

    /* JADX INFO: renamed from: ޒ, reason: contains not printable characters */
    public boolean f9004;

    /* JADX INFO: renamed from: ޓ, reason: contains not printable characters */
    public InterfaceC2932<?> f9005;

    /* JADX INFO: renamed from: ޔ, reason: contains not printable characters */
    public EnumC2840 f9006;

    /* JADX INFO: renamed from: ޕ, reason: contains not printable characters */
    public boolean f9007;

    /* JADX INFO: renamed from: ޖ, reason: contains not printable characters */
    public GlideException f9008;

    /* JADX INFO: renamed from: ޗ, reason: contains not printable characters */
    public boolean f9009;

    /* JADX INFO: renamed from: ޘ, reason: contains not printable characters */
    public C2925<?> f9010;

    /* JADX INFO: renamed from: ޙ, reason: contains not printable characters */
    public RunnableC2895<R> f9011;

    /* JADX INFO: renamed from: ޚ, reason: contains not printable characters */
    public volatile boolean f9012;

    /* JADX INFO: renamed from: ދ.ؠ.֏.ތ.ފ.ފ$֏, reason: contains not printable characters */
    public class RunnableC2917 implements Runnable {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final InterfaceC3204 f9013;

        public RunnableC2917(InterfaceC3204 interfaceC3204) {
            this.f9013 = interfaceC3204;
        }

        @Override // java.lang.Runnable
        public void run() {
            C3205 c3205 = (C3205) this.f9013;
            c3205.f9507.mo5344();
            synchronized (c3205.f9508) {
                synchronized (C2916.this) {
                    if (C2916.this.f8989.f9019.contains(new C2920(this.f9013, C3233.f9579))) {
                        C2916 c2916 = C2916.this;
                        InterfaceC3204 interfaceC3204 = this.f9013;
                        if (c2916 == null) {
                            throw null;
                        }
                        try {
                            ((C3205) interfaceC3204).m5285(c2916.f9008, 5);
                        } catch (Throwable th) {
                            throw new C2888(th);
                        }
                    }
                    C2916.this.m5051();
                }
            }
        }
    }

    /* JADX INFO: renamed from: ދ.ؠ.֏.ތ.ފ.ފ$ؠ, reason: contains not printable characters */
    public class RunnableC2918 implements Runnable {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final InterfaceC3204 f9015;

        public RunnableC2918(InterfaceC3204 interfaceC3204) {
            this.f9015 = interfaceC3204;
        }

        @Override // java.lang.Runnable
        public void run() {
            C3205 c3205 = (C3205) this.f9015;
            c3205.f9507.mo5344();
            synchronized (c3205.f9508) {
                synchronized (C2916.this) {
                    if (C2916.this.f8989.f9019.contains(new C2920(this.f9015, C3233.f9579))) {
                        C2916.this.f9010.m5063();
                        C2916 c2916 = C2916.this;
                        InterfaceC3204 interfaceC3204 = this.f9015;
                        if (c2916 == null) {
                            throw null;
                        }
                        try {
                            ((C3205) interfaceC3204).m5288(c2916.f9010, c2916.f9006);
                            C2916.this.m5056(this.f9015);
                        } catch (Throwable th) {
                            throw new C2888(th);
                        }
                    }
                    C2916.this.m5051();
                }
            }
        }
    }

    /* JADX INFO: renamed from: ދ.ؠ.֏.ތ.ފ.ފ$ހ, reason: contains not printable characters */
    public static class C2919 {
    }

    /* JADX INFO: renamed from: ދ.ؠ.֏.ތ.ފ.ފ$ށ, reason: contains not printable characters */
    public static final class C2920 {

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public final InterfaceC3204 f9017;

        /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
        public final Executor f9018;

        public C2920(InterfaceC3204 interfaceC3204, Executor executor) {
            this.f9017 = interfaceC3204;
            this.f9018 = executor;
        }

        public boolean equals(Object obj) {
            if (obj instanceof C2920) {
                return this.f9017.equals(((C2920) obj).f9017);
            }
            return false;
        }

        public int hashCode() {
            return this.f9017.hashCode();
        }
    }

    /* JADX INFO: renamed from: ދ.ؠ.֏.ތ.ފ.ފ$ނ, reason: contains not printable characters */
    public static final class C2921 implements Iterable<C2920> {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final List<C2920> f9019 = new ArrayList(2);

        public boolean isEmpty() {
            return this.f9019.isEmpty();
        }

        @Override // java.lang.Iterable
        public Iterator<C2920> iterator() {
            return this.f9019.iterator();
        }
    }

    public C2916(ExecutorServiceC2982 executorServiceC2982, ExecutorServiceC2982 executorServiceC29822, ExecutorServiceC2982 executorServiceC29823, ExecutorServiceC2982 executorServiceC29824, InterfaceC2922 interfaceC2922, C2925.InterfaceC2926 interfaceC2926, InterfaceC1902<C2916<?>> interfaceC1902) {
        C2919 c2919 = f8988;
        this.f8989 = new C2921();
        this.f8990 = new AbstractC3250.C3252();
        this.f8999 = new AtomicInteger();
        this.f8995 = executorServiceC2982;
        this.f8996 = executorServiceC29822;
        this.f8997 = executorServiceC29823;
        this.f8998 = executorServiceC29824;
        this.f8994 = interfaceC2922;
        this.f8991 = interfaceC2926;
        this.f8992 = interfaceC1902;
        this.f8993 = c2919;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public synchronized C2916<R> m5050(InterfaceC2844 interfaceC2844, boolean z, boolean z2, boolean z3, boolean z4) {
        this.f9000 = interfaceC2844;
        this.f9001 = z;
        this.f9002 = z2;
        this.f9003 = z3;
        this.f9004 = z4;
        return this;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m5051() {
        C2925<?> c2925;
        synchronized (this) {
            this.f8990.mo5344();
            C0567.m1898(m5059(), "Not yet complete!");
            int iDecrementAndGet = this.f8999.decrementAndGet();
            C0567.m1898(iDecrementAndGet >= 0, "Can't decrement below 0");
            if (iDecrementAndGet == 0) {
                c2925 = this.f9010;
                m5062();
            } else {
                c2925 = null;
            }
        }
        if (c2925 != null) {
            c2925.m5067();
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public synchronized void m5052(int i) {
        C0567.m1898(m5059(), "Not yet complete!");
        if (this.f8999.getAndAdd(i) == 0 && this.f9010 != null) {
            this.f9010.m5063();
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m5053(GlideException glideException) {
        synchronized (this) {
            this.f9008 = glideException;
        }
        m5060();
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m5054(RunnableC2895<?> runnableC2895) {
        (this.f9002 ? this.f8997 : this.f9003 ? this.f8998 : this.f8996).f9149.execute(runnableC2895);
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m5055(InterfaceC2932<R> interfaceC2932, EnumC2840 enumC2840) {
        synchronized (this) {
            this.f9005 = interfaceC2932;
            this.f9006 = enumC2840;
        }
        m5061();
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public synchronized void m5056(InterfaceC3204 interfaceC3204) {
        this.f8990.mo5344();
        this.f8989.f9019.remove(new C2920(interfaceC3204, C3233.f9579));
        if (this.f8989.isEmpty()) {
            boolean z = true;
            if (!m5059()) {
                this.f9012 = true;
                RunnableC2895<R> runnableC2895 = this.f9011;
                runnableC2895.f8934 = true;
                InterfaceC2892 interfaceC2892 = runnableC2895.f8932;
                if (interfaceC2892 != null) {
                    interfaceC2892.cancel();
                }
                ((C2909) this.f8994).m5044((C2916<?>) this, this.f9000);
            }
            if (!this.f9007 && !this.f9009) {
                z = false;
            }
            if (z && this.f8999.get() == 0) {
                m5062();
            }
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public synchronized void m5057(InterfaceC3204 interfaceC3204, Executor executor) {
        this.f8990.mo5344();
        this.f8989.f9019.add(new C2920(interfaceC3204, executor));
        boolean z = true;
        if (this.f9007) {
            m5052(1);
            executor.execute(new RunnableC2918(interfaceC3204));
        } else if (this.f9009) {
            m5052(1);
            executor.execute(new RunnableC2917(interfaceC3204));
        } else {
            if (this.f9012) {
                z = false;
            }
            C0567.m1898(z, "Cannot add callbacks to a cancelled EngineJob");
        }
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public synchronized void m5058(RunnableC2895<R> runnableC2895) {
        this.f9011 = runnableC2895;
        if (runnableC2895 == null) {
            throw null;
        }
        RunnableC2895.EnumC2902 enumC2902M5016 = runnableC2895.m5016(RunnableC2895.EnumC2902.INITIALIZE);
        (enumC2902M5016 == RunnableC2895.EnumC2902.RESOURCE_CACHE || enumC2902M5016 == RunnableC2895.EnumC2902.DATA_CACHE ? this.f8995 : this.f9002 ? this.f8997 : this.f9003 ? this.f8998 : this.f8996).f9149.execute(runnableC2895);
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final boolean m5059() {
        return this.f9009 || this.f9007 || this.f9012;
    }

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public void m5060() {
        synchronized (this) {
            this.f8990.mo5344();
            if (this.f9012) {
                m5062();
                return;
            }
            if (this.f8989.isEmpty()) {
                throw new IllegalStateException("Received an exception without any callbacks to notify");
            }
            if (this.f9009) {
                throw new IllegalStateException("Already failed once");
            }
            this.f9009 = true;
            InterfaceC2844 interfaceC2844 = this.f9000;
            C2921 c2921 = this.f8989;
            if (c2921 == null) {
                throw null;
            }
            ArrayList<C2920> arrayList = new ArrayList(c2921.f9019);
            m5052(arrayList.size() + 1);
            ((C2909) this.f8994).m5045((C2916<?>) this, interfaceC2844, (C2925<?>) null);
            for (C2920 c2920 : arrayList) {
                c2920.f9018.execute(new RunnableC2917(c2920.f9017));
            }
            m5051();
        }
    }

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public void m5061() {
        synchronized (this) {
            this.f8990.mo5344();
            if (this.f9012) {
                this.f9005.mo5066();
                m5062();
                return;
            }
            if (this.f8989.isEmpty()) {
                throw new IllegalStateException("Received a resource without any callbacks to notify");
            }
            if (this.f9007) {
                throw new IllegalStateException("Already have resource");
            }
            C2919 c2919 = this.f8993;
            InterfaceC2932<?> interfaceC2932 = this.f9005;
            boolean z = this.f9001;
            InterfaceC2844 interfaceC2844 = this.f9000;
            C2925.InterfaceC2926 interfaceC2926 = this.f8991;
            if (c2919 == null) {
                throw null;
            }
            this.f9010 = new C2925<>(interfaceC2932, z, true, interfaceC2844, interfaceC2926);
            this.f9007 = true;
            C2921 c2921 = this.f8989;
            if (c2921 == null) {
                throw null;
            }
            ArrayList<C2920> arrayList = new ArrayList(c2921.f9019);
            m5052(arrayList.size() + 1);
            ((C2909) this.f8994).m5045((C2916<?>) this, this.f9000, this.f9010);
            for (C2920 c2920 : arrayList) {
                c2920.f9018.execute(new RunnableC2918(c2920.f9017));
            }
            m5051();
        }
    }

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public final synchronized void m5062() {
        if (this.f9000 == null) {
            throw new IllegalArgumentException();
        }
        this.f8989.f9019.clear();
        this.f9000 = null;
        this.f9010 = null;
        this.f9005 = null;
        this.f9009 = false;
        this.f9012 = false;
        this.f9007 = false;
        RunnableC2895<R> runnableC2895 = this.f9011;
        if (runnableC2895.f8910.m5031(false)) {
            runnableC2895.m5024();
        }
        this.f9011 = null;
        this.f9008 = null;
        this.f9006 = null;
        this.f8992.mo3715(this);
    }

    @Override // p138.p145.p146.p174.p175.C3242.InterfaceC3246
    /* JADX INFO: renamed from: ބ */
    public AbstractC3250 mo5020() {
        return this.f8990;
    }
}