CrackMe.apk
Download file
package kotlinx.coroutines.channels;
import java.util.ArrayList;
import java.util.Objects;
import java.util.concurrent.CancellationException;
import kotlin.Deprecated;
import kotlin.DeprecationLevel;
import kotlin.Metadata;
import kotlin.ReplaceWith;
import kotlin.Result;
import kotlin.ResultKt;
import kotlin.Unit;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.IntrinsicsKt;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.DebugProbesKt;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlinx.coroutines.BeforeResumeCancelHandler;
import kotlinx.coroutines.CancellableContinuation;
import kotlinx.coroutines.CancellableContinuationImpl;
import kotlinx.coroutines.CancellableContinuationImplKt;
import kotlinx.coroutines.CancellableContinuationKt;
import kotlinx.coroutines.DebugKt;
import kotlinx.coroutines.DebugStringsKt;
import kotlinx.coroutines.DisposableHandle;
import kotlinx.coroutines.channels.Channel;
import kotlinx.coroutines.channels.ChannelIterator;
import kotlinx.coroutines.channels.ChannelResult;
import kotlinx.coroutines.channels.ReceiveChannel;
import kotlinx.coroutines.internal.AtomicKt;
import kotlinx.coroutines.internal.InlineList;
import kotlinx.coroutines.internal.LockFreeLinkedListHead;
import kotlinx.coroutines.internal.LockFreeLinkedListNode;
import kotlinx.coroutines.internal.LockFreeLinkedList_commonKt;
import kotlinx.coroutines.internal.OnUndeliveredElementKt;
import kotlinx.coroutines.internal.StackTraceRecoveryKt;
import kotlinx.coroutines.internal.Symbol;
import kotlinx.coroutines.intrinsics.CancellableKt;
import kotlinx.coroutines.intrinsics.UndispatchedKt;
import kotlinx.coroutines.selects.SelectClause1;
import kotlinx.coroutines.selects.SelectInstance;
import kotlinx.coroutines.selects.SelectKt;
@Metadata(d1 = {"\u0000\u0001\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u000e\b \u0018\u0000*\u0004\b\u0000\u0010\u00012\b\u0012\u0004\u0012\u0002H\u00010\u00022\b\u0012\u0004\u0012\u0002H\u00010\u0003:\u0007STUVWXYB'\u0012 \u0010\u0004\u001a\u001c\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00020\u0006\u0018\u00010\u0005j\n\u0012\u0004\u0012\u00028\u0000\u0018\u0001`\u0007¢\u0006\u0002\u0010\bJ\u0012\u0010\u0019\u001a\u00020\n2\b\u0010\u001a\u001a\u0004\u0018\u00010\u001bH\u0007J\u0016\u0010\u0019\u001a\u00020\u00062\u000e\u0010\u001a\u001a\n\u0018\u00010\u001cj\u0004\u0018\u0001`\u001dJ\u0017\u0010\u001e\u001a\u00020\n2\b\u0010\u001a\u001a\u0004\u0018\u00010\u001bH\u0000¢\u0006\u0002\b\u001fJ\u000e\u0010 \u001a\b\u0012\u0004\u0012\u00028\u00000!H\u0004J\u0016\u0010\"\u001a\u00020\n2\f\u0010#\u001a\b\u0012\u0004\u0012\u00028\u00000$H\u0002J\u0016\u0010%\u001a\u00020\n2\f\u0010#\u001a\b\u0012\u0004\u0012\u00028\u00000$H\u0014JR\u0010&\u001a\u00020\n\"\u0004\b\u0001\u0010'2\f\u0010(\u001a\b\u0012\u0004\u0012\u0002H'0)2$\u0010*\u001a \b\u0001\u0012\u0006\u0012\u0004\u0018\u00010,\u0012\n\u0012\b\u0012\u0004\u0012\u0002H'0-\u0012\u0006\u0012\u0004\u0018\u00010,0+2\u0006\u0010.\u001a\u00020/H\u0002ø\u0001\u0000¢\u0006\u0002\u00100J\u000f\u00101\u001a\b\u0012\u0004\u0012\u00028\u000002H\u0002J\u0010\u00103\u001a\u00020\u00062\u0006\u00104\u001a\u00020\nH\u0014J/\u00105\u001a\u00020\u00062\f\u00106\u001a\b\u0012\u0004\u0012\u000208072\n\u00109\u001a\u0006\u0012\u0002\b\u00030:H\u0014ø\u0001\u0000ø\u0001\u0001¢\u0006\u0004\b;\u0010<J\b\u0010=\u001a\u00020\u0006H\u0014J\b\u0010>\u001a\u00020\u0006H\u0014J\n\u0010?\u001a\u0004\u0018\u00010,H\u0014J\u0016\u0010@\u001a\u0004\u0018\u00010,2\n\u0010(\u001a\u0006\u0012\u0002\b\u00030)H\u0014J\u0011\u0010#\u001a\u00028\u0000H@ø\u0001\u0000¢\u0006\u0002\u0010AJ\"\u0010B\u001a\b\u0012\u0004\u0012\u00028\u00000\u0017H@ø\u0001\u0000ø\u0001\u0000ø\u0001\u0002ø\u0001\u0001¢\u0006\u0004\bC\u0010AJ\u001f\u0010D\u001a\u0002H'\"\u0004\b\u0001\u0010'2\u0006\u0010.\u001a\u00020/H@ø\u0001\u0000¢\u0006\u0002\u0010EJR\u0010F\u001a\u00020\u0006\"\u0004\b\u0001\u0010'2\f\u0010(\u001a\b\u0012\u0004\u0012\u0002H'0)2\u0006\u0010.\u001a\u00020/2$\u0010*\u001a \b\u0001\u0012\u0006\u0012\u0004\u0018\u00010,\u0012\n\u0012\b\u0012\u0004\u0012\u0002H'0-\u0012\u0006\u0012\u0004\u0018\u00010,0+H\u0002ø\u0001\u0000¢\u0006\u0002\u0010GJ \u0010H\u001a\u00020\u00062\n\u0010I\u001a\u0006\u0012\u0002\b\u00030J2\n\u0010#\u001a\u0006\u0012\u0002\b\u00030$H\u0002J\u0010\u0010K\u001a\n\u0012\u0004\u0012\u00028\u0000\u0018\u00010LH\u0014J\u001c\u0010M\u001a\b\u0012\u0004\u0012\u00028\u00000\u0017ø\u0001\u0000ø\u0001\u0002ø\u0001\u0001¢\u0006\u0004\bN\u0010OJX\u0010P\u001a\u00020\u0006\"\u0004\b\u0001\u0010'* \b\u0001\u0012\u0006\u0012\u0004\u0018\u00010,\u0012\n\u0012\b\u0012\u0004\u0012\u0002H'0-\u0012\u0006\u0012\u0004\u0018\u00010,0+2\f\u0010(\u001a\b\u0012\u0004\u0012\u0002H'0)2\u0006\u0010.\u001a\u00020/2\b\u0010Q\u001a\u0004\u0018\u00010,H\u0002ø\u0001\u0000¢\u0006\u0002\u0010RR\u0014\u0010\t\u001a\u00020\n8DX\u0004¢\u0006\u0006\u001a\u0004\b\u000b\u0010\fR\u0012\u0010\r\u001a\u00020\nX¤\u0004¢\u0006\u0006\u001a\u0004\b\r\u0010\fR\u0012\u0010\u000e\u001a\u00020\nX¤\u0004¢\u0006\u0006\u001a\u0004\b\u000e\u0010\fR\u0014\u0010\u000f\u001a\u00020\n8VX\u0004¢\u0006\u0006\u001a\u0004\b\u000f\u0010\fR\u0014\u0010\u0010\u001a\u00020\n8VX\u0004¢\u0006\u0006\u001a\u0004\b\u0010\u0010\fR\u0014\u0010\u0011\u001a\u00020\n8DX\u0004¢\u0006\u0006\u001a\u0004\b\u0011\u0010\fR\u0017\u0010\u0012\u001a\b\u0012\u0004\u0012\u00028\u00000\u00138F¢\u0006\u0006\u001a\u0004\b\u0014\u0010\u0015R \u0010\u0016\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00028\u00000\u00170\u00138Fø\u0001\u0000¢\u0006\u0006\u001a\u0004\b\u0018\u0010\u0015\u0002\u000f\n\u0002\b\u0019\n\u0005\b¡\u001e0\u0001\n\u0002\b!¨\u0006Z"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel;", "E", "Lkotlinx/coroutines/channels/AbstractSendChannel;", "Lkotlinx/coroutines/channels/Channel;", "onUndeliveredElement", "Lkotlin/Function1;", "", "Lkotlinx/coroutines/internal/OnUndeliveredElement;", "(Lkotlin/jvm/functions/Function1;)V", "hasReceiveOrClosed", "", "getHasReceiveOrClosed", "()Z", "isBufferAlwaysEmpty", "isBufferEmpty", "isClosedForReceive", "isEmpty", "isEmptyImpl", "onReceive", "Lkotlinx/coroutines/selects/SelectClause1;", "getOnReceive", "()Lkotlinx/coroutines/selects/SelectClause1;", "onReceiveCatching", "Lkotlinx/coroutines/channels/ChannelResult;", "getOnReceiveCatching", "cancel", "cause", "", "Ljava/util/concurrent/CancellationException;", "Lkotlinx/coroutines/CancellationException;", "cancelInternal", "cancelInternal$kotlinx_coroutines_core", "describeTryPoll", "Lkotlinx/coroutines/channels/AbstractChannel$TryPollDesc;", "enqueueReceive", "receive", "Lkotlinx/coroutines/channels/Receive;", "enqueueReceiveInternal", "enqueueReceiveSelect", "R", "select", "Lkotlinx/coroutines/selects/SelectInstance;", "block", "Lkotlin/Function2;", "", "Lkotlin/coroutines/Continuation;", "receiveMode", "", "(Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/functions/Function2;I)Z", "iterator", "Lkotlinx/coroutines/channels/ChannelIterator;", "onCancelIdempotent", "wasClosed", "onCancelIdempotentList", "list", "Lkotlinx/coroutines/internal/InlineList;", "Lkotlinx/coroutines/channels/Send;", "closed", "Lkotlinx/coroutines/channels/Closed;", "onCancelIdempotentList-w-w6eGU", "(Ljava/lang/Object;Lkotlinx/coroutines/channels/Closed;)V", "onReceiveDequeued", "onReceiveEnqueued", "pollInternal", "pollSelectInternal", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "receiveCatching", "receiveCatching-JP2dKIU", "receiveSuspend", "(ILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "registerSelectReceiveMode", "(Lkotlinx/coroutines/selects/SelectInstance;ILkotlin/jvm/functions/Function2;)V", "removeReceiveOnCancel", "cont", "Lkotlinx/coroutines/CancellableContinuation;", "takeFirstReceiveOrPeekClosed", "Lkotlinx/coroutines/channels/ReceiveOrClosed;", "tryReceive", "tryReceive-PtdJZtk", "()Ljava/lang/Object;", "tryStartBlockUnintercepted", "value", "(Lkotlin/jvm/functions/Function2;Lkotlinx/coroutines/selects/SelectInstance;ILjava/lang/Object;)V", "Itr", "ReceiveElement", "ReceiveElementWithUndeliveredHandler", "ReceiveHasNext", "ReceiveSelect", "RemoveReceiveOnCancel", "TryPollDesc", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
public abstract class AbstractChannel<E> extends AbstractSendChannel<E> implements Channel<E> {
/* access modifiers changed from: protected */
public abstract boolean isBufferAlwaysEmpty();
/* access modifiers changed from: protected */
public abstract boolean isBufferEmpty();
/* access modifiers changed from: protected */
public void onReceiveDequeued() {
}
/* access modifiers changed from: protected */
public void onReceiveEnqueued() {
}
@Deprecated(level = DeprecationLevel.HIDDEN, message = "Since 1.2.0, binary compatibility with versions <= 1.1.x")
public /* synthetic */ void cancel() {
ReceiveChannel.DefaultImpls.cancel(this);
}
public SelectClause1<E> getOnReceiveOrNull() {
return Channel.DefaultImpls.getOnReceiveOrNull(this);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Deprecated in the favour of 'tryReceive'. Please note that the provided replacement does not rethrow channel's close cause as 'poll' did, for the precise replacement please refer to the 'poll' documentation", replaceWith = @ReplaceWith(expression = "tryReceive().getOrNull()", imports = {}))
public E poll() {
return Channel.DefaultImpls.poll(this);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Deprecated in favor of 'receiveCatching'. Please note that the provided replacement does not rethrow channel's close cause as 'receiveOrNull' did, for the detailed replacement please refer to the 'receiveOrNull' documentation", replaceWith = @ReplaceWith(expression = "receiveCatching().getOrNull()", imports = {}))
public Object receiveOrNull(Continuation<? super E> continuation) {
return Channel.DefaultImpls.receiveOrNull(this, continuation);
}
public AbstractChannel(Function1<? super E, Unit> function1) {
super(function1);
}
/* access modifiers changed from: protected */
public Object pollInternal() {
while (true) {
Send takeFirstSendOrPeekClosed = takeFirstSendOrPeekClosed();
if (takeFirstSendOrPeekClosed == null) {
return AbstractChannelKt.POLL_FAILED;
}
Symbol tryResumeSend = takeFirstSendOrPeekClosed.tryResumeSend((LockFreeLinkedListNode.PrepareOp) null);
if (tryResumeSend != null) {
if (DebugKt.getASSERTIONS_ENABLED()) {
if (!(tryResumeSend == CancellableContinuationImplKt.RESUME_TOKEN)) {
throw new AssertionError();
}
}
takeFirstSendOrPeekClosed.completeResumeSend();
return takeFirstSendOrPeekClosed.getPollResult();
}
takeFirstSendOrPeekClosed.undeliveredElement();
}
}
/* access modifiers changed from: protected */
public Object pollSelectInternal(SelectInstance<?> selectInstance) {
TryPollDesc describeTryPoll = describeTryPoll();
Object performAtomicTrySelect = selectInstance.performAtomicTrySelect(describeTryPoll);
if (performAtomicTrySelect != null) {
return performAtomicTrySelect;
}
((Send) describeTryPoll.getResult()).completeResumeSend();
return ((Send) describeTryPoll.getResult()).getPollResult();
}
/* access modifiers changed from: protected */
public final boolean getHasReceiveOrClosed() {
return getQueue().getNextNode() instanceof ReceiveOrClosed;
}
public boolean isClosedForReceive() {
return getClosedForReceive() != null && isBufferEmpty();
}
public boolean isEmpty() {
return isEmptyImpl();
}
/* access modifiers changed from: protected */
public final boolean isEmptyImpl() {
return !(getQueue().getNextNode() instanceof Send) && isBufferEmpty();
}
public final Object receive(Continuation<? super E> continuation) {
Object pollInternal = pollInternal();
if (pollInternal == AbstractChannelKt.POLL_FAILED || (pollInternal instanceof Closed)) {
return receiveSuspend(0, continuation);
}
return pollInternal;
}
/* access modifiers changed from: protected */
public boolean enqueueReceiveInternal(Receive<? super E> receive) {
int tryCondAddNext;
LockFreeLinkedListNode prevNode;
if (isBufferAlwaysEmpty()) {
LockFreeLinkedListNode queue = getQueue();
do {
prevNode = queue.getPrevNode();
if (!(!(prevNode instanceof Send))) {
return false;
}
} while (!prevNode.addNext(receive, queue));
} else {
LockFreeLinkedListNode queue2 = getQueue();
LockFreeLinkedListNode lockFreeLinkedListNode = receive;
LockFreeLinkedListNode.CondAddOp abstractChannel$enqueueReceiveInternal$$inlined$addLastIfPrevAndIf$1 = new AbstractChannel$enqueueReceiveInternal$$inlined$addLastIfPrevAndIf$1(lockFreeLinkedListNode, this);
do {
LockFreeLinkedListNode prevNode2 = queue2.getPrevNode();
if (!(!(prevNode2 instanceof Send))) {
return false;
}
tryCondAddNext = prevNode2.tryCondAddNext(lockFreeLinkedListNode, queue2, abstractChannel$enqueueReceiveInternal$$inlined$addLastIfPrevAndIf$1);
if (tryCondAddNext != 1) {
}
} while (tryCondAddNext != 2);
return false;
}
return true;
}
/* access modifiers changed from: private */
public final boolean enqueueReceive(Receive<? super E> receive) {
boolean enqueueReceiveInternal = enqueueReceiveInternal(receive);
if (enqueueReceiveInternal) {
onReceiveEnqueued();
}
return enqueueReceiveInternal;
}
/* JADX WARNING: Removed duplicated region for block: B:12:0x0032 */
/* JADX WARNING: Removed duplicated region for block: B:8:0x0024 */
/* renamed from: receiveCatching-JP2dKIU reason: not valid java name */
/* Code decompiled incorrectly, please refer to instructions dump. */
public final java.lang.Object m1783receiveCatchingJP2dKIU(kotlin.coroutines.Continuation<? super kotlinx.coroutines.channels.ChannelResult<? extends E>> r5) {
/*
r4 = this;
boolean r0 = r5 instanceof kotlinx.coroutines.channels.AbstractChannel$receiveCatching$1
if (r0 == 0) goto L_0x0014
r0 = r5
kotlinx.coroutines.channels.AbstractChannel$receiveCatching$1 r0 = (kotlinx.coroutines.channels.AbstractChannel$receiveCatching$1) r0
int r1 = r0.label
r2 = -2147483648(0xffffffff80000000, float:-0.0)
r1 = r1 & r2
if (r1 == 0) goto L_0x0014
int r5 = r0.label
int r5 = r5 - r2
r0.label = r5
goto L_0x0019
L_0x0014:
kotlinx.coroutines.channels.AbstractChannel$receiveCatching$1 r0 = new kotlinx.coroutines.channels.AbstractChannel$receiveCatching$1
r0.<init>(r4, r5)
L_0x0019:
java.lang.Object r5 = r0.result
java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED()
int r2 = r0.label
r3 = 1
if (r2 == 0) goto L_0x0032
if (r2 != r3) goto L_0x002a
kotlin.ResultKt.throwOnFailure(r5)
goto L_0x005c
L_0x002a:
java.lang.IllegalStateException r5 = new java.lang.IllegalStateException
java.lang.String r0 = "call to 'resume' before 'invoke' with coroutine"
r5.<init>(r0)
throw r5
L_0x0032:
kotlin.ResultKt.throwOnFailure(r5)
java.lang.Object r5 = r4.pollInternal()
kotlinx.coroutines.internal.Symbol r2 = kotlinx.coroutines.channels.AbstractChannelKt.POLL_FAILED
if (r5 == r2) goto L_0x0053
boolean r0 = r5 instanceof kotlinx.coroutines.channels.Closed
if (r0 == 0) goto L_0x004c
kotlinx.coroutines.channels.ChannelResult$Companion r0 = kotlinx.coroutines.channels.ChannelResult.Companion
kotlinx.coroutines.channels.Closed r5 = (kotlinx.coroutines.channels.Closed) r5
java.lang.Throwable r5 = r5.closeCause
java.lang.Object r5 = r0.m1807closedJP2dKIU(r5)
goto L_0x0052
L_0x004c:
kotlinx.coroutines.channels.ChannelResult$Companion r0 = kotlinx.coroutines.channels.ChannelResult.Companion
java.lang.Object r5 = r0.m1809successJP2dKIU(r5)
L_0x0052:
return r5
L_0x0053:
r0.label = r3
java.lang.Object r5 = r4.receiveSuspend(r3, r0)
if (r5 != r1) goto L_0x005c
return r1
L_0x005c:
kotlinx.coroutines.channels.ChannelResult r5 = (kotlinx.coroutines.channels.ChannelResult) r5
java.lang.Object r5 = r5.m1806unboximpl()
return r5
*/
throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.AbstractChannel.m1783receiveCatchingJP2dKIU(kotlin.coroutines.Continuation):java.lang.Object");
}
/* renamed from: tryReceive-PtdJZtk reason: not valid java name */
public final Object m1784tryReceivePtdJZtk() {
Object pollInternal = pollInternal();
if (pollInternal == AbstractChannelKt.POLL_FAILED) {
return ChannelResult.Companion.m1808failurePtdJZtk();
}
if (pollInternal instanceof Closed) {
return ChannelResult.Companion.m1807closedJP2dKIU(((Closed) pollInternal).closeCause);
}
return ChannelResult.Companion.m1809successJP2dKIU(pollInternal);
}
public final void cancel(CancellationException cancellationException) {
if (!isClosedForReceive()) {
if (cancellationException == null) {
cancellationException = new CancellationException(Intrinsics.stringPlus(DebugStringsKt.getClassSimpleName(this), " was cancelled"));
}
cancel(cancellationException);
}
}
/* renamed from: cancelInternal$kotlinx_coroutines_core */
public final boolean cancel(Throwable th) {
boolean close = close(th);
onCancelIdempotent(close);
return close;
}
/* access modifiers changed from: protected */
public void onCancelIdempotent(boolean z) {
Closed<?> closedForSend = getClosedForSend();
if (closedForSend != null) {
Object r0 = InlineList.m1831constructorimpl$default((Object) null, 1, (DefaultConstructorMarker) null);
while (true) {
LockFreeLinkedListNode prevNode = closedForSend.getPrevNode();
if (prevNode instanceof LockFreeLinkedListHead) {
m1782onCancelIdempotentListww6eGU(r0, closedForSend);
return;
} else if (DebugKt.getASSERTIONS_ENABLED() && !(prevNode instanceof Send)) {
throw new AssertionError();
} else if (!prevNode.remove()) {
prevNode.helpRemove();
} else {
r0 = InlineList.m1836plusFjFbRPM(r0, (Send) prevNode);
}
}
} else {
throw new IllegalStateException("Cannot happen".toString());
}
}
public final ChannelIterator<E> iterator() {
return new Itr<>(this);
}
/* access modifiers changed from: protected */
public final TryPollDesc<E> describeTryPoll() {
return new TryPollDesc<>(getQueue());
}
@Metadata(d1 = {"\u0000:\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\b\u0004\u0018\u0000*\u0004\b\u0001\u0010\u00012\u0012\u0012\u0004\u0012\u00020\u00030\u0002j\b\u0012\u0004\u0012\u00020\u0003`\u0004B\r\u0012\u0006\u0010\u0005\u001a\u00020\u0006¢\u0006\u0002\u0010\u0007J\u0012\u0010\b\u001a\u0004\u0018\u00010\t2\u0006\u0010\n\u001a\u00020\u000bH\u0014J\u0016\u0010\f\u001a\u0004\u0018\u00010\t2\n\u0010\r\u001a\u00060\u000ej\u0002`\u000fH\u0016J\u0010\u0010\u0010\u001a\u00020\u00112\u0006\u0010\n\u001a\u00020\u000bH\u0016¨\u0006\u0012"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel$TryPollDesc;", "E", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode$RemoveFirstDesc;", "Lkotlinx/coroutines/channels/Send;", "Lkotlinx/coroutines/internal/RemoveFirstDesc;", "queue", "Lkotlinx/coroutines/internal/LockFreeLinkedListHead;", "(Lkotlinx/coroutines/internal/LockFreeLinkedListHead;)V", "failure", "", "affected", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode;", "onPrepare", "prepareOp", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode$PrepareOp;", "Lkotlinx/coroutines/internal/PrepareOp;", "onRemoved", "", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
protected static final class TryPollDesc<E> extends LockFreeLinkedListNode.RemoveFirstDesc<Send> {
public TryPollDesc(LockFreeLinkedListHead lockFreeLinkedListHead) {
super(lockFreeLinkedListHead);
}
/* access modifiers changed from: protected */
public Object failure(LockFreeLinkedListNode lockFreeLinkedListNode) {
if (lockFreeLinkedListNode instanceof Closed) {
return lockFreeLinkedListNode;
}
if (!(lockFreeLinkedListNode instanceof Send)) {
return AbstractChannelKt.POLL_FAILED;
}
return null;
}
public Object onPrepare(LockFreeLinkedListNode.PrepareOp prepareOp) {
Symbol tryResumeSend = ((Send) prepareOp.affected).tryResumeSend(prepareOp);
if (tryResumeSend == null) {
return LockFreeLinkedList_commonKt.REMOVE_PREPARED;
}
if (tryResumeSend == AtomicKt.RETRY_ATOMIC) {
return AtomicKt.RETRY_ATOMIC;
}
if (!DebugKt.getASSERTIONS_ENABLED()) {
return null;
}
if (tryResumeSend == CancellableContinuationImplKt.RESUME_TOKEN) {
return null;
}
throw new AssertionError();
}
public void onRemoved(LockFreeLinkedListNode lockFreeLinkedListNode) {
((Send) lockFreeLinkedListNode).undeliveredElement();
}
}
public final SelectClause1<E> getOnReceive() {
return new AbstractChannel$onReceive$1(this);
}
public final SelectClause1<ChannelResult<E>> getOnReceiveCatching() {
return new AbstractChannel$onReceiveCatching$1(this);
}
/* access modifiers changed from: private */
public final <R> void registerSelectReceiveMode(SelectInstance<? super R> selectInstance, int i, Function2<Object, ? super Continuation<? super R>, ? extends Object> function2) {
while (!selectInstance.isSelected()) {
if (!isEmptyImpl()) {
Object pollSelectInternal = pollSelectInternal(selectInstance);
if (pollSelectInternal != SelectKt.getALREADY_SELECTED()) {
if (!(pollSelectInternal == AbstractChannelKt.POLL_FAILED || pollSelectInternal == AtomicKt.RETRY_ATOMIC)) {
tryStartBlockUnintercepted(function2, selectInstance, i, pollSelectInternal);
}
} else {
return;
}
} else if (enqueueReceiveSelect(selectInstance, function2, i)) {
return;
}
}
}
private final <R> void tryStartBlockUnintercepted(Function2<Object, ? super Continuation<? super R>, ? extends Object> function2, SelectInstance<? super R> selectInstance, int i, Object obj) {
boolean z = obj instanceof Closed;
if (z) {
if (i == 0) {
throw StackTraceRecoveryKt.recoverStackTrace(((Closed) obj).getReceiveException());
} else if (i == 1 && selectInstance.trySelect()) {
UndispatchedKt.startCoroutineUnintercepted(function2, ChannelResult.m1794boximpl(ChannelResult.Companion.m1807closedJP2dKIU(((Closed) obj).closeCause)), selectInstance.getCompletion());
}
} else if (i == 1) {
ChannelResult.Companion companion = ChannelResult.Companion;
UndispatchedKt.startCoroutineUnintercepted(function2, ChannelResult.m1794boximpl(z ? companion.m1807closedJP2dKIU(((Closed) obj).closeCause) : companion.m1809successJP2dKIU(obj)), selectInstance.getCompletion());
} else {
UndispatchedKt.startCoroutineUnintercepted(function2, obj, selectInstance.getCompletion());
}
}
private final <R> boolean enqueueReceiveSelect(SelectInstance<? super R> selectInstance, Function2<Object, ? super Continuation<? super R>, ? extends Object> function2, int i) {
ReceiveSelect receiveSelect = new ReceiveSelect(this, selectInstance, function2, i);
boolean enqueueReceive = enqueueReceive(receiveSelect);
if (enqueueReceive) {
selectInstance.disposeOnSelect(receiveSelect);
}
return enqueueReceive;
}
/* access modifiers changed from: protected */
public ReceiveOrClosed<E> takeFirstReceiveOrPeekClosed() {
ReceiveOrClosed<E> takeFirstReceiveOrPeekClosed = super.takeFirstReceiveOrPeekClosed();
if (takeFirstReceiveOrPeekClosed != null && !(takeFirstReceiveOrPeekClosed instanceof Closed)) {
onReceiveDequeued();
}
return takeFirstReceiveOrPeekClosed;
}
/* access modifiers changed from: private */
public final void removeReceiveOnCancel(CancellableContinuation<?> cancellableContinuation, Receive<?> receive) {
cancellableContinuation.invokeOnCancellation(new RemoveReceiveOnCancel(receive));
}
@Metadata(d1 = {"\u0000$\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u0003\n\u0000\n\u0002\u0010\u000e\n\u0000\b\u0004\u0018\u00002\u00020\u0001B\u0011\u0012\n\u0010\u0002\u001a\u0006\u0012\u0002\b\u00030\u0003¢\u0006\u0002\u0010\u0004J\u0013\u0010\u0005\u001a\u00020\u00062\b\u0010\u0007\u001a\u0004\u0018\u00010\bH\u0002J\b\u0010\t\u001a\u00020\nH\u0016R\u0012\u0010\u0002\u001a\u0006\u0012\u0002\b\u00030\u0003X\u0004¢\u0006\u0002\n\u0000¨\u0006\u000b"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel$RemoveReceiveOnCancel;", "Lkotlinx/coroutines/BeforeResumeCancelHandler;", "receive", "Lkotlinx/coroutines/channels/Receive;", "(Lkotlinx/coroutines/channels/AbstractChannel;Lkotlinx/coroutines/channels/Receive;)V", "invoke", "", "cause", "", "toString", "", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
private final class RemoveReceiveOnCancel extends BeforeResumeCancelHandler {
private final Receive<?> receive;
public RemoveReceiveOnCancel(Receive<?> receive2) {
this.receive = receive2;
}
public /* bridge */ /* synthetic */ Object invoke(Object obj) {
invoke((Throwable) obj);
return Unit.INSTANCE;
}
public void invoke(Throwable th) {
if (this.receive.remove()) {
AbstractChannel.this.onReceiveDequeued();
}
}
public String toString() {
return "RemoveReceiveOnCancel[" + this.receive + ']';
}
}
@Metadata(d1 = {"\u0000$\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0002\b\u0005\n\u0002\u0010\u000b\n\u0002\b\u0005\b\u0002\u0018\u0000*\u0004\b\u0001\u0010\u00012\b\u0012\u0004\u0012\u0002H\u00010\u0002B\u0013\u0012\f\u0010\u0003\u001a\b\u0012\u0004\u0012\u00028\u00010\u0004¢\u0006\u0002\u0010\u0005J\u0011\u0010\f\u001a\u00020\rHBø\u0001\u0000¢\u0006\u0002\u0010\u000eJ\u0012\u0010\u000f\u001a\u00020\r2\b\u0010\u0006\u001a\u0004\u0018\u00010\u0007H\u0002J\u0011\u0010\u0010\u001a\u00020\rH@ø\u0001\u0000¢\u0006\u0002\u0010\u000eJ\u000e\u0010\u0011\u001a\u00028\u0001H\u0002¢\u0006\u0002\u0010\tR\u0016\u0010\u0003\u001a\b\u0012\u0004\u0012\u00028\u00010\u00048\u0006X\u0004¢\u0006\u0002\n\u0000R\u001c\u0010\u0006\u001a\u0004\u0018\u00010\u0007X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\b\u0010\t\"\u0004\b\n\u0010\u000b\u0002\u0004\n\u0002\b\u0019¨\u0006\u0012"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel$Itr;", "E", "Lkotlinx/coroutines/channels/ChannelIterator;", "channel", "Lkotlinx/coroutines/channels/AbstractChannel;", "(Lkotlinx/coroutines/channels/AbstractChannel;)V", "result", "", "getResult", "()Ljava/lang/Object;", "setResult", "(Ljava/lang/Object;)V", "hasNext", "", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "hasNextResult", "hasNextSuspend", "next", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
private static final class Itr<E> implements ChannelIterator<E> {
public final AbstractChannel<E> channel;
private Object result = AbstractChannelKt.POLL_FAILED;
public Itr(AbstractChannel<E> abstractChannel) {
this.channel = abstractChannel;
}
@Deprecated(level = DeprecationLevel.HIDDEN, message = "Since 1.3.0, binary compatibility with versions <= 1.2.x")
public /* synthetic */ Object next(Continuation continuation) {
return ChannelIterator.DefaultImpls.next(this, continuation);
}
public final Object getResult() {
return this.result;
}
public final void setResult(Object obj) {
this.result = obj;
}
public Object hasNext(Continuation<? super Boolean> continuation) {
if (getResult() != AbstractChannelKt.POLL_FAILED) {
return Boxing.boxBoolean(hasNextResult(getResult()));
}
setResult(this.channel.pollInternal());
if (getResult() != AbstractChannelKt.POLL_FAILED) {
return Boxing.boxBoolean(hasNextResult(getResult()));
}
return hasNextSuspend(continuation);
}
private final boolean hasNextResult(Object obj) {
if (!(obj instanceof Closed)) {
return true;
}
Closed closed = (Closed) obj;
if (closed.closeCause == null) {
return false;
}
throw StackTraceRecoveryKt.recoverStackTrace(closed.getReceiveException());
}
public E next() {
E e = this.result;
if (e instanceof Closed) {
throw StackTraceRecoveryKt.recoverStackTrace(((Closed) e).getReceiveException());
} else if (e != AbstractChannelKt.POLL_FAILED) {
this.result = AbstractChannelKt.POLL_FAILED;
return e;
} else {
throw new IllegalStateException("'hasNext' should be called prior to 'next' invocation");
}
}
/* access modifiers changed from: private */
public final Object hasNextSuspend(Continuation<? super Boolean> continuation) {
CancellableContinuationImpl<? super Boolean> orCreateCancellableContinuation = CancellableContinuationKt.getOrCreateCancellableContinuation(IntrinsicsKt.intercepted(continuation));
CancellableContinuation cancellableContinuation = orCreateCancellableContinuation;
ReceiveHasNext receiveHasNext = new ReceiveHasNext(this, cancellableContinuation);
while (true) {
Receive receive = receiveHasNext;
if (this.channel.enqueueReceive(receive)) {
this.channel.removeReceiveOnCancel(cancellableContinuation, receive);
break;
}
Object pollInternal = this.channel.pollInternal();
setResult(pollInternal);
if (pollInternal instanceof Closed) {
Closed closed = (Closed) pollInternal;
if (closed.closeCause == null) {
Result.Companion companion = Result.Companion;
cancellableContinuation.resumeWith(Result.m352constructorimpl(Boxing.boxBoolean(false)));
} else {
Result.Companion companion2 = Result.Companion;
cancellableContinuation.resumeWith(Result.m352constructorimpl(ResultKt.createFailure(closed.getReceiveException())));
}
} else if (pollInternal != AbstractChannelKt.POLL_FAILED) {
Boolean boxBoolean = Boxing.boxBoolean(true);
Function1 function1 = this.channel.onUndeliveredElement;
cancellableContinuation.resume(boxBoolean, function1 == null ? null : OnUndeliveredElementKt.bindCancellationFun(function1, pollInternal, cancellableContinuation.getContext()));
}
}
Object result2 = orCreateCancellableContinuation.getResult();
if (result2 == IntrinsicsKt.getCOROUTINE_SUSPENDED()) {
DebugProbesKt.probeCoroutineSuspended(continuation);
}
return result2;
}
}
@Metadata(d1 = {"\u0000B\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0012\u0018\u0000*\u0006\b\u0001\u0010\u0001 \u00002\b\u0012\u0004\u0012\u0002H\u00010\u0002B\u001d\u0012\u000e\u0010\u0003\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00050\u0004\u0012\u0006\u0010\u0006\u001a\u00020\u0007¢\u0006\u0002\u0010\bJ\u0015\u0010\t\u001a\u00020\n2\u0006\u0010\u000b\u001a\u00028\u0001H\u0016¢\u0006\u0002\u0010\fJ\u0014\u0010\r\u001a\u00020\n2\n\u0010\u000e\u001a\u0006\u0012\u0002\b\u00030\u000fH\u0016J\u0015\u0010\u0010\u001a\u0004\u0018\u00010\u00052\u0006\u0010\u000b\u001a\u00028\u0001¢\u0006\u0002\u0010\u0011J\b\u0010\u0012\u001a\u00020\u0013H\u0016J!\u0010\u0014\u001a\u0004\u0018\u00010\u00152\u0006\u0010\u000b\u001a\u00028\u00012\b\u0010\u0016\u001a\u0004\u0018\u00010\u0017H\u0016¢\u0006\u0002\u0010\u0018R\u0018\u0010\u0003\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00050\u00048\u0006X\u0004¢\u0006\u0002\n\u0000R\u0010\u0010\u0006\u001a\u00020\u00078\u0006X\u0004¢\u0006\u0002\n\u0000¨\u0006\u0019"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel$ReceiveElement;", "E", "Lkotlinx/coroutines/channels/Receive;", "cont", "Lkotlinx/coroutines/CancellableContinuation;", "", "receiveMode", "", "(Lkotlinx/coroutines/CancellableContinuation;I)V", "completeResumeReceive", "", "value", "(Ljava/lang/Object;)V", "resumeReceiveClosed", "closed", "Lkotlinx/coroutines/channels/Closed;", "resumeValue", "(Ljava/lang/Object;)Ljava/lang/Object;", "toString", "", "tryResumeReceive", "Lkotlinx/coroutines/internal/Symbol;", "otherOp", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode$PrepareOp;", "(Ljava/lang/Object;Lkotlinx/coroutines/internal/LockFreeLinkedListNode$PrepareOp;)Lkotlinx/coroutines/internal/Symbol;", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
private static class ReceiveElement<E> extends Receive<E> {
public final CancellableContinuation<Object> cont;
public final int receiveMode;
public ReceiveElement(CancellableContinuation<Object> cancellableContinuation, int i) {
this.cont = cancellableContinuation;
this.receiveMode = i;
}
public final Object resumeValue(E e) {
return this.receiveMode == 1 ? ChannelResult.m1794boximpl(ChannelResult.Companion.m1809successJP2dKIU(e)) : e;
}
public Symbol tryResumeReceive(E e, LockFreeLinkedListNode.PrepareOp prepareOp) {
Object tryResume = this.cont.tryResume(resumeValue(e), prepareOp == null ? null : prepareOp.desc, resumeOnCancellationFun(e));
if (tryResume == null) {
return null;
}
if (DebugKt.getASSERTIONS_ENABLED()) {
if (!(tryResume == CancellableContinuationImplKt.RESUME_TOKEN)) {
throw new AssertionError();
}
}
if (prepareOp != null) {
prepareOp.finishPrepare();
}
return CancellableContinuationImplKt.RESUME_TOKEN;
}
public void completeResumeReceive(E e) {
this.cont.completeResume(CancellableContinuationImplKt.RESUME_TOKEN);
}
public void resumeReceiveClosed(Closed<?> closed) {
if (this.receiveMode == 1) {
Result.Companion companion = Result.Companion;
this.cont.resumeWith(Result.m352constructorimpl(ChannelResult.m1794boximpl(ChannelResult.Companion.m1807closedJP2dKIU(closed.closeCause))));
return;
}
Result.Companion companion2 = Result.Companion;
this.cont.resumeWith(Result.m352constructorimpl(ResultKt.createFailure(closed.getReceiveException())));
}
public String toString() {
return "ReceiveElement@" + DebugStringsKt.getHexAddress(this) + "[receiveMode=" + this.receiveMode + ']';
}
}
@Metadata(d1 = {"\u00004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0003\n\u0002\b\u0003\b\u0002\u0018\u0000*\u0006\b\u0001\u0010\u0001 \u00002\b\u0012\u0004\u0012\u0002H\u00010\u0002B;\u0012\u000e\u0010\u0003\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00050\u0004\u0012\u0006\u0010\u0006\u001a\u00020\u0007\u0012\u001c\u0010\b\u001a\u0018\u0012\u0004\u0012\u00028\u0001\u0012\u0004\u0012\u00020\n0\tj\b\u0012\u0004\u0012\u00028\u0001`\u000b¢\u0006\u0002\u0010\fJ#\u0010\r\u001a\u0010\u0012\u0004\u0012\u00020\u000e\u0012\u0004\u0012\u00020\n\u0018\u00010\t2\u0006\u0010\u000f\u001a\u00028\u0001H\u0016¢\u0006\u0002\u0010\u0010R&\u0010\b\u001a\u0018\u0012\u0004\u0012\u00028\u0001\u0012\u0004\u0012\u00020\n0\tj\b\u0012\u0004\u0012\u00028\u0001`\u000b8\u0006X\u0004¢\u0006\u0002\n\u0000¨\u0006\u0011"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel$ReceiveElementWithUndeliveredHandler;", "E", "Lkotlinx/coroutines/channels/AbstractChannel$ReceiveElement;", "cont", "Lkotlinx/coroutines/CancellableContinuation;", "", "receiveMode", "", "onUndeliveredElement", "Lkotlin/Function1;", "", "Lkotlinx/coroutines/internal/OnUndeliveredElement;", "(Lkotlinx/coroutines/CancellableContinuation;ILkotlin/jvm/functions/Function1;)V", "resumeOnCancellationFun", "", "value", "(Ljava/lang/Object;)Lkotlin/jvm/functions/Function1;", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
private static final class ReceiveElementWithUndeliveredHandler<E> extends ReceiveElement<E> {
public final Function1<E, Unit> onUndeliveredElement;
public ReceiveElementWithUndeliveredHandler(CancellableContinuation<Object> cancellableContinuation, int i, Function1<? super E, Unit> function1) {
super(cancellableContinuation, i);
this.onUndeliveredElement = function1;
}
public Function1<Throwable, Unit> resumeOnCancellationFun(E e) {
return OnUndeliveredElementKt.bindCancellationFun(this.onUndeliveredElement, e, this.cont.getContext());
}
}
@Metadata(d1 = {"\u0000L\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0012\u0018\u0000*\u0004\b\u0001\u0010\u00012\b\u0012\u0004\u0012\u0002H\u00010\u0002B!\u0012\f\u0010\u0003\u001a\b\u0012\u0004\u0012\u00028\u00010\u0004\u0012\f\u0010\u0005\u001a\b\u0012\u0004\u0012\u00020\u00070\u0006¢\u0006\u0002\u0010\bJ\u0015\u0010\t\u001a\u00020\n2\u0006\u0010\u000b\u001a\u00028\u0001H\u0016¢\u0006\u0002\u0010\fJ#\u0010\r\u001a\u0010\u0012\u0004\u0012\u00020\u000f\u0012\u0004\u0012\u00020\n\u0018\u00010\u000e2\u0006\u0010\u000b\u001a\u00028\u0001H\u0016¢\u0006\u0002\u0010\u0010J\u0014\u0010\u0011\u001a\u00020\n2\n\u0010\u0012\u001a\u0006\u0012\u0002\b\u00030\u0013H\u0016J\b\u0010\u0014\u001a\u00020\u0015H\u0016J!\u0010\u0016\u001a\u0004\u0018\u00010\u00172\u0006\u0010\u000b\u001a\u00028\u00012\b\u0010\u0018\u001a\u0004\u0018\u00010\u0019H\u0016¢\u0006\u0002\u0010\u001aR\u0016\u0010\u0005\u001a\b\u0012\u0004\u0012\u00020\u00070\u00068\u0006X\u0004¢\u0006\u0002\n\u0000R\u0016\u0010\u0003\u001a\b\u0012\u0004\u0012\u00028\u00010\u00048\u0006X\u0004¢\u0006\u0002\n\u0000¨\u0006\u001b"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel$ReceiveHasNext;", "E", "Lkotlinx/coroutines/channels/Receive;", "iterator", "Lkotlinx/coroutines/channels/AbstractChannel$Itr;", "cont", "Lkotlinx/coroutines/CancellableContinuation;", "", "(Lkotlinx/coroutines/channels/AbstractChannel$Itr;Lkotlinx/coroutines/CancellableContinuation;)V", "completeResumeReceive", "", "value", "(Ljava/lang/Object;)V", "resumeOnCancellationFun", "Lkotlin/Function1;", "", "(Ljava/lang/Object;)Lkotlin/jvm/functions/Function1;", "resumeReceiveClosed", "closed", "Lkotlinx/coroutines/channels/Closed;", "toString", "", "tryResumeReceive", "Lkotlinx/coroutines/internal/Symbol;", "otherOp", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode$PrepareOp;", "(Ljava/lang/Object;Lkotlinx/coroutines/internal/LockFreeLinkedListNode$PrepareOp;)Lkotlinx/coroutines/internal/Symbol;", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
private static class ReceiveHasNext<E> extends Receive<E> {
public final CancellableContinuation<Boolean> cont;
public final Itr<E> iterator;
public ReceiveHasNext(Itr<E> itr, CancellableContinuation<? super Boolean> cancellableContinuation) {
this.iterator = itr;
this.cont = cancellableContinuation;
}
public Symbol tryResumeReceive(E e, LockFreeLinkedListNode.PrepareOp prepareOp) {
boolean z = true;
Object tryResume = this.cont.tryResume(true, prepareOp == null ? null : prepareOp.desc, resumeOnCancellationFun(e));
if (tryResume == null) {
return null;
}
if (DebugKt.getASSERTIONS_ENABLED()) {
if (tryResume != CancellableContinuationImplKt.RESUME_TOKEN) {
z = false;
}
if (!z) {
throw new AssertionError();
}
}
if (prepareOp != null) {
prepareOp.finishPrepare();
}
return CancellableContinuationImplKt.RESUME_TOKEN;
}
public void completeResumeReceive(E e) {
this.iterator.setResult(e);
this.cont.completeResume(CancellableContinuationImplKt.RESUME_TOKEN);
}
public void resumeReceiveClosed(Closed<?> closed) {
Object obj;
if (closed.closeCause == null) {
obj = CancellableContinuation.DefaultImpls.tryResume$default(this.cont, false, (Object) null, 2, (Object) null);
} else {
obj = this.cont.tryResumeWithException(closed.getReceiveException());
}
if (obj != null) {
this.iterator.setResult(closed);
this.cont.completeResume(obj);
}
}
public Function1<Throwable, Unit> resumeOnCancellationFun(E e) {
Function1 function1 = this.iterator.channel.onUndeliveredElement;
if (function1 == null) {
return null;
}
return OnUndeliveredElementKt.bindCancellationFun(function1, e, this.cont.getContext());
}
public String toString() {
return Intrinsics.stringPlus("ReceiveHasNext@", DebugStringsKt.getHexAddress(this));
}
}
@Metadata(d1 = {"\u0000b\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0002\u0018\u0000*\u0004\b\u0001\u0010\u0001*\u0004\b\u0002\u0010\u00022\b\u0012\u0004\u0012\u0002H\u00020\u00032\u00020\u0004BR\u0012\f\u0010\u0005\u001a\b\u0012\u0004\u0012\u00028\u00020\u0006\u0012\f\u0010\u0007\u001a\b\u0012\u0004\u0012\u00028\u00010\b\u0012$\u0010\t\u001a \b\u0001\u0012\u0006\u0012\u0004\u0018\u00010\u000b\u0012\n\u0012\b\u0012\u0004\u0012\u00028\u00010\f\u0012\u0006\u0012\u0004\u0018\u00010\u000b0\n\u0012\u0006\u0010\r\u001a\u00020\u000eø\u0001\u0000¢\u0006\u0002\u0010\u000fJ\u0015\u0010\u0011\u001a\u00020\u00122\u0006\u0010\u0013\u001a\u00028\u0002H\u0016¢\u0006\u0002\u0010\u0014J\b\u0010\u0015\u001a\u00020\u0012H\u0016J#\u0010\u0016\u001a\u0010\u0012\u0004\u0012\u00020\u0018\u0012\u0004\u0012\u00020\u0012\u0018\u00010\u00172\u0006\u0010\u0013\u001a\u00028\u0002H\u0016¢\u0006\u0002\u0010\u0019J\u0014\u0010\u001a\u001a\u00020\u00122\n\u0010\u001b\u001a\u0006\u0012\u0002\b\u00030\u001cH\u0016J\b\u0010\u001d\u001a\u00020\u001eH\u0016J!\u0010\u001f\u001a\u0004\u0018\u00010 2\u0006\u0010\u0013\u001a\u00028\u00022\b\u0010!\u001a\u0004\u0018\u00010\"H\u0016¢\u0006\u0002\u0010#R3\u0010\t\u001a \b\u0001\u0012\u0006\u0012\u0004\u0018\u00010\u000b\u0012\n\u0012\b\u0012\u0004\u0012\u00028\u00010\f\u0012\u0006\u0012\u0004\u0018\u00010\u000b0\n8\u0006X\u0004ø\u0001\u0000¢\u0006\u0004\n\u0002\u0010\u0010R\u0016\u0010\u0005\u001a\b\u0012\u0004\u0012\u00028\u00020\u00068\u0006X\u0004¢\u0006\u0002\n\u0000R\u0010\u0010\r\u001a\u00020\u000e8\u0006X\u0004¢\u0006\u0002\n\u0000R\u0016\u0010\u0007\u001a\b\u0012\u0004\u0012\u00028\u00010\b8\u0006X\u0004¢\u0006\u0002\n\u0000\u0002\u0004\n\u0002\b\u0019¨\u0006$"}, d2 = {"Lkotlinx/coroutines/channels/AbstractChannel$ReceiveSelect;", "R", "E", "Lkotlinx/coroutines/channels/Receive;", "Lkotlinx/coroutines/DisposableHandle;", "channel", "Lkotlinx/coroutines/channels/AbstractChannel;", "select", "Lkotlinx/coroutines/selects/SelectInstance;", "block", "Lkotlin/Function2;", "", "Lkotlin/coroutines/Continuation;", "receiveMode", "", "(Lkotlinx/coroutines/channels/AbstractChannel;Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/functions/Function2;I)V", "Lkotlin/jvm/functions/Function2;", "completeResumeReceive", "", "value", "(Ljava/lang/Object;)V", "dispose", "resumeOnCancellationFun", "Lkotlin/Function1;", "", "(Ljava/lang/Object;)Lkotlin/jvm/functions/Function1;", "resumeReceiveClosed", "closed", "Lkotlinx/coroutines/channels/Closed;", "toString", "", "tryResumeReceive", "Lkotlinx/coroutines/internal/Symbol;", "otherOp", "Lkotlinx/coroutines/internal/LockFreeLinkedListNode$PrepareOp;", "(Ljava/lang/Object;Lkotlinx/coroutines/internal/LockFreeLinkedListNode$PrepareOp;)Lkotlinx/coroutines/internal/Symbol;", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
/* compiled from: AbstractChannel.kt */
private static final class ReceiveSelect<R, E> extends Receive<E> implements DisposableHandle {
public final Function2<Object, Continuation<? super R>, Object> block;
public final AbstractChannel<E> channel;
public final int receiveMode;
public final SelectInstance<R> select;
public ReceiveSelect(AbstractChannel<E> abstractChannel, SelectInstance<? super R> selectInstance, Function2<Object, ? super Continuation<? super R>, ? extends Object> function2, int i) {
this.channel = abstractChannel;
this.select = selectInstance;
this.block = function2;
this.receiveMode = i;
}
public Symbol tryResumeReceive(E e, LockFreeLinkedListNode.PrepareOp prepareOp) {
return (Symbol) this.select.trySelectOther(prepareOp);
}
public void completeResumeReceive(E e) {
CancellableKt.startCoroutineCancellable(this.block, this.receiveMode == 1 ? ChannelResult.m1794boximpl(ChannelResult.Companion.m1809successJP2dKIU(e)) : e, this.select.getCompletion(), resumeOnCancellationFun(e));
}
public void resumeReceiveClosed(Closed<?> closed) {
if (this.select.trySelect()) {
int i = this.receiveMode;
if (i == 0) {
this.select.resumeSelectWithException(closed.getReceiveException());
} else if (i == 1) {
CancellableKt.startCoroutineCancellable$default(this.block, ChannelResult.m1794boximpl(ChannelResult.Companion.m1807closedJP2dKIU(closed.closeCause)), this.select.getCompletion(), (Function1) null, 4, (Object) null);
}
}
}
public void dispose() {
if (remove()) {
this.channel.onReceiveDequeued();
}
}
public Function1<Throwable, Unit> resumeOnCancellationFun(E e) {
Function1 function1 = this.channel.onUndeliveredElement;
if (function1 == null) {
return null;
}
return OnUndeliveredElementKt.bindCancellationFun(function1, e, this.select.getCompletion().getContext());
}
public String toString() {
return "ReceiveSelect@" + DebugStringsKt.getHexAddress(this) + '[' + this.select + ",receiveMode=" + this.receiveMode + ']';
}
}
/* access modifiers changed from: private */
public final <R> Object receiveSuspend(int i, Continuation<? super R> continuation) {
ReceiveElement receiveElement;
CancellableContinuationImpl<? super R> orCreateCancellableContinuation = CancellableContinuationKt.getOrCreateCancellableContinuation(IntrinsicsKt.intercepted(continuation));
CancellableContinuation cancellableContinuation = orCreateCancellableContinuation;
if (this.onUndeliveredElement == null) {
receiveElement = new ReceiveElement(cancellableContinuation, i);
} else {
receiveElement = new ReceiveElementWithUndeliveredHandler(cancellableContinuation, i, this.onUndeliveredElement);
}
while (true) {
Receive receive = receiveElement;
if (!enqueueReceive(receive)) {
Object pollInternal = pollInternal();
if (!(pollInternal instanceof Closed)) {
if (pollInternal != AbstractChannelKt.POLL_FAILED) {
cancellableContinuation.resume(receiveElement.resumeValue(pollInternal), receiveElement.resumeOnCancellationFun(pollInternal));
break;
}
} else {
receiveElement.resumeReceiveClosed((Closed) pollInternal);
break;
}
} else {
removeReceiveOnCancel(cancellableContinuation, receive);
break;
}
}
Object result = orCreateCancellableContinuation.getResult();
if (result == IntrinsicsKt.getCOROUTINE_SUSPENDED()) {
DebugProbesKt.probeCoroutineSuspended(continuation);
}
return result;
}
/* access modifiers changed from: protected */
/* renamed from: onCancelIdempotentList-w-w6eGU reason: not valid java name */
public void m1782onCancelIdempotentListww6eGU(Object obj, Closed<?> closed) {
if (obj != null) {
if (!(obj instanceof ArrayList)) {
((Send) obj).resumeSendClosed(closed);
return;
}
Objects.requireNonNull(obj, "null cannot be cast to non-null type java.util.ArrayList<E of kotlinx.coroutines.internal.InlineList>{ kotlin.collections.TypeAliasesKt.ArrayList<E of kotlinx.coroutines.internal.InlineList> }");
ArrayList arrayList = (ArrayList) obj;
int size = arrayList.size() - 1;
if (size >= 0) {
while (true) {
int i = size - 1;
((Send) arrayList.get(size)).resumeSendClosed(closed);
if (i >= 0) {
size = i;
} else {
return;
}
}
}
}
}
}
Download file