Lines Matching refs:numThreads

108 POOL_ctx* ZSTD_createThreadPool(size_t numThreads) {  in ZSTD_createThreadPool()  argument
109 return POOL_create (numThreads, 0); in ZSTD_createThreadPool()
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
120 if (!numThreads) { return NULL; } in POOL_create_advanced()
143 … ctx->threads = (ZSTD_pthread_t*)ZSTD_customMalloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
150 for (i = 0; i < numThreads; ++i) { in POOL_create_advanced()
156 ctx->threadCapacity = numThreads; in POOL_create_advanced()
157 ctx->threadLimit = numThreads; in POOL_create_advanced()
204 static int POOL_resize_internal(POOL_ctx* ctx, size_t numThreads) in POOL_resize_internal() argument
206 if (numThreads <= ctx->threadCapacity) { in POOL_resize_internal()
207 if (!numThreads) return 1; in POOL_resize_internal()
208 ctx->threadLimit = numThreads; in POOL_resize_internal()
212 …{ ZSTD_pthread_t* const threadPool = (ZSTD_pthread_t*)ZSTD_customMalloc(numThreads * sizeof(ZSTD… in POOL_resize_internal()
220 for (threadId = ctx->threadCapacity; threadId < numThreads; ++threadId) { in POOL_resize_internal()
227 ctx->threadCapacity = numThreads; in POOL_resize_internal()
228 ctx->threadLimit = numThreads; in POOL_resize_internal()
233 int POOL_resize(POOL_ctx* ctx, size_t numThreads) in POOL_resize() argument
238 result = POOL_resize_internal(ctx, numThreads); in POOL_resize()
312 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create() argument
313 return POOL_create_advanced(numThreads, queueSize, ZSTD_defaultCMem); in POOL_create()
316 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, ZSTD_customMem customMem) { in POOL_create_advanced() argument
317 (void)numThreads; in POOL_create_advanced()
328 int POOL_resize(POOL_ctx* ctx, size_t numThreads) { in POOL_resize() argument
329 (void)ctx; (void)numThreads; in POOL_resize()