package kotlinx.coroutines.internal; import androidx.concurrent.futures.AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0; import com.mbridge.msdk.foundation.entity.CampaignEx; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import kotlin.Metadata; import kotlin.Unit; import kotlin.jvm.Volatile; import kotlin.jvm.functions.Function0; import kotlin.jvm.functions.Function1; import kotlin.jvm.internal.Intrinsics; import kotlin.jvm.internal.PropertyReference0Impl; import kotlinx.coroutines.DebugKt; import kotlinx.coroutines.DebugStringsKt; /* compiled from: LockFreeLinkedList.kt */ @Metadata(d1 = {"\u0000X\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\b\n\u0002\b\u0006\b\u0017\u0018\u00002\u00020\u0001:\u00010B\u0005¢\u0006\u0002\u0010\u0002J\u0012\u0010\u0014\u001a\u00020\u00152\n\u0010\u0016\u001a\u00060\u0000j\u0002`\u000fJ%\u0010\u0017\u001a\u00020\t2\n\u0010\u0016\u001a\u00060\u0000j\u0002`\u000f2\u000e\b\u0004\u0010\u0018\u001a\b\u0012\u0004\u0012\u00020\t0\u0019H\u0086\bJ \u0010\u001a\u001a\u00020\t2\n\u0010\u0016\u001a\u00060\u0000j\u0002`\u000f2\n\u0010\u000b\u001a\u00060\u0000j\u0002`\u000fH\u0001J\u0012\u0010\u001b\u001a\u00020\t2\n\u0010\u0016\u001a\u00060\u0000j\u0002`\u000fJ\u001b\u0010\u001c\u001a\n\u0018\u00010\u0000j\u0004\u0018\u0001`\u000f2\b\u0010\u001d\u001a\u0004\u0018\u00010\u001eH\u0082\u0010J\u0019\u0010\u001f\u001a\u00060\u0000j\u0002`\u000f2\n\u0010 \u001a\u00060\u0000j\u0002`\u000fH\u0082\u0010J\u0014\u0010!\u001a\u00020\u00152\n\u0010\u000b\u001a\u00060\u0000j\u0002`\u000fH\u0002J%\u0010\"\u001a\u00020#2\n\u0010\u0016\u001a\u00060\u0000j\u0002`\u000f2\u000e\b\u0004\u0010\u0018\u001a\b\u0012\u0004\u0012\u00020\t0\u0019H\u0081\bJ\u0010\u0010$\u001a\n\u0018\u00010\u0000j\u0004\u0018\u0001`\u000fH\u0014J\b\u0010%\u001a\u00020\tH\u0016J\u0010\u0010&\u001a\n\u0018\u00010\u0000j\u0004\u0018\u0001`\u000fH\u0001J\b\u0010'\u001a\u00020\u0007H\u0002J\b\u0010(\u001a\u00020)H\u0016J(\u0010*\u001a\u00020+2\n\u0010\u0016\u001a\u00060\u0000j\u0002`\u000f2\n\u0010\u000b\u001a\u00060\u0000j\u0002`\u000f2\u0006\u0010,\u001a\u00020#H\u0001J%\u0010-\u001a\u00020\u00152\n\u0010.\u001a\u00060\u0000j\u0002`\u000f2\n\u0010\u000b\u001a\u00060\u0000j\u0002`\u000fH\u0000¢\u0006\u0002\b/R\u000f\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00010\u0004X\u0082\u0004R\u000f\u0010\u0005\u001a\b\u0012\u0004\u0012\u00020\u00000\u0004X\u0082\u0004R\u0011\u0010\u0006\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00070\u0004X\u0082\u0004R\u0014\u0010\b\u001a\u00020\t8VX\u0096\u0004¢\u0006\u0006\u001a\u0004\b\b\u0010\nR\u0011\u0010\u000b\u001a\u00020\u00018F¢\u0006\u0006\u001a\u0004\b\f\u0010\rR\u0015\u0010\u000e\u001a\u00060\u0000j\u0002`\u000f8F¢\u0006\u0006\u001a\u0004\b\u0010\u0010\u0011R\u0015\u0010\u0012\u001a\u00060\u0000j\u0002`\u000f8F¢\u0006\u0006\u001a\u0004\b\u0013\u0010\u0011¨\u00061"}, d2 = {"Lkotlinx/coroutines/internal/LockFreeLinkedListNode;", "", "()V", "_next", "Lkotlinx/atomicfu/AtomicRef;", "_prev", "_removedRef", "Lkotlinx/coroutines/internal/Removed;", "isRemoved", "", "()Z", "next", "getNext", "()Ljava/lang/Object;", "nextNode", "Lkotlinx/coroutines/internal/Node;", "getNextNode", "()Lkotlinx/coroutines/internal/LockFreeLinkedListNode;", "prevNode", "getPrevNode", "addLast", "", "node", "addLastIf", "condition", "Lkotlin/Function0;", "addNext", "addOneIfEmpty", "correctPrev", "op", "Lkotlinx/coroutines/internal/OpDescriptor;", "findPrevNonRemoved", "current", "finishAdd", "makeCondAddOp", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode$CondAddOp;", "nextIfRemoved", "remove", "removeOrNext", "removed", "toString", "", "tryCondAddNext", "", "condAdd", "validateNode", "prev", "validateNode$kotlinx_coroutines_core", "CondAddOp", "kotlinx-coroutines-core"}, k = 1, mv = {1, 8, 0}, xi = 48) /* loaded from: classes6.dex */ public class LockFreeLinkedListNode { private static final AtomicReferenceFieldUpdater _next$FU = AtomicReferenceFieldUpdater.newUpdater(LockFreeLinkedListNode.class, Object.class, "_next"); private static final AtomicReferenceFieldUpdater _prev$FU = AtomicReferenceFieldUpdater.newUpdater(LockFreeLinkedListNode.class, Object.class, "_prev"); private static final AtomicReferenceFieldUpdater _removedRef$FU = AtomicReferenceFieldUpdater.newUpdater(LockFreeLinkedListNode.class, Object.class, "_removedRef"); @Volatile private volatile Object _next = this; @Volatile private volatile Object _prev = this; @Volatile private volatile Object _removedRef; private final void loop$atomicfu(AtomicReferenceFieldUpdater atomicReferenceFieldUpdater, Function1 function1, Object obj) { while (true) { function1.invoke(atomicReferenceFieldUpdater.get(obj)); } } private final Removed removed() { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = _removedRef$FU; Removed removed = (Removed) atomicReferenceFieldUpdater.get(this); if (removed == null) { Removed removed2 = new Removed(this); atomicReferenceFieldUpdater.lazySet(this, removed2); return removed2; } return removed; } /* compiled from: LockFreeLinkedList.kt */ @Metadata(d1 = {"\u0000\"\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0000\b!\u0018\u00002\f\u0012\b\u0012\u00060\u0002j\u0002`\u00030\u0001B\u0011\u0012\n\u0010\u0004\u001a\u00060\u0002j\u0002`\u0003¢\u0006\u0002\u0010\u0005J\u001e\u0010\u0007\u001a\u00020\b2\n\u0010\t\u001a\u00060\u0002j\u0002`\u00032\b\u0010\n\u001a\u0004\u0018\u00010\u000bH\u0016R\u0014\u0010\u0004\u001a\u00060\u0002j\u0002`\u00038\u0006X\u0087\u0004¢\u0006\u0002\n\u0000R\u001a\u0010\u0006\u001a\n\u0018\u00010\u0002j\u0004\u0018\u0001`\u00038\u0006@\u0006X\u0087\u000e¢\u0006\u0002\n\u0000¨\u0006\f"}, d2 = {"Lkotlinx/coroutines/internal/LockFreeLinkedListNode$CondAddOp;", "Lkotlinx/coroutines/internal/AtomicOp;", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode;", "Lkotlinx/coroutines/internal/Node;", "newNode", "(Lkotlinx/coroutines/internal/LockFreeLinkedListNode;)V", "oldNext", CampaignEx.JSON_NATIVE_VIDEO_COMPLETE, "", "affected", "failure", "", "kotlinx-coroutines-core"}, k = 1, mv = {1, 8, 0}, xi = 48) /* loaded from: classes7.dex */ public static abstract class CondAddOp extends AtomicOp { public final LockFreeLinkedListNode newNode; public LockFreeLinkedListNode oldNext; public CondAddOp(LockFreeLinkedListNode lockFreeLinkedListNode) { this.newNode = lockFreeLinkedListNode; } @Override // kotlinx.coroutines.internal.AtomicOp public void complete(LockFreeLinkedListNode lockFreeLinkedListNode, Object obj) { boolean z = obj == null; LockFreeLinkedListNode lockFreeLinkedListNode2 = z ? this.newNode : this.oldNext; if (lockFreeLinkedListNode2 != null && AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(LockFreeLinkedListNode._next$FU, lockFreeLinkedListNode, this, lockFreeLinkedListNode2) && z) { LockFreeLinkedListNode lockFreeLinkedListNode3 = this.newNode; LockFreeLinkedListNode lockFreeLinkedListNode4 = this.oldNext; Intrinsics.checkNotNull(lockFreeLinkedListNode4); lockFreeLinkedListNode3.finishAdd(lockFreeLinkedListNode4); } } } public final CondAddOp makeCondAddOp(LockFreeLinkedListNode lockFreeLinkedListNode, Function0 function0) { return new LockFreeLinkedListNode$makeCondAddOp$1(lockFreeLinkedListNode, function0); } public boolean isRemoved() { return getNext() instanceof Removed; } public final Object getNext() { AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = _next$FU; while (true) { Object obj = atomicReferenceFieldUpdater.get(this); if (!(obj instanceof OpDescriptor)) { return obj; } ((OpDescriptor) obj).perform(this); } } public final LockFreeLinkedListNode getNextNode() { return LockFreeLinkedListKt.unwrap(getNext()); } public final LockFreeLinkedListNode getPrevNode() { LockFreeLinkedListNode correctPrev = correctPrev(null); return correctPrev == null ? findPrevNonRemoved((LockFreeLinkedListNode) _prev$FU.get(this)) : correctPrev; } private final LockFreeLinkedListNode findPrevNonRemoved(LockFreeLinkedListNode lockFreeLinkedListNode) { while (lockFreeLinkedListNode.isRemoved()) { lockFreeLinkedListNode = (LockFreeLinkedListNode) _prev$FU.get(lockFreeLinkedListNode); } return lockFreeLinkedListNode; } public final boolean addOneIfEmpty(LockFreeLinkedListNode lockFreeLinkedListNode) { _prev$FU.lazySet(lockFreeLinkedListNode, this); _next$FU.lazySet(lockFreeLinkedListNode, this); while (getNext() == this) { if (AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_next$FU, this, this, lockFreeLinkedListNode)) { lockFreeLinkedListNode.finishAdd(this); return true; } } return false; } public final void addLast(LockFreeLinkedListNode lockFreeLinkedListNode) { do { } while (!getPrevNode().addNext(lockFreeLinkedListNode, this)); } public final boolean addNext(LockFreeLinkedListNode lockFreeLinkedListNode, LockFreeLinkedListNode lockFreeLinkedListNode2) { _prev$FU.lazySet(lockFreeLinkedListNode, this); AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = _next$FU; atomicReferenceFieldUpdater.lazySet(lockFreeLinkedListNode, lockFreeLinkedListNode2); if (AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(atomicReferenceFieldUpdater, this, lockFreeLinkedListNode2, lockFreeLinkedListNode)) { lockFreeLinkedListNode.finishAdd(lockFreeLinkedListNode2); return true; } return false; } public final int tryCondAddNext(LockFreeLinkedListNode lockFreeLinkedListNode, LockFreeLinkedListNode lockFreeLinkedListNode2, CondAddOp condAddOp) { _prev$FU.lazySet(lockFreeLinkedListNode, this); AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = _next$FU; atomicReferenceFieldUpdater.lazySet(lockFreeLinkedListNode, lockFreeLinkedListNode2); condAddOp.oldNext = lockFreeLinkedListNode2; if (AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(atomicReferenceFieldUpdater, this, lockFreeLinkedListNode2, condAddOp)) { return condAddOp.perform(this) == null ? 1 : 2; } return 0; } /* renamed from: remove */ public boolean mo3141remove() { return removeOrNext() == null; } public final LockFreeLinkedListNode removeOrNext() { Object next; LockFreeLinkedListNode lockFreeLinkedListNode; do { next = getNext(); if (next instanceof Removed) { return ((Removed) next).ref; } if (next == this) { return (LockFreeLinkedListNode) next; } Intrinsics.checkNotNull(next, "null cannot be cast to non-null type kotlinx.coroutines.internal.LockFreeLinkedListNode{ kotlinx.coroutines.internal.LockFreeLinkedListKt.Node }"); lockFreeLinkedListNode = (LockFreeLinkedListNode) next; } while (!AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_next$FU, this, next, lockFreeLinkedListNode.removed())); lockFreeLinkedListNode.correctPrev(null); return null; } /* JADX INFO: Access modifiers changed from: private */ public final void finishAdd(LockFreeLinkedListNode lockFreeLinkedListNode) { LockFreeLinkedListNode lockFreeLinkedListNode2; AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = _prev$FU; do { lockFreeLinkedListNode2 = (LockFreeLinkedListNode) atomicReferenceFieldUpdater.get(lockFreeLinkedListNode); if (getNext() != lockFreeLinkedListNode) { return; } } while (!AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(_prev$FU, lockFreeLinkedListNode, lockFreeLinkedListNode2, this)); if (isRemoved()) { lockFreeLinkedListNode.correctPrev(null); } } protected LockFreeLinkedListNode nextIfRemoved() { Object next = getNext(); Removed removed = next instanceof Removed ? (Removed) next : null; if (removed != null) { return removed.ref; } return null; } /* JADX WARN: Code restructure failed: missing block: B:24:0x0042, code lost: if (androidx.concurrent.futures.AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(r4, r3, r2, ((kotlinx.coroutines.internal.Removed) r5).ref) != false) goto L23; */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ private final kotlinx.coroutines.internal.LockFreeLinkedListNode correctPrev(kotlinx.coroutines.internal.OpDescriptor r9) { /* r8 = this; L0: java.util.concurrent.atomic.AtomicReferenceFieldUpdater r0 = kotlinx.coroutines.internal.LockFreeLinkedListNode._prev$FU java.lang.Object r0 = r0.get(r8) kotlinx.coroutines.internal.LockFreeLinkedListNode r0 = (kotlinx.coroutines.internal.LockFreeLinkedListNode) r0 r1 = 0 r2 = r0 La: r3 = r1 Lb: java.util.concurrent.atomic.AtomicReferenceFieldUpdater r4 = kotlinx.coroutines.internal.LockFreeLinkedListNode._next$FU java.lang.Object r5 = r4.get(r2) if (r5 != r8) goto L20 if (r0 != r2) goto L16 return r2 L16: java.util.concurrent.atomic.AtomicReferenceFieldUpdater r1 = kotlinx.coroutines.internal.LockFreeLinkedListNode._prev$FU boolean r0 = androidx.concurrent.futures.AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(r1, r8, r0, r2) if (r0 != 0) goto L1f goto L0 L1f: return r2 L20: boolean r6 = r8.isRemoved() if (r6 == 0) goto L27 return r1 L27: if (r5 != r9) goto L2a return r2 L2a: boolean r6 = r5 instanceof kotlinx.coroutines.internal.OpDescriptor if (r6 == 0) goto L34 kotlinx.coroutines.internal.OpDescriptor r5 = (kotlinx.coroutines.internal.OpDescriptor) r5 r5.perform(r2) goto L0 L34: boolean r6 = r5 instanceof kotlinx.coroutines.internal.Removed if (r6 == 0) goto L50 if (r3 == 0) goto L47 kotlinx.coroutines.internal.Removed r5 = (kotlinx.coroutines.internal.Removed) r5 kotlinx.coroutines.internal.LockFreeLinkedListNode r5 = r5.ref boolean r2 = androidx.concurrent.futures.AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0.m(r4, r3, r2, r5) if (r2 != 0) goto L45 goto L0 L45: r2 = r3 goto La L47: java.util.concurrent.atomic.AtomicReferenceFieldUpdater r4 = kotlinx.coroutines.internal.LockFreeLinkedListNode._prev$FU java.lang.Object r2 = r4.get(r2) kotlinx.coroutines.internal.LockFreeLinkedListNode r2 = (kotlinx.coroutines.internal.LockFreeLinkedListNode) r2 goto Lb L50: java.lang.String r3 = "null cannot be cast to non-null type kotlinx.coroutines.internal.LockFreeLinkedListNode{ kotlinx.coroutines.internal.LockFreeLinkedListKt.Node }" kotlin.jvm.internal.Intrinsics.checkNotNull(r5, r3) r3 = r5 kotlinx.coroutines.internal.LockFreeLinkedListNode r3 = (kotlinx.coroutines.internal.LockFreeLinkedListNode) r3 r7 = r3 r3 = r2 r2 = r7 goto Lb */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.internal.LockFreeLinkedListNode.correctPrev(kotlinx.coroutines.internal.OpDescriptor):kotlinx.coroutines.internal.LockFreeLinkedListNode"); } public final void validateNode$kotlinx_coroutines_core(LockFreeLinkedListNode lockFreeLinkedListNode, LockFreeLinkedListNode lockFreeLinkedListNode2) { if (DebugKt.getASSERTIONS_ENABLED() && lockFreeLinkedListNode != _prev$FU.get(this)) { throw new AssertionError(); } if (DebugKt.getASSERTIONS_ENABLED() && lockFreeLinkedListNode2 != _next$FU.get(this)) { throw new AssertionError(); } } public String toString() { return new PropertyReference0Impl(this) { // from class: kotlinx.coroutines.internal.LockFreeLinkedListNode$toString$1 @Override // kotlin.jvm.internal.PropertyReference0Impl, kotlin.reflect.KProperty0 public Object get() { return DebugStringsKt.getClassSimpleName(this.receiver); } } + '@' + DebugStringsKt.getHexAddress(this); } public final boolean addLastIf(LockFreeLinkedListNode lockFreeLinkedListNode, Function0 function0) { int tryCondAddNext; LockFreeLinkedListNode$makeCondAddOp$1 lockFreeLinkedListNode$makeCondAddOp$1 = new LockFreeLinkedListNode$makeCondAddOp$1(lockFreeLinkedListNode, function0); do { tryCondAddNext = getPrevNode().tryCondAddNext(lockFreeLinkedListNode, this, lockFreeLinkedListNode$makeCondAddOp$1); if (tryCondAddNext == 1) { return true; } } while (tryCondAddNext != 2); return false; } }