Searched refs:deqIdx (Results 1 – 3 of 3) sorted by relevance
20 private val deqIdx = atomic(0L) in newSegment() constant in kotlinx.coroutines.internal.SegmentBasedQueue35 if (this.deqIdx.value >= this.enqIdx.value) return null in dequeue()37 val deqIdx = this.deqIdx.getAndIncrement() in dequeue() constant38 firstSegment = getSegmentAndMoveHead(firstSegment, deqIdx) ?: continue in dequeue()
108 private val deqIdx = atomic(0L) in newSegment() constant151 val deqIdx = deqIdx.getAndIncrement() in resumeNextFromQueue() constant152 val segment = getSegmentAndMoveHead(first, deqIdx / SEGMENT_SIZE) ?: continue@try_again in resumeNextFromQueue()153 val i = (deqIdx % SEGMENT_SIZE).toInt() in resumeNextFromQueue()
1311 static int deqIdx(int value, int paramType) { in deqIdx() function1605 deqIdx(outputIdxData[xttIdx][ps][band], paramType); in mapIndexData()