package kotlinx.coroutines.channels; import com.google.android.gms.ads.RequestConfiguration; import kotlin.Metadata; import kotlin.Unit; import kotlin.jvm.functions.Function1; import kotlin.reflect.KFunction; import kotlinx.coroutines.CancellableContinuation; import kotlinx.coroutines.internal.Symbol; import kotlinx.coroutines.internal.SystemPropsKt__SystemProps_commonKt; /* compiled from: BufferedChannel.kt */ @Metadata(d1 = {"\u0000T\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\b\u0007\n\u0002\u0010\b\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0012\n\u0002\u0010\u000b\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\u001a\u0018\u00106\u001a\u00020\u00032\u0006\u00107\u001a\u00020\u00032\u0006\u00108\u001a\u00020.H\u0002\u001a\u0018\u00109\u001a\u00020\u00032\u0006\u00107\u001a\u00020\u00032\u0006\u0010:\u001a\u00020\u000bH\u0002\u001a*\u0010;\u001a\b\u0012\u0004\u0012\u0002H<0\u001a\"\u0004\b\u0000\u0010<2\u0006\u0010=\u001a\u00020\u00032\f\u0010>\u001a\b\u0012\u0004\u0012\u0002H<0\u001aH\u0002\u001a,\u0010?\u001a \u0012\u0004\u0012\u00020\u0003\u0012\n\u0012\b\u0012\u0004\u0012\u0002H<0\u001a\u0012\n\u0012\b\u0012\u0004\u0012\u0002H<0\u001a0@\"\u0004\b\u0000\u0010 NULL_SEGMENT = new ChannelSegment<>(-1, null, null, 0); private static final Symbol POISONED; private static final int RESULT_BUFFERED = 1; private static final int RESULT_CLOSED = 4; private static final int RESULT_FAILED = 5; private static final int RESULT_RENDEZVOUS = 0; private static final int RESULT_SUSPEND = 2; private static final int RESULT_SUSPEND_NO_WAITER = 3; private static final Symbol RESUMING_BY_EB; private static final Symbol RESUMING_BY_RCV; public static final int SEGMENT_SIZE; private static final int SENDERS_CLOSE_STATUS_SHIFT = 60; private static final long SENDERS_COUNTER_MASK = 1152921504606846975L; private static final Symbol SUSPEND; private static final Symbol SUSPEND_NO_WAITER; /* JADX INFO: Access modifiers changed from: private */ public static final long constructEBCompletedAndPauseFlag(long j, boolean z) { return (z ? 4611686018427387904L : 0L) + j; } /* JADX INFO: Access modifiers changed from: private */ public static final long constructSendersAndCloseStatus(long j, int i) { return (i << 60) + j; } public static final Symbol getCHANNEL_CLOSED() { return CHANNEL_CLOSED; } private static final long getEbCompletedCounter(long j) { return j & 4611686018427387903L; } private static final boolean getEbPauseExpandBuffers(long j) { return (j & 4611686018427387904L) != 0; } private static final int getSendersCloseStatus(long j) { return (int) (j >> 60); } private static final long getSendersCounter(long j) { return j & SENDERS_COUNTER_MASK; } /* JADX INFO: Access modifiers changed from: private */ public static final long initialBufferEnd(int i) { if (i != 0) { if (i != Integer.MAX_VALUE) { return i; } return Long.MAX_VALUE; } return 0L; } public static final KFunction> createSegmentFunction() { return BufferedChannelKt$createSegmentFunction$1.INSTANCE; } /* JADX INFO: Access modifiers changed from: private */ public static final ChannelSegment createSegment(long j, ChannelSegment channelSegment) { return new ChannelSegment<>(j, channelSegment, channelSegment.getChannel(), 0); } static { int systemProp$default; int systemProp$default2; systemProp$default = SystemPropsKt__SystemProps_commonKt.systemProp$default("kotlinx.coroutines.bufferedChannel.segmentSize", 32, 0, 0, 12, (Object) null); SEGMENT_SIZE = systemProp$default; systemProp$default2 = SystemPropsKt__SystemProps_commonKt.systemProp$default("kotlinx.coroutines.bufferedChannel.expandBufferCompletionWaitIterations", 10000, 0, 0, 12, (Object) null); EXPAND_BUFFER_COMPLETION_WAIT_ITERATIONS = systemProp$default2; BUFFERED = new Symbol("BUFFERED"); IN_BUFFER = new Symbol("SHOULD_BUFFER"); RESUMING_BY_RCV = new Symbol("S_RESUMING_BY_RCV"); RESUMING_BY_EB = new Symbol("RESUMING_BY_EB"); POISONED = new Symbol("POISONED"); DONE_RCV = new Symbol("DONE_RCV"); INTERRUPTED_SEND = new Symbol("INTERRUPTED_SEND"); INTERRUPTED_RCV = new Symbol("INTERRUPTED_RCV"); CHANNEL_CLOSED = new Symbol("CHANNEL_CLOSED"); SUSPEND = new Symbol("SUSPEND"); SUSPEND_NO_WAITER = new Symbol("SUSPEND_NO_WAITER"); FAILED = new Symbol("FAILED"); NO_RECEIVE_RESULT = new Symbol("NO_RECEIVE_RESULT"); CLOSE_HANDLER_CLOSED = new Symbol("CLOSE_HANDLER_CLOSED"); CLOSE_HANDLER_INVOKED = new Symbol("CLOSE_HANDLER_INVOKED"); NO_CLOSE_CAUSE = new Symbol("NO_CLOSE_CAUSE"); } /* JADX INFO: Access modifiers changed from: package-private */ public static /* synthetic */ boolean tryResume0$default(CancellableContinuation cancellableContinuation, Object obj, Function1 function1, int i, Object obj2) { if ((i & 2) != 0) { function1 = null; } return tryResume0(cancellableContinuation, obj, function1); } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Multi-variable type inference failed */ public static final boolean tryResume0(CancellableContinuation cancellableContinuation, T t, Function1 function1) { Object tryResume = cancellableContinuation.tryResume(t, null, function1); if (tryResume != null) { cancellableContinuation.completeResume(tryResume); return true; } return false; } }