package defpackage; import androidx.media3.container.NalUnitUtil; import androidx.media3.extractor.text.ttml.TtmlNode; 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 kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.jvm.internal.DebugProbesKt; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000\"\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0010\u0018\u00002\u00020\u0001R\u0011\u0010\u0004\u001a\b\u0012\u0004\u0012\u00020\u00030\u00028\u0002X\u0082\u0004R\u000b\u0010\u0006\u001a\u00020\u00058\u0002X\u0082\u0004R\u0011\u0010\u0007\u001a\b\u0012\u0004\u0012\u00020\u00030\u00028\u0002X\u0082\u0004R\u000b\u0010\b\u001a\u00020\u00058\u0002X\u0082\u0004R\u000b\u0010\n\u001a\u00020\t8\u0002X\u0082\u0004ยจ\u0006\u000b"}, d2 = {"Lag8;", "", "Lww;", "Leg8;", TtmlNode.TAG_HEAD, "Lpw;", "deqIdx", "tail", "enqIdx", "Lnw;", "_availablePermits", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public class ag8 { public static final /* synthetic */ AtomicReferenceFieldUpdater c = AtomicReferenceFieldUpdater.newUpdater(ag8.class, Object.class, "head$volatile"); public static final /* synthetic */ AtomicLongFieldUpdater d = AtomicLongFieldUpdater.newUpdater(ag8.class, "deqIdx$volatile"); public static final /* synthetic */ AtomicReferenceFieldUpdater e = AtomicReferenceFieldUpdater.newUpdater(ag8.class, Object.class, "tail$volatile"); public static final /* synthetic */ AtomicLongFieldUpdater f = AtomicLongFieldUpdater.newUpdater(ag8.class, "enqIdx$volatile"); public static final /* synthetic */ AtomicIntegerFieldUpdater g = AtomicIntegerFieldUpdater.newUpdater(ag8.class, "_availablePermits$volatile"); private volatile /* synthetic */ int _availablePermits$volatile; public final int a; public final ux3 b; private volatile /* synthetic */ long deqIdx$volatile; private volatile /* synthetic */ long enqIdx$volatile; private volatile /* synthetic */ Object head$volatile; private volatile /* synthetic */ Object tail$volatile; public ag8(int i, int i2) { this.a = i; if (i <= 0) { throw new IllegalArgumentException(n41.k("Semaphore should have at least 1 permit, but had ", i).toString()); } if (i2 < 0 || i2 > i) { throw new IllegalArgumentException(n41.k("The number of acquired permits should be in 0..", i).toString()); } eg8 eg8Var = new eg8(0L, null, 2); this.head$volatile = eg8Var; this.tail$volatile = eg8Var; this._availablePermits$volatile = i - i2; this.b = new ux3(this, 8); } /* JADX WARN: Code restructure failed: missing block: B:13:0x0025, code lost: r1.m(r3, r5.b); */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object b(Continuation continuation) { AtomicIntegerFieldUpdater atomicIntegerFieldUpdater; int andDecrement; int i; do { atomicIntegerFieldUpdater = g; andDecrement = atomicIntegerFieldUpdater.getAndDecrement(this); i = this.a; } while (andDecrement > i); e6a e6aVar = e6a.a; if (andDecrement <= 0) { ts0 ts0VarB = vs0.b(dr4.d(continuation)); try { if (!d(ts0VarB)) { while (true) { int andDecrement2 = atomicIntegerFieldUpdater.getAndDecrement(this); if (andDecrement2 <= i) { if (andDecrement2 > 0) { break; } if (d(ts0VarB)) { break; } } } } Object objQ = ts0VarB.q(); ck1 ck1Var = ck1.a; if (objQ == ck1Var) { DebugProbesKt.probeCoroutineSuspended(continuation); } if (objQ != ck1Var) { objQ = e6aVar; } if (objQ == ck1Var) { return objQ; } } catch (Throwable th) { ts0VarB.z(); throw th; } } return e6aVar; } public final boolean d(bna bnaVar) { Object objA; AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = e; eg8 eg8Var = (eg8) atomicReferenceFieldUpdater.get(this); long andIncrement = f.getAndIncrement(this); yf8 yf8Var = yf8.a; long j = andIncrement / ((long) dg8.f); loop0: while (true) { objA = eb1.a(eg8Var, j, yf8Var); if (!se8.b(objA)) { ne8 ne8VarA = se8.a(objA); while (true) { ne8 ne8Var = (ne8) atomicReferenceFieldUpdater.get(this); if (ne8Var.c >= ne8VarA.c) { break loop0; } if (!ne8VarA.j()) { break; } while (!atomicReferenceFieldUpdater.compareAndSet(this, ne8Var, ne8VarA)) { if (atomicReferenceFieldUpdater.get(this) != ne8Var) { if (ne8VarA.f()) { ne8VarA.e(); } } } if (ne8Var.f()) { ne8Var.e(); } } } else { break; } } eg8 eg8Var2 = (eg8) se8.a(objA); AtomicReferenceArray atomicReferenceArray = eg8Var2.e; int i = (int) (andIncrement % ((long) dg8.f)); while (!atomicReferenceArray.compareAndSet(i, null, bnaVar)) { if (atomicReferenceArray.get(i) != null) { kg9 kg9Var = dg8.b; kg9 kg9Var2 = dg8.c; while (!atomicReferenceArray.compareAndSet(i, kg9Var, kg9Var2)) { if (atomicReferenceArray.get(i) != kg9Var) { return false; } } boolean z = bnaVar instanceof ss0; e6a e6aVar = e6a.a; if (z) { ((ss0) bnaVar).m(e6aVar, this.b); return true; } if (bnaVar instanceof lf8) { ((lf8) bnaVar).c(e6aVar); return true; } throw new IllegalStateException(("unexpected: " + bnaVar).toString()); } } bnaVar.a(eg8Var2, i); return true; } public final void release() { int i; Object objA; boolean zD; do { AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = g; int andIncrement = atomicIntegerFieldUpdater.getAndIncrement(this); int i2 = this.a; if (andIncrement >= i2) { do { i = atomicIntegerFieldUpdater.get(this); if (i <= i2) { break; } } while (!atomicIntegerFieldUpdater.compareAndSet(this, i, i2)); throw new IllegalStateException(("The number of released permits cannot be greater than " + i2).toString()); } if (andIncrement >= 0) { return; } AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = c; eg8 eg8Var = (eg8) atomicReferenceFieldUpdater.get(this); long andIncrement2 = d.getAndIncrement(this); long j = andIncrement2 / ((long) dg8.f); zf8 zf8Var = zf8.a; while (true) { objA = eb1.a(eg8Var, j, zf8Var); if (se8.b(objA)) { break; } ne8 ne8VarA = se8.a(objA); while (true) { ne8 ne8Var = (ne8) atomicReferenceFieldUpdater.get(this); if (ne8Var.c >= ne8VarA.c) { break; } if (!ne8VarA.j()) { break; } while (!atomicReferenceFieldUpdater.compareAndSet(this, ne8Var, ne8VarA)) { if (atomicReferenceFieldUpdater.get(this) != ne8Var) { if (ne8VarA.f()) { ne8VarA.e(); } } } if (ne8Var.f()) { ne8Var.e(); } } } eg8 eg8Var2 = (eg8) se8.a(objA); AtomicReferenceArray atomicReferenceArray = eg8Var2.e; eg8Var2.a(); zD = false; if (eg8Var2.c <= j) { int i3 = (int) (andIncrement2 % ((long) dg8.f)); Object andSet = atomicReferenceArray.getAndSet(i3, dg8.b); if (andSet == null) { int i4 = dg8.a; for (int i5 = 0; i5 < i4; i5++) { if (atomicReferenceArray.get(i3) == dg8.c) { zD = true; break; } } kg9 kg9Var = dg8.b; kg9 kg9Var2 = dg8.d; while (true) { if (!atomicReferenceArray.compareAndSet(i3, kg9Var, kg9Var2)) { if (atomicReferenceArray.get(i3) != kg9Var) { break; } } else { zD = true; break; } } zD = !zD; } else if (andSet != dg8.e) { boolean z = andSet instanceof ss0; e6a e6aVar = e6a.a; if (z) { ss0 ss0Var = (ss0) andSet; kg9 kg9VarE = ss0Var.e(e6aVar, this.b); if (kg9VarE != null) { ss0Var.v(kg9VarE); zD = true; break; break; } } else { if (!(andSet instanceof lf8)) { throw new IllegalStateException(("unexpected: " + andSet).toString()); } zD = ((lf8) andSet).d(this, e6aVar); } } } } while (!zD); } }