Searched refs:POLL_FAILED (Results 1 – 4 of 4) sorted by relevance
184 … if (size == 0) return closedForSend ?: POLL_FAILED // when nothing can be read from buffer in pollInternal()190 var replacement: Any? = POLL_FAILED in pollInternal()205 if (replacement !== POLL_FAILED && replacement !is Closed<*>) { in pollInternal()224 if (size == 0) return closedForSend ?: POLL_FAILED in pollSelectInternal()230 var replacement: Any? = POLL_FAILED in pollSelectInternal()242 … failure === POLL_FAILED -> break@loop // cannot poll -> Ok to take from buffer in pollSelectInternal()259 if (replacement !== POLL_FAILED && replacement !is Closed<*>) { in pollSelectInternal()
515 val send = takeFirstSendOrPeekClosed() ?: return POLL_FAILED in pollInternal()564 if (result !== POLL_FAILED && result !is Closed<*>) return result as E in receive()585 if (result !== POLL_FAILED) { in receiveSuspend()604 if (result !== POLL_FAILED && result !is Closed<*>) return result as E in receiveOrNull()622 if (result !== POLL_FAILED) return result.toResult() in receiveOrClosed()630 return if (result === POLL_FAILED) null else receiveOrNullResult(result) in poll()689 !is Send -> POLL_FAILED in iterator()741 pollResult === POLL_FAILED -> {} // retry in registerSelectReceiveMode()824 var result: Any? = POLL_FAILED // E | POLL_FAILED | Closed828 if (result !== POLL_FAILED) return hasNextResult(result) in hasNext()[all …]
250 …result === POLL_FAILED -> continue@loop // must retest `needsToCheckOfferWithoutLock` outside of t… in elementAt()281 result === POLL_FAILED -> { /* just bail out of lock */ } in elementAt()310 result === POLL_FAILED -> { /* just bail out of lock */ } in elementAt()361 return closedBroadcast ?: this.closedForReceive ?: POLL_FAILED in elementAt()
97 if (value === EMPTY) return closedForSend ?: POLL_FAILED in pollInternal()108 if (value === EMPTY) return closedForSend ?: POLL_FAILED in pollSelectInternal()