package X4; import I2.C0317a; import V4.C0772m; import V4.E; import V4.InterfaceC0770l; import V4.N0; import a.AbstractC0872a; import a5.AbstractC0988a; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.NoSuchElementException; import java.util.concurrent.CancellationException; import java.util.concurrent.atomic.AtomicLongFieldUpdater; import java.util.concurrent.atomic.AtomicReferenceArray; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import kotlin.jvm.internal.F; import m3.AbstractC2467b; import w4.C3137A; import x4.AbstractC3252r; /* JADX INFO: loaded from: classes3.dex */ public class e implements i { /* JADX INFO: renamed from: b, reason: collision with root package name */ public static final /* synthetic */ AtomicLongFieldUpdater f8653b = AtomicLongFieldUpdater.newUpdater(e.class, "sendersAndCloseStatus$volatile"); /* JADX INFO: renamed from: c, reason: collision with root package name */ public static final /* synthetic */ AtomicLongFieldUpdater f8654c = AtomicLongFieldUpdater.newUpdater(e.class, "receivers$volatile"); /* JADX INFO: renamed from: d, reason: collision with root package name */ public static final /* synthetic */ AtomicLongFieldUpdater f8655d = AtomicLongFieldUpdater.newUpdater(e.class, "bufferEnd$volatile"); /* JADX INFO: renamed from: e, reason: collision with root package name */ public static final /* synthetic */ AtomicLongFieldUpdater f8656e = AtomicLongFieldUpdater.newUpdater(e.class, "completedExpandBuffersAndPauseFlag$volatile"); /* JADX INFO: renamed from: f, reason: collision with root package name */ public static final /* synthetic */ AtomicReferenceFieldUpdater f8657f = AtomicReferenceFieldUpdater.newUpdater(e.class, Object.class, "sendSegment$volatile"); /* JADX INFO: renamed from: j, reason: collision with root package name */ public static final /* synthetic */ AtomicReferenceFieldUpdater f8658j = AtomicReferenceFieldUpdater.newUpdater(e.class, Object.class, "receiveSegment$volatile"); /* JADX INFO: renamed from: k, reason: collision with root package name */ public static final /* synthetic */ AtomicReferenceFieldUpdater f8659k = AtomicReferenceFieldUpdater.newUpdater(e.class, Object.class, "bufferEndSegment$volatile"); public static final /* synthetic */ AtomicReferenceFieldUpdater l = AtomicReferenceFieldUpdater.newUpdater(e.class, Object.class, "_closeCause$volatile"); /* JADX INFO: renamed from: m, reason: collision with root package name */ public static final /* synthetic */ AtomicReferenceFieldUpdater f8660m = AtomicReferenceFieldUpdater.newUpdater(e.class, Object.class, "closeHandler$volatile"); private volatile /* synthetic */ Object _closeCause$volatile; /* JADX INFO: renamed from: a, reason: collision with root package name */ public final int f8661a; private volatile /* synthetic */ long bufferEnd$volatile; private volatile /* synthetic */ Object bufferEndSegment$volatile; private volatile /* synthetic */ Object closeHandler$volatile; private volatile /* synthetic */ long completedExpandBuffersAndPauseFlag$volatile; private volatile /* synthetic */ Object receiveSegment$volatile; private volatile /* synthetic */ long receivers$volatile; private volatile /* synthetic */ Object sendSegment$volatile; private volatile /* synthetic */ long sendersAndCloseStatus$volatile; public e(int i6) { this.f8661a = i6; if (i6 < 0) { throw new IllegalArgumentException(Z0.o.j(i6, "Invalid channel capacity: ", ", should be >=0").toString()); } m mVar = g.f8663a; this.bufferEnd$volatile = i6 != 0 ? i6 != Integer.MAX_VALUE ? i6 : Long.MAX_VALUE : 0L; this.completedExpandBuffersAndPauseFlag$volatile = f8655d.get(this); m mVar2 = new m(0L, null, this, 3); this.sendSegment$volatile = mVar2; this.receiveSegment$volatile = mVar2; if (x()) { mVar2 = g.f8663a; kotlin.jvm.internal.o.f(mVar2, "null cannot be cast to non-null type kotlinx.coroutines.channels.ChannelSegment"); } this.bufferEndSegment$volatile = mVar2; this._closeCause$volatile = g.f8680s; } /* JADX WARN: Removed duplicated region for block: B:8:0x0014 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public static Object A(e eVar, C4.c cVar) { c cVar2; m mVar; if (cVar instanceof c) { cVar2 = (c) cVar; int i6 = cVar2.f8649c; if ((i6 & Integer.MIN_VALUE) != 0) { cVar2.f8649c = i6 - Integer.MIN_VALUE; } else { cVar2 = new c(eVar, cVar); } } c cVar3 = cVar2; Object obj = cVar3.f8647a; B4.a aVar = B4.a.f492a; int i7 = cVar3.f8649c; if (i7 != 0) { if (i7 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } AbstractC2467b.l(obj); return ((l) obj).f8686a; } AbstractC2467b.l(obj); m mVar2 = (m) f8658j.get(eVar); while (!eVar.u()) { long andIncrement = f8654c.getAndIncrement(eVar); long j4 = g.f8664b; long j6 = andIncrement / j4; int i8 = (int) (andIncrement % j4); if (mVar2.f10849c != j6) { m mVarN = eVar.n(j6, mVar2); if (mVarN == null) { continue; } else { mVar = mVarN; } } else { mVar = mVar2; } e eVar2 = eVar; Object objF = eVar2.F(mVar, i8, andIncrement, null); if (objF == g.f8674m) { throw new IllegalStateException("unexpected"); } if (objF != g.f8676o) { if (objF != g.f8675n) { mVar.b(); return objF; } cVar3.f8649c = 1; Object objB = eVar2.B(mVar, i8, andIncrement, cVar3); return objB == aVar ? aVar : objB; } if (andIncrement < eVar2.r()) { mVar.b(); } eVar = eVar2; mVar2 = mVar; } return new j(eVar.o()); } public static boolean E(Object obj) { if (obj instanceof InterfaceC0770l) { kotlin.jvm.internal.o.f(obj, "null cannot be cast to non-null type kotlinx.coroutines.CancellableContinuation"); return g.a((InterfaceC0770l) obj, C3137A.f25453a, null); } throw new IllegalStateException(("Unexpected waiter: " + obj).toString()); } public static final m b(e eVar, long j4, m mVar) { Object objB; e eVar2; eVar.getClass(); m mVar2 = g.f8663a; f fVar = f.f8662a; loop0: while (true) { objB = AbstractC0988a.b(mVar, j4, fVar); if (!AbstractC0988a.e(objB)) { a5.q qVarC = AbstractC0988a.c(objB); while (true) { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f8657f; a5.q qVar = (a5.q) atomicReferenceFieldUpdater.get(eVar); if (qVar.f10849c >= qVarC.f10849c) { break loop0; } if (!qVarC.j()) { break; } while (!atomicReferenceFieldUpdater.compareAndSet(eVar, qVar, qVarC)) { if (atomicReferenceFieldUpdater.get(eVar) != qVar) { if (qVarC.f()) { qVarC.e(); } } } if (qVar.f()) { qVar.e(); } } } else { break; } } boolean zE = AbstractC0988a.e(objB); AtomicLongFieldUpdater atomicLongFieldUpdater = f8654c; if (zE) { eVar.v(); if (mVar.f10849c * ((long) g.f8664b) < atomicLongFieldUpdater.get(eVar)) { mVar.b(); return null; } } else { m mVar3 = (m) AbstractC0988a.c(objB); long j6 = mVar3.f10849c; if (j6 <= j4) { return mVar3; } long j7 = ((long) g.f8664b) * j6; while (true) { AtomicLongFieldUpdater atomicLongFieldUpdater2 = f8653b; long j8 = atomicLongFieldUpdater2.get(eVar); long j9 = 1152921504606846975L & j8; if (j9 >= j7) { eVar2 = eVar; break; } eVar2 = eVar; if (atomicLongFieldUpdater2.compareAndSet(eVar2, j8, j9 + (((long) ((int) (j8 >> 60))) << 60))) { break; } eVar = eVar2; } if (j6 * ((long) g.f8664b) < atomicLongFieldUpdater.get(eVar2)) { mVar3.b(); } } return null; } public static final void d(e eVar, Object obj, C0772m c0772m) { eVar.getClass(); c0772m.resumeWith(AbstractC2467b.d(eVar.q())); } public static final int h(e eVar, m mVar, int i6, Object obj, long j4, Object obj2, boolean z6) { eVar.getClass(); mVar.n(i6, obj); if (z6) { return eVar.G(mVar, i6, obj, j4, obj2, z6); } Object objL = mVar.l(i6); if (objL == null) { if (eVar.i(j4)) { if (mVar.k(i6, null, g.f8666d)) { return 1; } } else { if (obj2 == null) { return 3; } if (mVar.k(i6, null, obj2)) { return 2; } } } else if (objL instanceof N0) { mVar.n(i6, null); if (eVar.D(objL, obj)) { mVar.o(i6, g.f8671i); return 0; } C0317a c0317a = g.f8673k; if (mVar.f8688f.getAndSet((i6 * 2) + 1, c0317a) == c0317a) { return 5; } mVar.m(i6, true); return 5; } return eVar.G(mVar, i6, obj, j4, obj2, z6); } public static void s(e eVar) { eVar.getClass(); AtomicLongFieldUpdater atomicLongFieldUpdater = f8656e; if ((atomicLongFieldUpdater.addAndGet(eVar, 1L) & 4611686018427387904L) != 0) { while ((atomicLongFieldUpdater.get(eVar) & 4611686018427387904L) != 0) { } } } /* JADX WARN: Removed duplicated region for block: B:7:0x0015 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object B(m mVar, int i6, long j4, C4.c cVar) { d dVar; m mVar2; if (cVar instanceof d) { dVar = (d) cVar; int i7 = dVar.f8652c; if ((i7 & Integer.MIN_VALUE) != 0) { dVar.f8652c = i7 - Integer.MIN_VALUE; } else { dVar = new d(this, cVar); } } Object objR = dVar.f8650a; B4.a aVar = B4.a.f492a; int i8 = dVar.f8652c; if (i8 == 0) { AbstractC2467b.l(objR); dVar.f8652c = 1; C0772m c0772mR = E.r(AbstractC0872a.V(dVar)); try { u uVar = new u(c0772mR); Object objF = F(mVar, i6, j4, uVar); if (objF == g.f8674m) { uVar.a(mVar, i6); } else if (objF == g.f8676o) { if (j4 < r()) { mVar.b(); } m mVar3 = (m) f8658j.get(this); while (true) { if (u()) { c0772mR.resumeWith(new l(new j(o()))); break; } long andIncrement = f8654c.getAndIncrement(this); long j6 = g.f8664b; long j7 = andIncrement / j6; int i9 = (int) (andIncrement % j6); if (mVar3.f10849c != j7) { m mVarN = n(j7, mVar3); if (mVarN != null) { mVar2 = mVarN; } } else { mVar2 = mVar3; } Object objF2 = F(mVar2, i9, andIncrement, uVar); m mVar4 = mVar2; if (objF2 == g.f8674m) { uVar.a(mVar4, i9); break; } if (objF2 == g.f8676o) { if (andIncrement < r()) { mVar4.b(); } mVar3 = mVar4; } else { if (objF2 == g.f8675n) { throw new IllegalStateException("unexpected"); } mVar4.b(); c0772mR.k(new l(objF2), null); } } } else { mVar.b(); c0772mR.k(new l(objF), null); } objR = c0772mR.r(); B4.a aVar2 = B4.a.f492a; if (objR == aVar) { return aVar; } } catch (Throwable th) { c0772mR.z(); throw th; } } else { if (i8 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } AbstractC2467b.l(objR); } return ((l) objR).f8686a; } public final void C(N0 n02, boolean z6) { if (n02 instanceof InterfaceC0770l) { ((A4.d) n02).resumeWith(AbstractC2467b.d(z6 ? p() : q())); return; } if (n02 instanceof u) { ((u) n02).f8698a.resumeWith(new l(new j(o()))); return; } if (!(n02 instanceof b)) { throw new IllegalStateException(("Unexpected waiter: " + n02).toString()); } b bVar = (b) n02; C0772m c0772m = bVar.f8645b; kotlin.jvm.internal.o.e(c0772m); bVar.f8645b = null; bVar.f8644a = g.l; Throwable thO = bVar.f8646c.o(); if (thO == null) { c0772m.resumeWith(Boolean.FALSE); } else { c0772m.resumeWith(AbstractC2467b.d(thO)); } } public final boolean D(Object obj, Object obj2) { if (obj instanceof u) { kotlin.jvm.internal.o.f(obj, "null cannot be cast to non-null type kotlinx.coroutines.channels.ReceiveCatching"); return g.a(((u) obj).f8698a, new l(obj2), null); } if (!(obj instanceof b)) { if (obj instanceof InterfaceC0770l) { kotlin.jvm.internal.o.f(obj, "null cannot be cast to non-null type kotlinx.coroutines.CancellableContinuation"); return g.a((InterfaceC0770l) obj, obj2, null); } throw new IllegalStateException(("Unexpected receiver type: " + obj).toString()); } kotlin.jvm.internal.o.f(obj, "null cannot be cast to non-null type kotlinx.coroutines.channels.BufferedChannel.BufferedChannelIterator"); b bVar = (b) obj; C0772m c0772m = bVar.f8645b; kotlin.jvm.internal.o.e(c0772m); bVar.f8645b = null; bVar.f8644a = obj2; Boolean bool = Boolean.TRUE; bVar.f8646c.getClass(); return g.a(c0772m, bool, null); } public final Object F(m mVar, int i6, long j4, Object obj) { Object objL = mVar.l(i6); AtomicReferenceArray atomicReferenceArray = mVar.f8688f; AtomicLongFieldUpdater atomicLongFieldUpdater = f8653b; if (objL == null) { if (j4 >= (atomicLongFieldUpdater.get(this) & 1152921504606846975L)) { if (obj == null) { return g.f8675n; } if (mVar.k(i6, objL, obj)) { m(); return g.f8674m; } } } else if (objL == g.f8666d && mVar.k(i6, objL, g.f8671i)) { m(); Object obj2 = atomicReferenceArray.get(i6 * 2); mVar.n(i6, null); return obj2; } while (true) { Object objL2 = mVar.l(i6); if (objL2 == null || objL2 == g.f8667e) { if (j4 < (atomicLongFieldUpdater.get(this) & 1152921504606846975L)) { if (mVar.k(i6, objL2, g.f8670h)) { m(); return g.f8676o; } } else { if (obj == null) { return g.f8675n; } if (mVar.k(i6, objL2, obj)) { m(); return g.f8674m; } } } else if (objL2 != g.f8666d) { C0317a c0317a = g.f8672j; if (objL2 == c0317a) { return g.f8676o; } if (objL2 == g.f8670h) { return g.f8676o; } if (objL2 == g.l) { m(); return g.f8676o; } if (objL2 != g.f8669g && mVar.k(i6, objL2, g.f8668f)) { boolean z6 = objL2 instanceof x; if (z6) { objL2 = ((x) objL2).f8699a; } if (E(objL2)) { mVar.o(i6, g.f8671i); m(); Object obj3 = atomicReferenceArray.get(i6 * 2); mVar.n(i6, null); return obj3; } mVar.o(i6, c0317a); mVar.i(); if (z6) { m(); } return g.f8676o; } } else if (mVar.k(i6, objL2, g.f8671i)) { m(); Object obj4 = atomicReferenceArray.get(i6 * 2); mVar.n(i6, null); return obj4; } } } public final int G(m mVar, int i6, Object obj, long j4, Object obj2, boolean z6) { while (true) { Object objL = mVar.l(i6); if (objL == null) { if (!i(j4) || z6) { if (z6) { if (mVar.k(i6, null, g.f8672j)) { mVar.i(); return 4; } } else { if (obj2 == null) { return 3; } if (mVar.k(i6, null, obj2)) { return 2; } } } else if (mVar.k(i6, null, g.f8666d)) { break; } } else { if (objL != g.f8667e) { C0317a c0317a = g.f8673k; if (objL == c0317a) { mVar.n(i6, null); return 5; } if (objL == g.f8670h) { mVar.n(i6, null); return 5; } if (objL == g.l) { mVar.n(i6, null); v(); return 4; } mVar.n(i6, null); if (objL instanceof x) { objL = ((x) objL).f8699a; } if (D(objL, obj)) { mVar.o(i6, g.f8671i); return 0; } if (mVar.f8688f.getAndSet((i6 * 2) + 1, c0317a) != c0317a) { mVar.m(i6, true); } return 5; } if (mVar.k(i6, objL, g.f8666d)) { break; } } } return 1; } public final void H(long j4) { AtomicLongFieldUpdater atomicLongFieldUpdater; e eVar = this; if (eVar.x()) { return; } while (true) { atomicLongFieldUpdater = f8655d; if (atomicLongFieldUpdater.get(eVar) > j4) { break; } else { eVar = this; } } int i6 = g.f8665c; int i7 = 0; while (true) { AtomicLongFieldUpdater atomicLongFieldUpdater2 = f8656e; if (i7 < i6) { long j6 = atomicLongFieldUpdater.get(eVar); if (j6 == (4611686018427387903L & atomicLongFieldUpdater2.get(eVar)) && j6 == atomicLongFieldUpdater.get(eVar)) { return; } else { i7++; } } else { while (true) { long j7 = atomicLongFieldUpdater2.get(eVar); if (atomicLongFieldUpdater2.compareAndSet(eVar, j7, (j7 & 4611686018427387903L) + 4611686018427387904L)) { break; } else { eVar = this; } } while (true) { long j8 = atomicLongFieldUpdater.get(eVar); long j9 = atomicLongFieldUpdater2.get(eVar); long j10 = j9 & 4611686018427387903L; boolean z6 = (j9 & 4611686018427387904L) != 0; if (j8 == j10 && j8 == atomicLongFieldUpdater.get(eVar)) { break; } if (!z6) { atomicLongFieldUpdater2.compareAndSet(this, j9, 4611686018427387904L + j10); } eVar = this; } while (true) { long j11 = atomicLongFieldUpdater2.get(eVar); if (atomicLongFieldUpdater2.compareAndSet(eVar, j11, j11 & 4611686018427387903L)) { return; } else { eVar = this; } } } } } @Override // X4.v public final Object a(Z4.s sVar) { return A(this, sVar); } @Override // X4.v public final Object c() { m mVar; AtomicLongFieldUpdater atomicLongFieldUpdater = f8654c; long j4 = atomicLongFieldUpdater.get(this); long j6 = f8653b.get(this); if (t(j6, true)) { return new j(o()); } long j7 = j6 & 1152921504606846975L; k kVar = l.f8685b; if (j4 >= j7) { return kVar; } Object obj = g.f8673k; m mVar2 = (m) f8658j.get(this); while (!u()) { long andIncrement = atomicLongFieldUpdater.getAndIncrement(this); long j8 = g.f8664b; long j9 = andIncrement / j8; int i6 = (int) (andIncrement % j8); if (mVar2.f10849c != j9) { m mVarN = n(j9, mVar2); if (mVarN == null) { continue; } else { mVar = mVarN; } } else { mVar = mVar2; } Object objF = F(mVar, i6, andIncrement, obj); m mVar3 = mVar; if (objF == g.f8674m) { N0 n02 = obj instanceof N0 ? (N0) obj : null; if (n02 != null) { n02.a(mVar3, i6); } H(andIncrement); mVar3.i(); return kVar; } if (objF != g.f8676o) { if (objF == g.f8675n) { throw new IllegalStateException("unexpected"); } mVar3.b(); return objF; } if (andIncrement < r()) { mVar3.b(); } mVar2 = mVar3; } return new j(o()); } @Override // X4.v public final void cancel(CancellationException cancellationException) { if (cancellationException == null) { cancellationException = new CancellationException("Channel was cancelled"); } j(cancellationException, true); } @Override // X4.v public final Object e(A4.d dVar) { m mVar; Throwable th; m mVar2; AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f8658j; m mVar3 = (m) atomicReferenceFieldUpdater.get(this); while (!u()) { AtomicLongFieldUpdater atomicLongFieldUpdater = f8654c; long andIncrement = atomicLongFieldUpdater.getAndIncrement(this); long j4 = g.f8664b; long j6 = andIncrement / j4; int i6 = (int) (andIncrement % j4); if (mVar3.f10849c != j6) { m mVarN = n(j6, mVar3); if (mVarN == null) { continue; } else { mVar = mVarN; } } else { mVar = mVar3; } Object objF = F(mVar, i6, andIncrement, null); C0317a c0317a = g.f8674m; if (objF == c0317a) { throw new IllegalStateException("unexpected"); } C0317a c0317a2 = g.f8676o; if (objF == c0317a2) { if (andIncrement < r()) { mVar.b(); } mVar3 = mVar; } else { if (objF != g.f8675n) { mVar.b(); return objF; } C0772m c0772mR = E.r(AbstractC0872a.V(dVar)); e eVar = this; try { Object objF2 = eVar.F(mVar, i6, andIncrement, c0772mR); if (objF2 == c0317a) { c0772mR.a(mVar, i6); } else { if (objF2 == c0317a2) { if (andIncrement < r()) { mVar.b(); } m mVar4 = (m) atomicReferenceFieldUpdater.get(this); while (true) { if (u()) { c0772mR.resumeWith(AbstractC2467b.d(p())); break; } C0772m c0772m = c0772mR; try { long andIncrement2 = atomicLongFieldUpdater.getAndIncrement(this); long j7 = g.f8664b; long j8 = andIncrement2 / j7; int i7 = (int) (andIncrement2 % j7); if (mVar4.f10849c != j8) { try { m mVarN2 = n(j8, mVar4); if (mVarN2 == null) { c0772mR = c0772m; } else { mVar2 = mVarN2; } } catch (Throwable th2) { th = th2; c0772mR = c0772m; c0772mR.z(); throw th; } } else { mVar2 = mVar4; } objF2 = eVar.F(mVar2, i7, andIncrement2, c0772m); m mVar5 = mVar2; c0772mR = c0772m; if (objF2 == g.f8674m) { c0772mR.a(mVar5, i7); break; } if (objF2 == g.f8676o) { if (andIncrement2 < r()) { mVar5.b(); } eVar = this; mVar4 = mVar5; } else { if (objF2 == g.f8675n) { throw new IllegalStateException("unexpected"); } mVar5.b(); } } catch (Throwable th3) { th = th3; c0772mR = c0772m; th = th; c0772mR.z(); throw th; } } } else { mVar.b(); } c0772mR.k(objF2, null); } Object objR = c0772mR.r(); B4.a aVar = B4.a.f492a; return objR; } catch (Throwable th4) { th = th4; } } } Throwable thP = p(); int i8 = a5.r.f10850a; throw thP; } /* JADX WARN: Removed duplicated region for block: B:22:0x0068 */ /* JADX WARN: Removed duplicated region for block: B:57:0x00be A[SYNTHETIC] */ @Override // X4.w /* Code decompiled incorrectly, please refer to instructions dump. */ public Object f(Object obj) { int iH; AtomicLongFieldUpdater atomicLongFieldUpdater = f8653b; boolean z6 = false; long j4 = 1152921504606846975L; boolean z7 = t(atomicLongFieldUpdater.get(this), false) ? false : !i(r1 & 1152921504606846975L); k kVar = l.f8685b; if (z7) { return kVar; } Object obj2 = g.f8672j; m mVar = (m) f8657f.get(this); while (true) { long andIncrement = atomicLongFieldUpdater.getAndIncrement(this); long j6 = andIncrement & j4; boolean zT = t(andIncrement, z6); int i6 = g.f8664b; long j7 = i6; long j8 = j6 / j7; int i7 = (int) (j6 % j7); if (mVar.f10849c == j8) { iH = h(this, mVar, i7, obj, j6, obj2, zT); C3137A c3137a = C3137A.f25453a; if (iH != 0) { mVar.b(); return c3137a; } if (iH == 1) { return c3137a; } if (iH == 2) { if (zT) { mVar.i(); return new j(q()); } N0 n02 = obj2 instanceof N0 ? (N0) obj2 : null; if (n02 != null) { n02.a(mVar, i7 + i6); } mVar.i(); return kVar; } if (iH == 3) { throw new IllegalStateException("unexpected"); } if (iH == 4) { if (j6 < f8654c.get(this)) { mVar.b(); } return new j(q()); } if (iH == 5) { mVar.b(); } z6 = false; } else { m mVarB = b(this, j8, mVar); if (mVarB != null) { mVar = mVarB; iH = h(this, mVar, i7, obj, j6, obj2, zT); C3137A c3137a2 = C3137A.f25453a; if (iH != 0) { } } else { if (zT) { return new j(q()); } z6 = false; } } j4 = 1152921504606846975L; } } /* JADX WARN: Code restructure failed: missing block: B:103:0x0189, code lost: return r10; */ /* JADX WARN: Code restructure failed: missing block: B:45:0x00c6, code lost: d(r1, r4, r7); */ /* JADX WARN: Removed duplicated region for block: B:93:0x0170 */ /* JADX WARN: Removed duplicated region for block: B:95:0x0173 A[RETURN] */ @Override // X4.w /* Code decompiled incorrectly, please refer to instructions dump. */ public Object g(A4.d dVar, Object obj) throws Throwable { int iH; Object objR; B4.a aVar; Object obj2; e eVar; int i6; int i7; boolean z6; m mVar; e eVar2 = this; AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f8657f; m mVar2 = (m) atomicReferenceFieldUpdater.get(eVar2); while (true) { AtomicLongFieldUpdater atomicLongFieldUpdater = f8653b; long andIncrement = atomicLongFieldUpdater.getAndIncrement(eVar2); long j4 = andIncrement & 1152921504606846975L; boolean zT = eVar2.t(andIncrement, false); int i8 = g.f8664b; long j6 = i8; long j7 = j4 / j6; int i9 = (int) (j4 % j6); long j8 = mVar2.f10849c; C3137A c3137a = C3137A.f25453a; if (j8 != j7) { m mVarB = b(eVar2, j7, mVar2); if (mVarB != null) { mVar2 = mVarB; } else if (zT) { Object objZ = z(dVar, obj); if (objZ == B4.a.f492a) { return objZ; } } } int iH2 = h(eVar2, mVar2, i9, obj, j4, null, zT); if (iH2 == 0) { mVar2.b(); return c3137a; } if (iH2 == 1) { break; } if (iH2 != 2) { AtomicLongFieldUpdater atomicLongFieldUpdater2 = f8654c; if (iH2 == 3) { C0772m c0772mR = E.r(AbstractC0872a.V(dVar)); Object obj3 = obj; try { iH = h(eVar2, mVar2, i9, obj3, j4, c0772mR, false); try { } catch (Throwable th) { th = th; } } catch (Throwable th2) { th = th2; } if (iH != 0) { if (iH == 1) { c0772mR.resumeWith(c3137a); } else if (iH != 2) { if (iH != 4) { String str = "unexpected"; if (iH != 5) { throw new IllegalStateException("unexpected"); } mVar2.b(); m mVar3 = (m) atomicReferenceFieldUpdater.get(eVar2); while (true) { long andIncrement2 = atomicLongFieldUpdater.getAndIncrement(eVar2); long j9 = andIncrement2 & 1152921504606846975L; boolean zT2 = eVar2.t(andIncrement2, false); int i10 = g.f8664b; AtomicLongFieldUpdater atomicLongFieldUpdater3 = atomicLongFieldUpdater; long j10 = i10; String str2 = str; long j11 = j9 / j10; int i11 = (int) (j9 % j10); AtomicLongFieldUpdater atomicLongFieldUpdater4 = atomicLongFieldUpdater2; if (mVar3.f10849c != j11) { m mVarB2 = b(eVar2, j11, mVar3); if (mVarB2 != null) { z6 = zT2; mVar = mVarB2; i6 = i10; i7 = i11; } else { if (zT2) { break; } atomicLongFieldUpdater = atomicLongFieldUpdater3; str = str2; atomicLongFieldUpdater2 = atomicLongFieldUpdater4; } } else { i6 = i10; i7 = i11; z6 = zT2; mVar = mVar3; } int iH3 = h(eVar2, mVar, i7, obj3, j9, c0772mR, z6); Object obj4 = obj3; eVar = eVar2; m mVar4 = mVar; int i12 = i7; obj2 = obj4; if (iH3 == 0) { mVar4.b(); break; } if (iH3 == 1) { break; } if (iH3 != 2) { if (iH3 == 3) { throw new IllegalStateException(str2); } if (iH3 != 4) { if (iH3 == 5) { mVar4.b(); } mVar3 = mVar4; eVar2 = eVar; atomicLongFieldUpdater = atomicLongFieldUpdater3; str = str2; atomicLongFieldUpdater2 = atomicLongFieldUpdater4; obj3 = obj2; } else if (j9 < atomicLongFieldUpdater4.get(eVar)) { mVar4.b(); } } else if (z6) { mVar4.i(); } else { c0772mR.a(mVar4, i12 + i6); } } c0772mR.z(); throw th; } obj2 = obj3; eVar = eVar2; if (j4 < atomicLongFieldUpdater2.get(eVar)) { mVar2.b(); } d(eVar, obj2, c0772mR); } else { c0772mR.a(mVar2, i9 + i8); } objR = c0772mR.r(); aVar = B4.a.f492a; if (objR != aVar) { objR = c3137a; } if (objR != aVar) { return objR; } } else { mVar2.b(); } c0772mR.resumeWith(c3137a); objR = c0772mR.r(); aVar = B4.a.f492a; if (objR != aVar) { } if (objR != aVar) { } } else if (iH2 == 4) { if (j4 < atomicLongFieldUpdater2.get(eVar2)) { mVar2.b(); } Object objZ2 = z(dVar, obj); if (objZ2 == B4.a.f492a) { return objZ2; } } else if (iH2 == 5) { mVar2.b(); } } else if (zT) { mVar2.i(); Object objZ3 = z(dVar, obj); if (objZ3 == B4.a.f492a) { return objZ3; } } } } public final boolean i(long j4) { return j4 < f8655d.get(this) || j4 < f8654c.get(this) + ((long) this.f8661a); } @Override // X4.v public final b iterator() { return new b(this); } public final boolean j(Throwable th, boolean z6) { e eVar; boolean z7; long j4; long j6; long j7; Object obj; long j8; long j9; AtomicLongFieldUpdater atomicLongFieldUpdater = f8653b; if (!z6) { eVar = this; break; } do { j9 = atomicLongFieldUpdater.get(this); if (((int) (j9 >> 60)) != 0) { eVar = this; break; } m mVar = g.f8663a; eVar = this; } while (!atomicLongFieldUpdater.compareAndSet(eVar, j9, (j9 & 1152921504606846975L) + (((long) 1) << 60))); C0317a c0317a = g.f8680s; while (true) { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = l; if (atomicReferenceFieldUpdater.compareAndSet(this, c0317a, th)) { z7 = true; break; } if (atomicReferenceFieldUpdater.get(this) != c0317a) { z7 = false; break; } } if (z6) { do { j8 = atomicLongFieldUpdater.get(this); } while (!atomicLongFieldUpdater.compareAndSet(eVar, j8, (((long) 3) << 60) + (j8 & 1152921504606846975L))); } else { do { j4 = atomicLongFieldUpdater.get(this); int i6 = (int) (j4 >> 60); if (i6 == 0) { j6 = j4 & 1152921504606846975L; j7 = 2; } else { if (i6 != 1) { break; } j6 = j4 & 1152921504606846975L; j7 = 3; } } while (!atomicLongFieldUpdater.compareAndSet(eVar, j4, (j7 << 60) + j6)); } v(); if (z7) { loop3: while (true) { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater2 = f8660m; obj = atomicReferenceFieldUpdater2.get(this); C0317a c0317a2 = obj == null ? g.f8678q : g.f8679r; while (!atomicReferenceFieldUpdater2.compareAndSet(this, obj, c0317a2)) { if (atomicReferenceFieldUpdater2.get(this) != obj) { break; } } } if (obj != null) { F.c(1, obj); ((J4.c) obj).invoke(o()); return z7; } } return z7; } /* JADX WARN: Code restructure failed: missing block: B:37:0x008f, code lost: r1 = (X4.m) ((a5.b) a5.b.f10817b.get(r1)); */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final m k(long j4) { Object objF; long j6; AtomicReferenceFieldUpdater atomicReferenceFieldUpdater; Object obj = f8659k.get(this); m mVar = (m) f8657f.get(this); if (mVar.f10849c > ((m) obj).f10849c) { obj = mVar; } m mVar2 = (m) f8658j.get(this); if (mVar2.f10849c > ((m) obj).f10849c) { obj = mVar2; } a5.b bVar = (a5.b) obj; loop0: while (true) { bVar.getClass(); Object obj2 = a5.b.f10816a.get(bVar); C0317a c0317a = AbstractC0988a.f10809a; objF = null; if (obj2 == c0317a) { break; } a5.b bVar2 = (a5.b) obj2; if (bVar2 == null) { do { atomicReferenceFieldUpdater = a5.b.f10816a; if (atomicReferenceFieldUpdater.compareAndSet(bVar, null, c0317a)) { break loop0; } } while (atomicReferenceFieldUpdater.get(bVar) == null); } else { bVar = bVar2; } } m mVar3 = (m) bVar; if (w()) { m mVar4 = mVar3; loop2: do { int i6 = g.f8664b - 1; while (true) { if (-1 >= i6) { break; } j6 = (mVar4.f10849c * ((long) g.f8664b)) + ((long) i6); if (j6 < f8654c.get(this)) { break loop2; } while (true) { Object objL = mVar4.l(i6); if (objL != null && objL != g.f8667e) { if (objL == g.f8666d) { break loop2; } } else { if (mVar4.k(i6, objL, g.l)) { mVar4.i(); break; } } } i6--; } } while (mVar4 != null); j6 = -1; if (j6 != -1) { l(j6); } } loop5: for (m mVar5 = mVar3; mVar5 != null; mVar5 = (m) ((a5.b) a5.b.f10817b.get(mVar5))) { for (int i7 = g.f8664b - 1; -1 < i7; i7--) { if ((mVar5.f10849c * ((long) g.f8664b)) + ((long) i7) < j4) { break loop5; } while (true) { Object objL2 = mVar5.l(i7); if (objL2 != null && objL2 != g.f8667e) { if (!(objL2 instanceof x)) { if (!(objL2 instanceof N0)) { break; } if (mVar5.k(i7, objL2, g.l)) { objF = AbstractC0988a.f(objF, objL2); mVar5.m(i7, true); break; } } else { if (mVar5.k(i7, objL2, g.l)) { objF = AbstractC0988a.f(objF, ((x) objL2).f8699a); mVar5.m(i7, true); break; } } } else { if (mVar5.k(i7, objL2, g.l)) { mVar5.i(); break; } } } } } if (objF != null) { if (!(objF instanceof ArrayList)) { C((N0) objF, true); return mVar3; } ArrayList arrayList = (ArrayList) objF; for (int size = arrayList.size() - 1; -1 < size; size--) { C((N0) arrayList.get(size), true); } } return mVar3; } public final void l(long j4) { m mVar = (m) f8658j.get(this); while (true) { AtomicLongFieldUpdater atomicLongFieldUpdater = f8654c; long j6 = atomicLongFieldUpdater.get(this); if (j4 < Math.max(((long) this.f8661a) + j6, f8655d.get(this))) { return; } if (atomicLongFieldUpdater.compareAndSet(this, j6, 1 + j6)) { long j7 = g.f8664b; long j8 = j6 / j7; int i6 = (int) (j6 % j7); if (mVar.f10849c != j8) { m mVarN = n(j8, mVar); if (mVarN != null) { mVar = mVarN; } } m mVar2 = mVar; if (F(mVar2, i6, j6, null) != g.f8676o || j6 < r()) { mVar2.b(); } mVar = mVar2; } } } /* JADX WARN: Code restructure failed: missing block: B:102:0x018e, code lost: s(r15); */ /* JADX WARN: Code restructure failed: missing block: B:103:0x0191, code lost: return; */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void m() { Object objB; if (x()) { return; } AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f8659k; m mVar = (m) atomicReferenceFieldUpdater.get(this); loop0: while (true) { long andIncrement = f8655d.getAndIncrement(this); long j4 = andIncrement / ((long) g.f8664b); if (r() <= andIncrement) { if (mVar.f10849c < j4 && mVar.c() != null) { y(j4, mVar); } s(this); return; } if (mVar.f10849c != j4) { f fVar = f.f8662a; while (true) { objB = AbstractC0988a.b(mVar, j4, fVar); if (!AbstractC0988a.e(objB)) { a5.q qVarC = AbstractC0988a.c(objB); while (true) { a5.q qVar = (a5.q) atomicReferenceFieldUpdater.get(this); if (qVar.f10849c >= qVarC.f10849c) { break; } if (!qVarC.j()) { break; } while (!atomicReferenceFieldUpdater.compareAndSet(this, qVar, qVarC)) { if (atomicReferenceFieldUpdater.get(this) != qVar) { if (qVarC.f()) { qVarC.e(); } } } if (qVar.f()) { qVar.e(); } } } else { break; } } m mVar2 = null; if (AbstractC0988a.e(objB)) { v(); y(j4, mVar); s(this); } else { m mVar3 = (m) AbstractC0988a.c(objB); long j6 = mVar3.f10849c; if (j6 > j4) { long j7 = j6 * ((long) g.f8664b); if (f8655d.compareAndSet(this, 1 + andIncrement, j7)) { AtomicLongFieldUpdater atomicLongFieldUpdater = f8656e; if ((atomicLongFieldUpdater.addAndGet(this, j7 - andIncrement) & 4611686018427387904L) != 0) { while ((atomicLongFieldUpdater.get(this) & 4611686018427387904L) != 0) { } } } else { s(this); } } else { mVar2 = mVar3; } } if (mVar2 == null) { continue; } else { mVar = mVar2; } } int i6 = (int) (andIncrement % ((long) g.f8664b)); Object objL = mVar.l(i6); boolean z6 = objL instanceof N0; AtomicLongFieldUpdater atomicLongFieldUpdater2 = f8654c; if (!z6 || andIncrement < atomicLongFieldUpdater2.get(this) || !mVar.k(i6, objL, g.f8669g)) { while (true) { Object objL2 = mVar.l(i6); if (!(objL2 instanceof N0)) { if (objL2 != g.f8672j) { if (objL2 != null) { if (objL2 == g.f8666d || objL2 == g.f8670h || objL2 == g.f8671i || objL2 == g.f8673k || objL2 == g.l) { break loop0; } if (objL2 != g.f8668f) { throw new IllegalStateException(("Unexpected cell state: " + objL2).toString()); } } else if (mVar.k(i6, objL2, g.f8667e)) { break loop0; } } else { break; } } else if (andIncrement < atomicLongFieldUpdater2.get(this)) { if (mVar.k(i6, objL2, new x((N0) objL2))) { break loop0; } } else if (mVar.k(i6, objL2, g.f8669g)) { if (E(objL2)) { mVar.o(i6, g.f8666d); break; } else { mVar.o(i6, g.f8672j); mVar.i(); } } } } else if (E(objL)) { mVar.o(i6, g.f8666d); break; } else { mVar.o(i6, g.f8672j); mVar.i(); s(this); } } } public final m n(long j4, m mVar) { Object objB; AtomicLongFieldUpdater atomicLongFieldUpdater; long j6; m mVar2 = g.f8663a; f fVar = f.f8662a; loop0: while (true) { objB = AbstractC0988a.b(mVar, j4, fVar); if (!AbstractC0988a.e(objB)) { a5.q qVarC = AbstractC0988a.c(objB); while (true) { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f8658j; a5.q qVar = (a5.q) atomicReferenceFieldUpdater.get(this); if (qVar.f10849c >= qVarC.f10849c) { break loop0; } if (!qVarC.j()) { break; } while (!atomicReferenceFieldUpdater.compareAndSet(this, qVar, qVarC)) { if (atomicReferenceFieldUpdater.get(this) != qVar) { if (qVarC.f()) { qVarC.e(); } } } if (qVar.f()) { qVar.e(); } } } else { break; } } if (AbstractC0988a.e(objB)) { v(); if (mVar.f10849c * ((long) g.f8664b) < r()) { mVar.b(); return null; } } else { m mVar3 = (m) AbstractC0988a.c(objB); boolean zX = x(); long j7 = mVar3.f10849c; if (!zX && j4 <= f8655d.get(this) / ((long) g.f8664b)) { while (true) { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater2 = f8659k; a5.q qVar2 = (a5.q) atomicReferenceFieldUpdater2.get(this); if (qVar2.f10849c >= j7 || !mVar3.j()) { break; } while (!atomicReferenceFieldUpdater2.compareAndSet(this, qVar2, mVar3)) { if (atomicReferenceFieldUpdater2.get(this) != qVar2) { if (mVar3.f()) { mVar3.e(); } } } if (qVar2.f()) { qVar2.e(); } } } if (j7 <= j4) { return mVar3; } long j8 = j7 * ((long) g.f8664b); do { atomicLongFieldUpdater = f8654c; j6 = atomicLongFieldUpdater.get(this); if (j6 >= j8) { break; } } while (!atomicLongFieldUpdater.compareAndSet(this, j6, j8)); if (j7 * ((long) g.f8664b) < r()) { mVar3.b(); } } return null; } public final Throwable o() { return (Throwable) l.get(this); } public final Throwable p() { Throwable thO = o(); return thO == null ? new o("Channel was closed") : thO; } public final Throwable q() { Throwable thO = o(); return thO == null ? new p("Channel was closed") : thO; } public final long r() { return f8653b.get(this) & 1152921504606846975L; } /* JADX WARN: Code restructure failed: missing block: B:53:0x00a2, code lost: r0 = (X4.m) ((a5.b) a5.b.f10817b.get(r0)); */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final boolean t(long j4, boolean z6) { int i6 = (int) (j4 >> 60); if (i6 != 0 && i6 != 1) { AtomicLongFieldUpdater atomicLongFieldUpdater = f8654c; if (i6 == 2) { k(1152921504606846975L & j4); if (z6) { while (true) { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f8658j; m mVarN = (m) atomicReferenceFieldUpdater.get(this); long j6 = atomicLongFieldUpdater.get(this); if (r() <= j6) { break; } long j7 = g.f8664b; long j8 = j6 / j7; if (mVarN.f10849c != j8 && (mVarN = n(j8, mVarN)) == null) { if (((m) atomicReferenceFieldUpdater.get(this)).f10849c < j8) { break; } } else { mVarN.b(); int i7 = (int) (j6 % j7); while (true) { Object objL = mVarN.l(i7); if (objL != null && objL != g.f8667e) { if (objL == g.f8666d || (objL != g.f8672j && objL != g.l && objL != g.f8671i && objL != g.f8670h && (objL == g.f8669g || (objL != g.f8668f && j6 == atomicLongFieldUpdater.get(this))))) { break; } } else { if (mVarN.k(i7, objL, g.f8670h)) { m(); break; } } } f8654c.compareAndSet(this, j6, j6 + 1); } } } } else { if (i6 != 3) { throw new IllegalStateException(Z0.o.l("unexpected close status: ", i6).toString()); } m mVarK = k(1152921504606846975L & j4); Object objF = null; loop0: do { int i8 = g.f8664b - 1; while (true) { if (-1 >= i8) { break; } long j9 = (mVarK.f10849c * ((long) g.f8664b)) + ((long) i8); while (true) { Object objL2 = mVarK.l(i8); if (objL2 == g.f8671i) { break loop0; } if (objL2 != g.f8666d) { if (objL2 != g.f8667e && objL2 != null) { if (!(objL2 instanceof N0) && !(objL2 instanceof x)) { C0317a c0317a = g.f8669g; if (objL2 == c0317a || objL2 == g.f8668f) { break loop0; } if (objL2 != c0317a) { break; } } else { if (j9 < atomicLongFieldUpdater.get(this)) { break loop0; } N0 n02 = objL2 instanceof x ? ((x) objL2).f8699a : (N0) objL2; if (mVarK.k(i8, objL2, g.l)) { objF = AbstractC0988a.f(objF, n02); mVarK.n(i8, null); mVarK.i(); break; } } } else { if (mVarK.k(i8, objL2, g.l)) { mVarK.i(); break; } } } else { if (j9 < atomicLongFieldUpdater.get(this)) { break loop0; } if (mVarK.k(i8, objL2, g.l)) { mVarK.n(i8, null); mVarK.i(); break; } } } i8--; } } while (mVarK != null); if (objF != null) { if (objF instanceof ArrayList) { ArrayList arrayList = (ArrayList) objF; for (int size = arrayList.size() - 1; -1 < size; size--) { C((N0) arrayList.get(size), false); } } else { C((N0) objF, false); } } } return true; } return false; } /* JADX WARN: Code restructure failed: missing block: B:75:0x019d, code lost: r16 = r7; r3 = (X4.m) r3.c(); */ /* JADX WARN: Code restructure failed: missing block: B:76:0x01a6, code lost: if (r3 != null) goto L82; */ /* JADX WARN: Multi-variable type inference failed */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final String toString() { boolean z6; String string; StringBuilder sb = new StringBuilder(); int i6 = (int) (f8653b.get(this) >> 60); if (i6 == 2) { sb.append("closed,"); } else if (i6 == 3) { sb.append("cancelled,"); } sb.append("capacity=" + this.f8661a + ','); sb.append("data=["); int i7 = 0; boolean z7 = true; List listB = AbstractC3252r.B(f8658j.get(this), f8657f.get(this), f8659k.get(this)); ArrayList arrayList = new ArrayList(); for (Object obj : listB) { if (((m) obj) != g.f8663a) { arrayList.add(obj); } } Iterator it = arrayList.iterator(); if (!it.hasNext()) { throw new NoSuchElementException(); } Object next = it.next(); if (it.hasNext()) { long j4 = ((m) next).f10849c; do { Object next2 = it.next(); long j6 = ((m) next2).f10849c; if (j4 > j6) { next = next2; j4 = j6; } } while (it.hasNext()); } m mVar = (m) next; long j7 = f8654c.get(this); long jR = r(); loop2: while (true) { int i8 = g.f8664b; int i9 = i7; while (true) { if (i9 >= i8) { break; } long j8 = (mVar.f10849c * ((long) g.f8664b)) + ((long) i9); if (j8 >= jR && j8 >= j7) { break loop2; } Object objL = mVar.l(i9); boolean z8 = z7; Object obj2 = mVar.f8688f.get(i9 * 2); if (objL instanceof InterfaceC0770l) { string = (j8 >= j7 || j8 < jR) ? (j8 >= jR || j8 < j7) ? "cont" : "send" : "receive"; } else if (objL instanceof u) { string = "receiveCatching"; } else if (objL instanceof x) { string = "EB(" + objL + ')'; } else if (kotlin.jvm.internal.o.c(objL, g.f8668f) || kotlin.jvm.internal.o.c(objL, g.f8669g)) { string = "resuming_sender"; } else if (objL == null || objL.equals(g.f8667e) || objL.equals(g.f8671i) || objL.equals(g.f8670h) || objL.equals(g.f8673k) || objL.equals(g.f8672j) || objL.equals(g.l)) { i9++; z7 = z8; } else { string = objL.toString(); } if (obj2 != null) { sb.append("(" + string + ',' + obj2 + "),"); } else { sb.append(string + ','); } i9++; z7 = z8; } z7 = z6; i7 = 0; } if (S4.p.R0(sb) == ',') { kotlin.jvm.internal.o.g(sb.deleteCharAt(sb.length() - 1), "deleteCharAt(...)"); } sb.append("]"); return sb.toString(); } public final boolean u() { return t(f8653b.get(this), true); } public final boolean v() { return t(f8653b.get(this), false); } public boolean w() { return false; } public final boolean x() { long j4 = f8655d.get(this); return j4 == 0 || j4 == Long.MAX_VALUE; } /* JADX WARN: Code restructure failed: missing block: B:39:0x0011, code lost: continue; */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void y(long j4, m mVar) { m mVar2; m mVar3; while (mVar.f10849c < j4 && (mVar3 = (m) mVar.c()) != null) { mVar = mVar3; } while (true) { if (!mVar.d() || (mVar2 = (m) mVar.c()) == null) { while (true) { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f8659k; a5.q qVar = (a5.q) atomicReferenceFieldUpdater.get(this); if (qVar.f10849c >= mVar.f10849c) { return; } if (!mVar.j()) { break; } while (!atomicReferenceFieldUpdater.compareAndSet(this, qVar, mVar)) { if (atomicReferenceFieldUpdater.get(this) != qVar) { if (mVar.f()) { mVar.e(); } } } if (qVar.f()) { qVar.e(); return; } return; } } mVar = mVar2; } } public final Object z(A4.d dVar, Object obj) { C0772m c0772m = new C0772m(1, AbstractC0872a.V(dVar)); c0772m.s(); c0772m.resumeWith(AbstractC2467b.d(q())); Object objR = c0772m.r(); return objR == B4.a.f492a ? objR : C3137A.f25453a; } }