Lines Matching refs:numThreads
109 POOL_ctx* ZSTD_createThreadPool(size_t numThreads) { in ZSTD_createThreadPool() argument
110 return POOL_create (numThreads, 0); in ZSTD_createThreadPool()
113 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create() argument
114 return POOL_create_advanced(numThreads, queueSize, ZSTD_defaultCMem); in POOL_create()
117 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, in POOL_create_advanced() argument
122 if (!numThreads) { return NULL; } in POOL_create_advanced()
145 … ctx->threads = (ZSTD_pthread_t*)ZSTD_customMalloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
152 for (i = 0; i < numThreads; ++i) { in POOL_create_advanced()
158 ctx->threadCapacity = numThreads; in POOL_create_advanced()
159 ctx->threadLimit = numThreads; in POOL_create_advanced()
206 static int POOL_resize_internal(POOL_ctx* ctx, size_t numThreads) in POOL_resize_internal() argument
208 if (numThreads <= ctx->threadCapacity) { in POOL_resize_internal()
209 if (!numThreads) return 1; in POOL_resize_internal()
210 ctx->threadLimit = numThreads; in POOL_resize_internal()
214 …{ ZSTD_pthread_t* const threadPool = (ZSTD_pthread_t*)ZSTD_customMalloc(numThreads * sizeof(ZSTD… in POOL_resize_internal()
222 for (threadId = ctx->threadCapacity; threadId < numThreads; ++threadId) { in POOL_resize_internal()
229 ctx->threadCapacity = numThreads; in POOL_resize_internal()
230 ctx->threadLimit = numThreads; in POOL_resize_internal()
235 int POOL_resize(POOL_ctx* ctx, size_t numThreads) in POOL_resize() argument
240 result = POOL_resize_internal(ctx, numThreads); in POOL_resize()
315 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create() argument
316 return POOL_create_advanced(numThreads, queueSize, ZSTD_defaultCMem); in POOL_create()
320 POOL_create_advanced(size_t numThreads, size_t queueSize, ZSTD_customMem customMem) in POOL_create_advanced() argument
322 (void)numThreads; in POOL_create_advanced()
333 int POOL_resize(POOL_ctx* ctx, size_t numThreads) { in POOL_resize() argument
334 (void)ctx; (void)numThreads; in POOL_resize()