Lines Matching refs:queueSize
6777 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize);
6779 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize,
7016 size_t queueSize; member
7058 ctx->queueHead = (ctx->queueHead + 1) % ctx->queueSize; in POOL_thread()
7070 if (ctx->queueSize == 1) { in POOL_thread()
7079 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create() argument
7080 return POOL_create_advanced(numThreads, queueSize, ZSTD_defaultCMem); in POOL_create()
7083 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, in POOL_create_advanced() argument
7095 ctx->queueSize = queueSize + 1; in POOL_create_advanced()
7096 ctx->queue = (POOL_job*)ZSTD_malloc(ctx->queueSize * sizeof(POOL_job), customMem); in POOL_create_advanced()
7163 + ctx->queueSize * sizeof(POOL_job) in POOL_sizeof()
7216 if (ctx->queueSize > 1) { in isQueueFull()
7217 return ctx->queueHead == ((ctx->queueTail + 1) % ctx->queueSize); in isQueueFull()
7233 ctx->queueTail = (ctx->queueTail + 1) % ctx->queueSize; in POOL_add_internal()
7277 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create() argument
7278 return POOL_create_advanced(numThreads, queueSize, ZSTD_defaultCMem); in POOL_create()
7281 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, ZSTD_customMem customMem) { in POOL_create_advanced() argument
7283 (void)queueSize; in POOL_create_advanced()