Lines Matching refs:numThreads
6777 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize);
6779 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize,
6796 int POOL_resize(POOL_ctx* ctx, size_t numThreads);
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
7087 if (!numThreads) { return NULL; } in POOL_create_advanced()
7110 ctx->threads = (ZSTD_pthread_t*)ZSTD_malloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
7117 for (i = 0; i < numThreads; ++i) { in POOL_create_advanced()
7123 ctx->threadCapacity = numThreads; in POOL_create_advanced()
7124 ctx->threadLimit = numThreads; in POOL_create_advanced()
7169 static int POOL_resize_internal(POOL_ctx* ctx, size_t numThreads) in POOL_resize_internal() argument
7171 if (numThreads <= ctx->threadCapacity) { in POOL_resize_internal()
7172 if (!numThreads) return 1; in POOL_resize_internal()
7173 ctx->threadLimit = numThreads; in POOL_resize_internal()
7177 …{ ZSTD_pthread_t* const threadPool = (ZSTD_pthread_t*)ZSTD_malloc(numThreads * sizeof(ZSTD_pthre… in POOL_resize_internal()
7185 for (threadId = ctx->threadCapacity; threadId < numThreads; ++threadId) { in POOL_resize_internal()
7192 ctx->threadCapacity = numThreads; in POOL_resize_internal()
7193 ctx->threadLimit = numThreads; in POOL_resize_internal()
7198 int POOL_resize(POOL_ctx* ctx, size_t numThreads) in POOL_resize() argument
7203 result = POOL_resize_internal(ctx, numThreads); in POOL_resize()
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
7282 (void)numThreads; in POOL_create_advanced()
7293 int POOL_resize(POOL_ctx* ctx, size_t numThreads) { in POOL_resize() argument
7294 (void)ctx; (void)numThreads; in POOL_resize()