Searched refs:deqIdx (Results 1 – 4 of 4) sorted by relevance
25 private val deqIdx = atomic(0L) constant in kotlinx.coroutines.internal.SegmentBasedQueue48 if (this.deqIdx.value >= this.enqIdx.value) return null in dequeue()50 val deqIdx = this.deqIdx.getAndIncrement() in dequeue() constant51 …val segmentOrClosed = this.head.findSegmentAndMoveForward(id = deqIdx, startFrom = curHead, create… in dequeue()54 if (s.id > deqIdx) continue in dequeue()
130 private val deqIdx = atomic(0L) constant221 val deqIdx = deqIdx.getAndIncrement() in tryResumeNextFromQueue() constant222 val id = deqIdx / SEGMENT_SIZE in tryResumeNextFromQueue()227 val i = (deqIdx % SEGMENT_SIZE).toInt() in tryResumeNextFromQueue()
1316 static int deqIdx(int value, int paramType) { in deqIdx() function1610 deqIdx(outputIdxData[xttIdx][ps][band], paramType); in mapIndexData()
META-INF/ META-INF/MANIFEST.MF kotlinx/ kotlinx/coroutines/ kotlinx/ ...