Searched refs:threadPool (Results 1 – 4 of 4) sorted by relevance
| /freebsd/sys/contrib/zstd/programs/ |
| H A D | fileio_asyncio.c | 165 ctx->threadPool = NULL; in AIO_IOPool_createThreadPool()
173 ctx->threadPool = POOL_create(1, MAX_IO_JOBS - 2); in AIO_IOPool_createThreadPool()
175 if (!ctx->threadPool) in AIO_IOPool_createThreadPool()
187 ctx->totalIoJobs = ctx->threadPool ? MAX_IO_JOBS : 2; in AIO_IOPool_init()
201 return ctx->threadPool && ctx->threadPoolActive; in AIO_IOPool_threadPoolActive()
233 POOL_joinJobs(ctx->threadPool); in AIO_IOPool_join()
252 if(ctx->threadPool) { in AIO_IOPool_destroy()
257 POOL_free(ctx->threadPool); in AIO_IOPool_destroy()
304 POOL_add(ctx->threadPool, ctx->poolFunction, job); in AIO_IOPool_enqueueJob()
471 assert(ctx->base.threadPool != NULL); /* we shouldn't be here if we work in sync mode */ in AIO_ReadPool_getNextCompletedJob()
[all …]
|
| H A D | fileio_asyncio.h | 36 POOL_ctx* threadPool; member
|
| /freebsd/sys/contrib/openzfs/module/zstd/lib/common/ |
| H A D | pool.c | 224 …{ ZSTD_pthread_t* const threadPool = (ZSTD_pthread_t*)ZSTD_customCalloc(numThreads * sizeof(ZSTD… in POOL_resize_internal() local
225 if (!threadPool) return 1; in POOL_resize_internal()
227 ZSTD_memcpy(threadPool, ctx->threads, ctx->threadCapacity * sizeof(ZSTD_pthread_t)); in POOL_resize_internal()
229 ctx->threads = threadPool; in POOL_resize_internal()
233 if (ZSTD_pthread_create(&threadPool[threadId], NULL, &POOL_thread, ctx)) { in POOL_resize_internal()
|
| /freebsd/sys/contrib/zstd/lib/common/ |
| H A D | pool.c | 223 …{ ZSTD_pthread_t* const threadPool = (ZSTD_pthread_t*)ZSTD_customCalloc(numThreads * sizeof(ZSTD… in POOL_resize_internal() local
224 if (!threadPool) return 1; in POOL_resize_internal()
226 ZSTD_memcpy(threadPool, ctx->threads, ctx->threadCapacity * sizeof(ZSTD_pthread_t)); in POOL_resize_internal()
228 ctx->threads = threadPool; in POOL_resize_internal()
232 if (ZSTD_pthread_create(&threadPool[threadId], NULL, &POOL_thread, ctx)) { in POOL_resize_internal()
|