Home
last modified time | relevance | path

Searched refs:numThreads (Results 1 – 7 of 7) sorted by relevance

/src/sys/contrib/zstd/lib/common/
H A Dpool.c109 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()
[all …]
H A Dpool.h31 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize);
33 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize,
50 int POOL_resize(POOL_ctx* ctx, size_t numThreads);
/src/sys/contrib/openzfs/module/zstd/lib/common/
H A Dpool.c108 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
121 if (!numThreads) { return NULL; } in POOL_create_advanced()
144 … ctx->threads = (ZSTD_pthread_t*)ZSTD_customCalloc(numThreads * sizeof(ZSTD_pthread_t), customMem); in POOL_create_advanced()
151 for (i = 0; i < numThreads; ++i) { in POOL_create_advanced()
157 ctx->threadCapacity = numThreads; in POOL_create_advanced()
158 ctx->threadLimit = numThreads; in POOL_create_advanced()
[all …]
H A Dpool.h28 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize);
30 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize,
53 int POOL_resize(POOL_ctx* ctx, size_t numThreads);
/src/tools/test/stress2/misc/
H A Dsignal.sh97 int numThreads;
98 sscanf(argv[1], "%d", &numThreads);
99 if( numThreads < 1 ) numThreads = 1;
101 pthread_t *threads = (pthread_t *)malloc(sizeof(pthread_t)*numThreads);
116 for(i = 0; i < numThreads; ++i) {
159 for(i = 0; i < numThreads; ++i ) {
/src/sys/contrib/zstd/lib/
H A Dzstd.h1616 ZSTDLIB_STATIC_API ZSTD_threadPool* ZSTD_createThreadPool(size_t numThreads);
/src/sys/contrib/openzfs/module/zstd/lib/
H A Dzstd.h1908 ZSTDLIB_STATIC_API ZSTD_threadPool* ZSTD_createThreadPool(size_t numThreads);