| /freebsd-12.1/sys/contrib/zstd/contrib/pzstd/test/ |
| H A D | PzstdTest.cpp | 44 for (unsigned numThreads = 1; numThreads <= 2; ++numThreads) { in TEST() local
47 std::fprintf(stderr, "# threads: %u\n", numThreads); in TEST()
53 options.numThreads = numThreads; in TEST()
79 for (unsigned numThreads = 1; numThreads <= 16; numThreads *= 4) { in TEST() local
82 std::fprintf(stderr, "# threads: %u\n", numThreads); in TEST()
88 options.numThreads = std::min(numThreads, options.numThreads); in TEST()
126 if (options.numThreads == 0) { in TEST()
127 options.numThreads = 1; in TEST()
146 options.numThreads = 1; in TEST()
|
| H A D | RoundTripTest.cpp | 54 std::uniform_int_distribution<unsigned> numThreads{1, 32}; in generateOptions() local
57 options.numThreads = numThreads(gen); in generateOptions()
77 std::fprintf(stderr, "numThreads: %u\n", options.numThreads); in main()
|
| H A D | OptionsTest.cpp | 18 return lhs.numThreads == rhs.numThreads && in operator ==()
31 << "numThreads: " << opt.numThreads; in operator <<()
|
| /freebsd-12.1/sys/contrib/zstd/lib/common/ |
| H A D | pool.c | 37 size_t numThreads; member
102 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create() argument
109 if (!numThreads) { return NULL; } in POOL_create_advanced()
129 ctx->numThreads = 0; in POOL_create_advanced()
135 for (i = 0; i < numThreads; ++i) { in POOL_create_advanced()
137 ctx->numThreads = i; in POOL_create_advanced()
141 ctx->numThreads = numThreads; in POOL_create_advanced()
159 for (i = 0; i < ctx->numThreads; ++i) { in POOL_join()
179 + ctx->numThreads * sizeof(ZSTD_pthread_t); in POOL_sizeof()
192 return ctx->numThreadsBusy == ctx->numThreads || in isQueueFull()
[all …]
|
| H A D | pool.h | 31 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize);
33 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, ZSTD_customMem customMem);
|
| /freebsd-12.1/sys/contrib/zstd/tests/ |
| H A D | poolTests.c | 41 int testOrder(size_t numThreads, size_t queueSize) { in testOrder() argument
43 POOL_ctx *ctx = POOL_create(numThreads, queueSize); in testOrder()
71 int testWait(size_t numThreads, size_t queueSize) { in testWait() argument
73 POOL_ctx *ctx = POOL_create(numThreads, queueSize); in testWait()
86 size_t numThreads; in main() local
87 for (numThreads = 1; numThreads <= 4; ++numThreads) { in main()
90 if (testOrder(numThreads, queueSize)) { in main()
94 if (testWait(numThreads, queueSize)) { in main()
|
| /freebsd-12.1/sys/contrib/zstd/contrib/pzstd/ |
| H A D | Options.h | 24 unsigned numThreads; member
43 Options(unsigned numThreads, unsigned maxWindowLog, unsigned compressionLevel, in Options()
47 : numThreads(numThreads), maxWindowLog(maxWindowLog), in Options()
|
| H A D | Pzstd.cpp | 66 WorkQueue<std::shared_ptr<BufferWorkQueue>> outs{options.numThreads + 1}; in handleOneInput()
71 ThreadPool executor(options.numThreads); in handleOneInput()
84 options.numThreads, in handleOneInput()
342 size_t numThreads, in calculateStep() argument
345 (void)numThreads; in calculateStep()
390 size_t numThreads, in asyncCompressChunks() argument
397 size_t step = calculateStep(size, numThreads, params); in asyncCompressChunks()
|
| H A D | Options.cpp | 114 : numThreads(defaultNumThreads()), maxWindowLog(23), in Options()
229 numThreads = parseUnsigned(&optionArgument); in parse()
233 numThreads, optionArgument); in parse()
404 if (numThreads == 0) { in parse()
|
| H A D | Pzstd.h | 112 std::size_t numThreads,
|
| /freebsd-12.1/sys/contrib/zstd/contrib/pzstd/utils/ |
| H A D | ThreadPool.h | 27 explicit ThreadPool(std::size_t numThreads) { in ThreadPool() argument
28 threads_.reserve(numThreads); in ThreadPool()
29 for (std::size_t i = 0; i < numThreads; ++i) { in ThreadPool()
|