package defpackage;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceArray;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import sun.misc.Unsafe;

/* renamed from: ˎʽ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public class C1679 {

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f6690;

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public static final /* synthetic */ long f6691;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public static final /* synthetic */ long f6692;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicLongFieldUpdater f6693;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f6694;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicLongFieldUpdater f6695;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f6696 = AtomicReferenceFieldUpdater.newUpdater(C1679.class, Object.class, "head$volatile");
    private volatile /* synthetic */ int _availablePermits$volatile;
    private volatile /* synthetic */ long deqIdx$volatile;
    private volatile /* synthetic */ long enqIdx$volatile;
    private volatile /* synthetic */ Object head$volatile;
    private volatile /* synthetic */ Object tail$volatile;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final ˇʖᵲᵪ f6697;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final int f6698;

    static {
        Unsafe unsafe = AbstractC3747.f13986;
        f6692 = unsafe.objectFieldOffset(C1679.class.getDeclaredField("head$volatile"));
        f6695 = AtomicLongFieldUpdater.newUpdater(C1679.class, "deqIdx$volatile");
        f6694 = AtomicReferenceFieldUpdater.newUpdater(C1679.class, Object.class, "tail$volatile");
        f6691 = unsafe.objectFieldOffset(C1679.class.getDeclaredField("tail$volatile"));
        f6693 = AtomicLongFieldUpdater.newUpdater(C1679.class, "enqIdx$volatile");
        f6690 = AtomicIntegerFieldUpdater.newUpdater(C1679.class, "_availablePermits$volatile");
    }

    public C1679(int i) {
        this.f6698 = i;
        if (i <= 0) {
            ᵹˉᵞ.ᵸˑ(AbstractC2990.m7313(i, "Semaphore should have at least 1 permit, but had "));
            throw null;
        }
        if (i < 0) {
            ᵹˉᵞ.ᵸˑ(AbstractC2990.m7313(i, "The number of acquired permits should be in 0.."));
            throw null;
        }
        C0640 c0640 = new C0640(0L, null, 2);
        this.head$volatile = c0640;
        this.tail$volatile = c0640;
        this._availablePermits$volatile = i;
        this.f6697 = new ˇʖᵲᵪ(18, this);
    }

    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public final void m4810() {
        int i;
        do {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f6690;
            int andIncrement = atomicIntegerFieldUpdater.getAndIncrement(this);
            int i2 = this.f6698;
            if (andIncrement >= i2) {
                do {
                    i = atomicIntegerFieldUpdater.get(this);
                    if (i <= i2) {
                        break;
                    }
                } while (!atomicIntegerFieldUpdater.compareAndSet(this, i, i2));
                ᵨᴵᵺ.ˎˏʜʾ(i2, "The number of released permits cannot be greater than ");
                return;
            }
            if (andIncrement >= 0) {
                return;
            }
        } while (!m4811());
    }

    /* renamed from: ˏˋٴ, reason: contains not printable characters */
    public final boolean m4811() {
        Object objM8185;
        Unsafe unsafe;
        f6696.getClass();
        Unsafe unsafe2 = AbstractC3747.f13986;
        long j = f6692;
        C0640 c0640 = (C0640) unsafe2.getObjectVolatile(this, j);
        long andIncrement = f6695.getAndIncrement(this);
        long j2 = andIncrement / AbstractC2232.f8756;
        C3639 c3639 = C3639.f13538;
        loop0: while (true) {
            objM8185 = AbstractC3575.m8185(c0640, j2, c3639);
            if (ᵿᵧ.ᵤᵙᵷ(objM8185)) {
                break;
            }
            AbstractC2858 abstractC2858 = ᵿᵧ.ˑᵱ(objM8185);
            while (true) {
                AbstractC2858 abstractC28582 = (AbstractC2858) AbstractC3747.f13986.getObjectVolatile(this, j);
                if (abstractC28582.f11081 >= abstractC2858.f11081) {
                    break loop0;
                }
                if (!abstractC2858.m6990()) {
                    break;
                }
                do {
                    unsafe = AbstractC3747.f13986;
                    if (unsafe.compareAndSwapObject(this, f6692, abstractC28582, abstractC2858)) {
                        if (abstractC28582.m6991()) {
                            abstractC28582.m10145();
                        }
                    }
                } while (unsafe.getObjectVolatile(this, j) == abstractC28582);
                if (abstractC2858.m6991()) {
                    abstractC2858.m10145();
                }
            }
        }
        C0640 c06402 = (C0640) ᵿᵧ.ˑᵱ(objM8185);
        c06402.m10146();
        AtomicReferenceArray atomicReferenceArray = c06402.f3149;
        boolean z = false;
        if (c06402.f11081 <= j2) {
            int i = (int) (andIncrement % AbstractC2232.f8756);
            Object andSet = atomicReferenceArray.getAndSet(i, AbstractC2232.f8759);
            if (andSet == null) {
                int i2 = AbstractC2232.f8758;
                for (int i3 = 0; i3 < i2; i3++) {
                    if (atomicReferenceArray.get(i) == AbstractC2232.f8757) {
                        return true;
                    }
                }
                C0434 c0434 = AbstractC2232.f8759;
                C0434 c04342 = AbstractC2232.f8760;
                while (true) {
                    if (atomicReferenceArray.compareAndSet(i, c0434, c04342)) {
                        z = true;
                        break;
                    }
                    if (atomicReferenceArray.get(i) != c0434) {
                        break;
                    }
                }
                return !z;
            }
            if (andSet != AbstractC2232.f8755) {
                boolean z2 = andSet instanceof InterfaceC0719;
                C3637 c3637 = C3637.f13536;
                if (!z2) {
                    if (andSet instanceof C3707) {
                        return ((C3707) andSet).m8338(this, c3637) == 0;
                    }
                    C4069.m8939(andSet, "unexpected: ");
                    return false;
                }
                InterfaceC0719 interfaceC0719 = (InterfaceC0719) andSet;
                C0434 c0434Mo2136 = interfaceC0719.mo2136(c3637, this.f6697);
                if (c0434Mo2136 != null) {
                    interfaceC0719.mo2139(c0434Mo2136);
                    return true;
                }
            }
        }
        return false;
    }

    /* JADX WARN: Code restructure failed: missing block: B:13:0x0025, code lost:
    
        r5.mo2138(r3, r4.f6697);
     */
    /* renamed from: ᵴᵳ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final java.lang.Object m4812(defpackage.AbstractC1989 r5) throws kotlinx.coroutines.DispatchException {
        /*
            r4 = this;
        L0:
            java.util.concurrent.atomic.AtomicIntegerFieldUpdater r0 = defpackage.C1679.f6690
            int r1 = r0.getAndDecrement(r4)
            int r2 = r4.f6698
            if (r1 > r2) goto L0
            ᵧˈᵽᵰ r3 = defpackage.C3637.f13536
            if (r1 <= 0) goto Lf
            goto L3e
        Lf:
            ᵸʚˑ r5 = ᵱᵞᵪ.ᵞʡ(r5)
            ᵱʽ r5 = ˁـᵛ.ᵡʠ(r5)
            boolean r1 = r4.m4813(r5)     // Catch: java.lang.Throwable -> L3f
            if (r1 != 0) goto L31
        L1d:
            int r1 = r0.getAndDecrement(r4)     // Catch: java.lang.Throwable -> L3f
            if (r1 > r2) goto L1d
            if (r1 <= 0) goto L2b
            ˇʖᵲᵪ r4 = r4.f6697     // Catch: java.lang.Throwable -> L3f
            r5.mo2138(r3, r4)     // Catch: java.lang.Throwable -> L3f
            goto L31
        L2b:
            boolean r1 = r4.m4813(r5)     // Catch: java.lang.Throwable -> L3f
            if (r1 == 0) goto L1d
        L31:
            java.lang.Object r4 = r5.m9405()
            ᵣˊᵛ r5 = defpackage.EnumC3346.f12524
            if (r4 != r5) goto L3a
            goto L3b
        L3a:
            r4 = r3
        L3b:
            if (r4 != r5) goto L3e
            return r4
        L3e:
            return r3
        L3f:
            r4 = move-exception
            r5.m9396()
            throw r4
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C1679.m4812(ːᵱ):java.lang.Object");
    }

    /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */
    public final boolean m4813(InterfaceC5233 interfaceC5233) {
        Object objM8185;
        Unsafe unsafe;
        C1679 c1679 = this;
        f6694.getClass();
        Unsafe unsafe2 = AbstractC3747.f13986;
        long j = f6691;
        C0640 c0640 = (C0640) unsafe2.getObjectVolatile(c1679, j);
        long andIncrement = f6693.getAndIncrement(c1679);
        C3663 c3663 = C3663.f13651;
        long j2 = andIncrement / AbstractC2232.f8756;
        loop0: while (true) {
            objM8185 = AbstractC3575.m8185(c0640, j2, c3663);
            if (ᵿᵧ.ᵤᵙᵷ(objM8185)) {
                break;
            }
            AbstractC2858 abstractC2858 = ᵿᵧ.ˑᵱ(objM8185);
            while (true) {
                AbstractC2858 abstractC28582 = (AbstractC2858) AbstractC3747.f13986.getObjectVolatile(c1679, j);
                if (abstractC28582.f11081 >= abstractC2858.f11081) {
                    c1679 = this;
                    break loop0;
                }
                if (!abstractC2858.m6990()) {
                    break;
                }
                do {
                    unsafe = AbstractC3747.f13986;
                    c1679 = this;
                    if (unsafe.compareAndSwapObject(c1679, f6691, abstractC28582, abstractC2858)) {
                        if (abstractC28582.m6991()) {
                            abstractC28582.m10145();
                        }
                    }
                } while (unsafe.getObjectVolatile(c1679, j) == abstractC28582);
                if (abstractC2858.m6991()) {
                    abstractC2858.m10145();
                }
            }
            c1679 = this;
        }
        C0640 c06402 = (C0640) ᵿᵧ.ˑᵱ(objM8185);
        AtomicReferenceArray atomicReferenceArray = c06402.f3149;
        int i = (int) (andIncrement % AbstractC2232.f8756);
        while (!atomicReferenceArray.compareAndSet(i, null, interfaceC5233)) {
            if (atomicReferenceArray.get(i) != null) {
                C0434 c0434 = AbstractC2232.f8759;
                C0434 c04342 = AbstractC2232.f8757;
                while (!atomicReferenceArray.compareAndSet(i, c0434, c04342)) {
                    if (atomicReferenceArray.get(i) != c0434) {
                        return false;
                    }
                }
                ((InterfaceC0719) interfaceC5233).mo2138(C3637.f13536, c1679.f6697);
                return true;
            }
        }
        interfaceC5233.mo2137(c06402, i);
        return true;
    }
}