| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | SharedFlow.kt | 446 val newHead = head + 1 in dropOldestLocked() constant
447 if (replayIndex < newHead) replayIndex = newHead in dropOldestLocked()
448 if (minCollectorIndex < newHead) correctCollectorIndexesOnDropOldest(newHead) in dropOldestLocked()
449 …assert { head == newHead } // since head = minOf(minCollectorIndex, replayIndex) it should have up… in dropOldestLocked()
452 private fun correctCollectorIndexesOnDropOldest(newHead: Long) { in correctCollectorIndexesOnDropOldest()
455 if (slot.index >= 0 && slot.index < newHead) { in correctCollectorIndexesOnDropOldest()
456 …slot.index = newHead // force move it up (this collector was too slow and missed the value at its … in correctCollectorIndexesOnDropOldest()
459 minCollectorIndex = newHead in correctCollectorIndexesOnDropOldest()
597 val newHead = minOf(newMinCollectorIndex, newReplayIndex) in updateBufferLocked() constant
598 assert { newHead >= head } in updateBufferLocked()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | LockFreeTaskQueue.kt | 179 val newHead = (head + 1) and MAX_CAPACITY_MASK in removeFirstOrNull() constant
180 if (_state.compareAndSet(state, state.updateHead(newHead))) { in removeFirstOrNull()
192 cur = cur.removeSlowPath(head, newHead) ?: return element in removeFirstOrNull()
198 private fun removeSlowPath(oldHead: Int, newHead: Int): Core<E>? { in removeSlowPath()
206 if (_state.compareAndSet(state, state.updateHead(newHead))) { in removeSlowPath()
295 fun Long.updateHead(newHead: Int) = (this wo HEAD_MASK) or (newHead.toLong() shl HEAD_SHIFT) in isClosed()
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 628 RunnableExecutorPair newHead = new RunnableExecutorPair(runnable, executor);
635 newHead.execute();
639 newHead.next = oldHead;
640 } while (!UNSAFE.compareAndSwapObject(this, HEAD_OFFSET, oldHead, newHead));
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 628 RunnableExecutorPair newHead = new RunnableExecutorPair(runnable, executor);
635 newHead.execute();
639 newHead.next = oldHead;
640 } while (!UNSAFE.compareAndSwapObject(this, HEAD_OFFSET, oldHead, newHead));
|
| /external/kotlinx.atomicfu/atomicfu/src/nativeMain/kotlin/kotlinx/atomicfu/locks/ |
| D | Synchronized.kt | 215 val newHead = oldTop!!.pointed.next in pop() constant
216 if (top.compareAndSet(oldTop.rawValue, newHead.rawValue)) in pop()
|
| /external/pdfium/third_party/lcms/src/ |
| D | cmscnvrt.c | 105 _cmsIntentsPluginChunkType newHead = { NULL }; in DupPluginIntentsList() local
127 if (newHead.Intents == NULL) in DupPluginIntentsList()
128 newHead.Intents = newEntry; in DupPluginIntentsList()
131 …ctx ->chunks[IntentPlugin] = _cmsSubAllocDup(ctx->MemPool, &newHead, sizeof(_cmsIntentsPluginChunk… in DupPluginIntentsList()
|
| D | cmsgamma.c | 74 _cmsCurvesPluginChunkType newHead = { NULL }; in DupPluginCurvesList() local
98 if (newHead.ParametricCurves == NULL) in DupPluginCurvesList()
99 newHead.ParametricCurves = newEntry; in DupPluginCurvesList()
102 …ctx ->chunks[CurvesPlugin] = _cmsSubAllocDup(ctx->MemPool, &newHead, sizeof(_cmsCurvesPluginChunkT… in DupPluginCurvesList()
|
| D | cmsxform.c | 632 _cmsTransformPluginChunkType newHead = { NULL }; in DupPluginTransformList() local
654 if (newHead.TransformCollection == NULL) in DupPluginTransformList()
655 newHead.TransformCollection = newEntry; in DupPluginTransformList()
658 …ctx ->chunks[TransformPlugin] = _cmsSubAllocDup(ctx->MemPool, &newHead, sizeof(_cmsTransformPlugin… in DupPluginTransformList()
|
| D | cmsopt.c | 1853 _cmsOptimizationPluginChunkType newHead = { NULL }; in DupPluginOptimizationList() local
1878 if (newHead.OptimizationCollection == NULL) in DupPluginOptimizationList()
1879 newHead.OptimizationCollection = newEntry; in DupPluginOptimizationList()
1882 …ctx ->chunks[OptimizationPlugin] = _cmsSubAllocDup(ctx->MemPool, &newHead, sizeof(_cmsOptimization… in DupPluginOptimizationList()
|
| D | cmstypes.c | 5526 _cmsTagTypePluginChunkType newHead = { NULL }; in DupTagTypeList() local
5548 if (newHead.TagTypes == NULL) in DupTagTypeList()
5549 newHead.TagTypes = newEntry; in DupTagTypeList()
5552 ctx ->chunks[loc] = _cmsSubAllocDup(ctx->MemPool, &newHead, sizeof(_cmsTagTypePluginChunkType)); in DupTagTypeList()
5730 _cmsTagPluginChunkType newHead = { NULL }; in DupTagList() local
5752 if (newHead.Tag == NULL) in DupTagList()
5753 newHead.Tag = newEntry; in DupTagList()
5756 … ctx ->chunks[TagPlugin] = _cmsSubAllocDup(ctx->MemPool, &newHead, sizeof(_cmsTagPluginChunkType)); in DupTagList()
|
| D | cmspack.c | 3725 _cmsFormattersPluginChunkType newHead = { NULL }; in DupFormatterFactoryList() local
3749 if (newHead.FactoryList == NULL) in DupFormatterFactoryList()
3750 newHead.FactoryList = newEntry; in DupFormatterFactoryList()
3753 …ctx ->chunks[FormattersPlugin] = _cmsSubAllocDup(ctx->MemPool, &newHead, sizeof(_cmsFormattersPlug… in DupFormatterFactoryList()
|