package i7;

import A6.n;
import Z6.AbstractC0385z;
import Z6.B0;
import Z6.C0368h;
import Z6.C0369i;
import Z6.F;
import Z6.InterfaceC0367g;
import com.google.android.gms.internal.measurement.C1;
import d5.AbstractC0844a;
import e7.AbstractC0892a;
import e7.r;
import h7.C1040e;
import h7.InterfaceC1041f;
import java.lang.reflect.InvocationTargetException;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceArray;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: loaded from: classes.dex */
public class i {

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f13586s = AtomicReferenceFieldUpdater.newUpdater(i.class, Object.class, "head$volatile");

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public static final /* synthetic */ AtomicLongFieldUpdater f13587t = AtomicLongFieldUpdater.newUpdater(i.class, "deqIdx$volatile");

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f13588u = AtomicReferenceFieldUpdater.newUpdater(i.class, Object.class, "tail$volatile");

    /* JADX INFO: renamed from: v, reason: collision with root package name */
    public static final /* synthetic */ AtomicLongFieldUpdater f13589v = AtomicLongFieldUpdater.newUpdater(i.class, "enqIdx$volatile");

    /* JADX INFO: renamed from: w, reason: collision with root package name */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f13590w = AtomicIntegerFieldUpdater.newUpdater(i.class, "_availablePermits$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;

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final int f13591q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final C0368h f13592r;
    private volatile /* synthetic */ Object tail$volatile;

    public i(int i, int i5) {
        this.f13591q = i;
        if (i <= 0) {
            throw new IllegalArgumentException(AbstractC0844a.j("Semaphore should have at least 1 permit, but had ", i).toString());
        }
        if (i5 < 0 || i5 > i) {
            throw new IllegalArgumentException(AbstractC0844a.j("The number of acquired permits should be in 0..", i).toString());
        }
        l lVar = new l(0L, null, 2);
        this.head$volatile = lVar;
        this.tail$volatile = lVar;
        this._availablePermits$volatile = i - i5;
        this.f13592r = new C0368h(1, this);
    }

    /* JADX WARN: Code restructure failed: missing block: B:13:0x0025, code lost:
    
        r5.c(r3, r4.f13592r);
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object c(G6.c cVar) throws IllegalAccessException, F, InvocationTargetException {
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater;
        int andDecrement;
        int i;
        do {
            atomicIntegerFieldUpdater = f13590w;
            andDecrement = atomicIntegerFieldUpdater.getAndDecrement(this);
            i = this.f13591q;
        } while (andDecrement > i);
        n nVar = n.f457a;
        if (andDecrement <= 0) {
            C0369i c0369iO = AbstractC0385z.o(C1.A(cVar));
            try {
                if (!d(c0369iO)) {
                    while (true) {
                        int andDecrement2 = atomicIntegerFieldUpdater.getAndDecrement(this);
                        if (andDecrement2 <= i) {
                            if (andDecrement2 > 0) {
                                break;
                            }
                            if (d(c0369iO)) {
                                break;
                            }
                        }
                    }
                }
                Object objU = c0369iO.u();
                F6.a aVar = F6.a.f2580q;
                if (objU != aVar) {
                    objU = nVar;
                }
                if (objU == aVar) {
                    return objU;
                }
            } catch (Throwable th) {
                c0369iO.C();
                throw th;
            }
        }
        return nVar;
    }

    public final boolean d(B0 b02) {
        Object objB;
        AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f13588u;
        l lVar = (l) atomicReferenceFieldUpdater.get(this);
        long andIncrement = f13589v.getAndIncrement(this);
        g gVar = g.f13584y;
        long j8 = andIncrement / ((long) k.f13598f);
        loop0: while (true) {
            objB = AbstractC0892a.b(lVar, j8, gVar);
            if (!AbstractC0892a.e(objB)) {
                r rVarC = AbstractC0892a.c(objB);
                while (true) {
                    r rVar = (r) atomicReferenceFieldUpdater.get(this);
                    if (rVar.f12574s >= rVarC.f12574s) {
                        break loop0;
                    }
                    if (!rVarC.j()) {
                        break;
                    }
                    while (!atomicReferenceFieldUpdater.compareAndSet(this, rVar, rVarC)) {
                        if (atomicReferenceFieldUpdater.get(this) != rVar) {
                            if (rVarC.f()) {
                                rVarC.e();
                            }
                        }
                    }
                    if (rVar.f()) {
                        rVar.e();
                    }
                }
            } else {
                break;
            }
        }
        l lVar2 = (l) AbstractC0892a.c(objB);
        int i = (int) (andIncrement % ((long) k.f13598f));
        AtomicReferenceArray atomicReferenceArray = lVar2.f13599u;
        while (!atomicReferenceArray.compareAndSet(i, null, b02)) {
            if (atomicReferenceArray.get(i) != null) {
                B3.f fVar = k.f13594b;
                B3.f fVar2 = k.f13595c;
                while (!atomicReferenceArray.compareAndSet(i, fVar, fVar2)) {
                    if (atomicReferenceArray.get(i) != fVar) {
                        return false;
                    }
                }
                boolean z8 = b02 instanceof InterfaceC0367g;
                n nVar = n.f457a;
                if (z8) {
                    ((InterfaceC0367g) b02).c(nVar, this.f13592r);
                    return true;
                }
                if (b02 instanceof InterfaceC1041f) {
                    ((C1040e) ((InterfaceC1041f) b02)).f13463u = nVar;
                    return true;
                }
                throw new IllegalStateException(("unexpected: " + b02).toString());
            }
        }
        b02.a(lVar2, i);
        return true;
    }

    public final void e() {
        int i;
        Object objB;
        boolean zG;
        do {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f13590w;
            int andIncrement = atomicIntegerFieldUpdater.getAndIncrement(this);
            int i5 = this.f13591q;
            if (andIncrement >= i5) {
                do {
                    i = atomicIntegerFieldUpdater.get(this);
                    if (i <= i5) {
                        break;
                    }
                } while (!atomicIntegerFieldUpdater.compareAndSet(this, i, i5));
                throw new IllegalStateException(("The number of released permits cannot be greater than " + i5).toString());
            }
            if (andIncrement >= 0) {
                return;
            }
            AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f13586s;
            l lVar = (l) atomicReferenceFieldUpdater.get(this);
            long andIncrement2 = f13587t.getAndIncrement(this);
            long j8 = andIncrement2 / ((long) k.f13598f);
            h hVar = h.f13585y;
            while (true) {
                objB = AbstractC0892a.b(lVar, j8, hVar);
                if (AbstractC0892a.e(objB)) {
                    break;
                }
                r rVarC = AbstractC0892a.c(objB);
                while (true) {
                    r rVar = (r) atomicReferenceFieldUpdater.get(this);
                    if (rVar.f12574s >= rVarC.f12574s) {
                        break;
                    }
                    if (!rVarC.j()) {
                        break;
                    }
                    while (!atomicReferenceFieldUpdater.compareAndSet(this, rVar, rVarC)) {
                        if (atomicReferenceFieldUpdater.get(this) != rVar) {
                            if (rVarC.f()) {
                                rVarC.e();
                            }
                        }
                    }
                    if (rVar.f()) {
                        rVar.e();
                    }
                }
            }
            l lVar2 = (l) AbstractC0892a.c(objB);
            lVar2.a();
            zG = false;
            if (lVar2.f12574s <= j8) {
                int i8 = (int) (andIncrement2 % ((long) k.f13598f));
                B3.f fVar = k.f13594b;
                AtomicReferenceArray atomicReferenceArray = lVar2.f13599u;
                Object andSet = atomicReferenceArray.getAndSet(i8, fVar);
                if (andSet == null) {
                    int i9 = k.f13593a;
                    for (int i10 = 0; i10 < i9; i10++) {
                        if (atomicReferenceArray.get(i8) == k.f13595c) {
                            zG = true;
                            break;
                        }
                    }
                    B3.f fVar2 = k.f13594b;
                    B3.f fVar3 = k.f13596d;
                    while (true) {
                        if (!atomicReferenceArray.compareAndSet(i8, fVar2, fVar3)) {
                            if (atomicReferenceArray.get(i8) != fVar2) {
                                break;
                            }
                        } else {
                            zG = true;
                            break;
                        }
                    }
                    zG = !zG;
                } else if (andSet != k.f13597e) {
                    boolean z8 = andSet instanceof InterfaceC0367g;
                    n nVar = n.f457a;
                    if (z8) {
                        InterfaceC0367g interfaceC0367g = (InterfaceC0367g) andSet;
                        B3.f fVarD = interfaceC0367g.d(nVar, this.f13592r);
                        if (fVarD != null) {
                            interfaceC0367g.o(fVarD);
                            zG = true;
                            break;
                            break;
                        }
                    } else {
                        if (!(andSet instanceof InterfaceC1041f)) {
                            throw new IllegalStateException(("unexpected: " + andSet).toString());
                        }
                        zG = ((C1040e) ((InterfaceC1041f) andSet)).g(this, nVar);
                    }
                }
            }
        } while (!zG);
    }
}