| /external/zstd/lib/common/ |
| D | pool.c | 45 size_t queueSize; member
87 ctx->queueHead = (ctx->queueHead + 1) % ctx->queueSize; in POOL_thread()
99 if (ctx->queueSize == 1) { in POOL_thread()
112 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create() argument
113 return POOL_create_advanced(numThreads, queueSize, ZSTD_defaultCMem); in POOL_create()
116 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, in POOL_create_advanced() argument
128 ctx->queueSize = queueSize + 1; in POOL_create_advanced()
129 ctx->queue = (POOL_job*)ZSTD_customMalloc(ctx->queueSize * sizeof(POOL_job), customMem); in POOL_create_advanced()
198 + ctx->queueSize * sizeof(POOL_job) in POOL_sizeof()
251 if (ctx->queueSize > 1) { in isQueueFull()
[all …]
|
| D | pool.h | 31 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize);
33 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize,
|
| /external/zstd/tests/ |
| D | poolTests.c | 43 static int testOrder(size_t numThreads, size_t queueSize) in testOrder() argument
46 POOL_ctx* const ctx = POOL_create(numThreads, queueSize); in testOrder()
75 static int testWait(size_t numThreads, size_t queueSize) { in testWait() argument
77 POOL_ctx* const ctx = POOL_create(numThreads, queueSize); in testWait()
237 size_t queueSize; in main() local
238 for (queueSize = 0; queueSize <= 2; ++queueSize) { in main()
240 (unsigned)queueSize, (unsigned)numThreads); in main()
241 if (testOrder(numThreads, queueSize)) { in main()
246 if (testWait(numThreads, queueSize)) { in main()
|
| /external/exoplayer/tree/playbacktests/src/androidTest/java/com/google/android/exoplayer2/playbacktests/gts/ |
| D | DebugRenderersFactory.java | 81 private int queueSize; field in DebugRenderersFactory.DebugMediaCodecVideoRenderer
140 minimumInsertIndex = startIndex + queueSize; in onInputFormatChanged()
212 queueSize = 0; in clearTimestamps()
218 for (int i = startIndex + queueSize - 1; i >= minimumInsertIndex; i--) { in insertTimestamp()
221 queueSize++; in insertTimestamp()
227 queueSize++; in insertTimestamp()
231 if (startIndex + queueSize == ARRAY_SIZE) { in maybeShiftTimestampsList()
232 System.arraycopy(timestampsList, startIndex, timestampsList, 0, queueSize); in maybeShiftTimestampsList()
239 queueSize--; in dequeueTimestamp()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | SharedFlow.kt | 281 private var queueSize = 0 // number of queued emitters variable
286 private val totalSize: Int get() = bufferSize + queueSize
288 private val queueEndIndex: Long get() = head + bufferSize + queueSize
428 queueSize++ // added to queue of waiting emitters in emitSuspend()
461 if (bufferCapacity == 0 && queueSize > 0) newMinCollectorIndex++ in updateCollectorIndexLocked()
476 minOf(queueSize, bufferCapacity - newBufferSize0) in updateCollectorIndexLocked()
479 queueSize // that's how many waiting emitters we have (at most) in updateCollectorIndexLocked()
482 val newQueueEndIndex = newBufferEndIndex + queueSize in updateCollectorIndexLocked()
538 queueSize = (newQueueEndIndex - newBufferEndIndex).toInt() in updateBufferLocked()
541 assert { queueSize >= 0 } in updateBufferLocked()
[all …]
|
| /external/exoplayer/tree/extensions/mediasession/src/main/java/com/google/android/exoplayer2/ext/mediasession/ |
| D | TimelineQueueNavigator.java | 180 int queueSize = Math.min(maxQueueSize, timeline.getWindowCount()); in publishFloatingQueueWindow() local
193 && queue.size() < queueSize) { in publishFloatingQueueWindow()
205 if (firstWindowIndex != C.INDEX_UNSET && queue.size() < queueSize) { in publishFloatingQueueWindow()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/trackselection/ |
| D | AdaptiveTrackSelection.java | 499 int queueSize = queue.size(); in evaluateQueueSize() local
500 MediaChunk lastChunk = queue.get(queueSize - 1); in evaluateQueueSize()
506 return queueSize; in evaluateQueueSize()
513 for (int i = 0; i < queueSize; i++) { in evaluateQueueSize()
527 return queueSize; in evaluateQueueSize()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | CoroutineScheduler.kt | 530 val queueSize = worker.localQueue.size in <lambda>() constant
535 queueSizes += queueSize.toString() + "b" // Blocking in <lambda>()
539 queueSizes += queueSize.toString() + "c" // CPU in <lambda>()
543 if (queueSize > 0) queueSizes += queueSize.toString() + "d" // Retiring in <lambda>()
|
| /external/sonivox/arm-wt-22k/lib_src/ |
| D | jet.c | 90 EAS_INLINE EAS_U8 JET_IncQueueIndex (EAS_U8 index, EAS_U8 queueSize) in JET_IncQueueIndex() argument
92 if (++index == queueSize) in JET_IncQueueIndex()
103 …ueue (EAS_U32 *pEventQueue, EAS_U8 *pWriteIndex, EAS_U8 readIndex, EAS_U8 queueSize, EAS_U32 event) in JET_WriteQueue() argument
108 temp = JET_IncQueueIndex(*pWriteIndex, queueSize); in JET_WriteQueue()
126 …ue (EAS_U32 *pEventQueue, EAS_U8 *pReadIndex, EAS_U8 writeIndex, EAS_U8 queueSize, EAS_U32 *pEvent) in JET_ReadQueue() argument
135 *pReadIndex = JET_IncQueueIndex(*pReadIndex, queueSize); in JET_ReadQueue()
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | MinMaxPriorityQueue.java | 231 private MinMaxPriorityQueue(Builder<? super E> builder, int queueSize) { in MinMaxPriorityQueue() argument
240 this.queue = new Object[queueSize]; in MinMaxPriorityQueue()
952 private static int capAtMaximumSize(int queueSize, int maximumSize) { in capAtMaximumSize() argument
953 return Math.min(queueSize - 1, maximumSize) + 1; // don't overflow in capAtMaximumSize()
|
| /external/guava/android/guava/src/com/google/common/collect/ |
| D | MinMaxPriorityQueue.java | 231 private MinMaxPriorityQueue(Builder<? super E> builder, int queueSize) { in MinMaxPriorityQueue() argument
240 this.queue = new Object[queueSize]; in MinMaxPriorityQueue()
952 private static int capAtMaximumSize(int queueSize, int maximumSize) { in capAtMaximumSize() argument
953 return Math.min(queueSize - 1, maximumSize) + 1; // don't overflow in capAtMaximumSize()
|
| /external/mesa3d/include/CL/ |
| D | cl2.hpp | 8794 cl_uint queueSize,
8804 CL_QUEUE_SIZE, queueSize,
8945 const Context &context, const Device &device, cl_uint queueSize, cl_int *err = nullptr)
8953 CL_QUEUE_SIZE, queueSize,
|