HomeSort by: relevance | last modified time | path
    Searched defs:nbWorkers (Results 1 - 8 of 8) sorted by relevancy

  /src/external/bsd/zstd/dist/programs/
benchzstd.h 104 int nbWorkers; /* multithreading */
fileio_types.h 65 int nbWorkers;
zstdcli.c 858 unsigned nbWorkers = 0;
908 nbWorkers = init_nbThreads();
912 if (exeNameMatch(programName, ZSTD_ZSTDMT)) nbWorkers=0, singleThread=0;
988 if (!strcmp(argument, "--single-thread")) { nbWorkers = 0; singleThread = 1; continue; }
1053 if (longCommandWArg(&argument, "--threads")) { NEXT_UINT32(nbWorkers); continue; }
1256 nbWorkers = readU32FromChar(&argument);
1301 if ((operation==zom_decompress) && (!singleThread) && (nbWorkers > 1)) {
1304 if ((nbWorkers==0) && (!singleThread)) {
1307 nbWorkers = (unsigned)UTIL_countLogicalCores();
1308 DISPLAYLEVEL(3, "Note: %d logical core(s) detected \n", nbWorkers);
    [all...]
  /src/external/bsd/zstd/dist/lib/compress/
zstdmt_compress.c 278 #define BUF_POOL_MAX_NB_BUFFERS(nbWorkers) (2*(nbWorkers) + 3)
282 #define SEQ_POOL_MAX_NB_BUFFERS(nbWorkers) (nbWorkers)
334 static ZSTDMT_seqPool* ZSTDMT_createSeqPool(unsigned nbWorkers, ZSTD_customMem cMem)
336 ZSTDMT_seqPool* const seqPool = ZSTDMT_createBufferPool(SEQ_POOL_MAX_NB_BUFFERS(nbWorkers), cMem);
347 static ZSTDMT_seqPool* ZSTDMT_expandSeqPool(ZSTDMT_seqPool* pool, U32 nbWorkers)
349 return ZSTDMT_expandBufferPool(pool, SEQ_POOL_MAX_NB_BUFFERS(nbWorkers));
379 * implies nbWorkers >= 1 , checked by caller ZSTDMT_createCCtx() */
380 static ZSTDMT_CCtxPool* ZSTDMT_createCCtxPool(int nbWorkers,
    [all...]
zstd_compress_internal.h 326 int nbWorkers;
zstd_compress.c 872 CCtxParams->nbWorkers = value;
873 return (size_t)(CCtxParams->nbWorkers);
1074 assert(CCtxParams->nbWorkers == 0);
1076 *value = CCtxParams->nbWorkers;
1751 RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-threaded compression only.");
1803 RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-threaded compression only.");
1862 if (cctx->appliedParams.nbWorkers > 0) {
1881 * Only useful for multithreading scenarios currently (nbWorkers >= 1).
1886 if (cctx->appliedParams.nbWorkers > 0) {
3469 int nbWorkers;
    [all...]
  /src/external/bsd/zstd/dist/tests/
zstreamtest.c 1496 { U32 const nbWorkers = 2;
1498 size_t const srcSize = jobSize * nbWorkers; /* we want each job to have predictable size */
1506 CHECK_Z( ZSTD_CCtx_setParameter(zc, ZSTD_c_nbWorkers, nbWorkers) );
2045 /* Test that compression returns the correct error with nbWorkers > 0 */
3039 int nbWorkers;
3050 /* Adjust number of workers occasionally - result must be deterministic independent of nbWorkers */
3051 CHECK_Z(ZSTD_CCtx_getParameter(zc, ZSTD_c_nbWorkers, &nbWorkers));
3052 if (nbWorkers > 0 && (FUZ_rand(&lseed) & 7) == 0) {
3053 DISPLAYLEVEL(6, "t%u: Modify nbWorkers: %d -> %d \n", testNb, nbWorkers, nbWorkers + iter)
    [all...]
fuzzer.c 1003 int nbWorkers;
1005 for (nbWorkers = 0; nbWorkers < 3; ++nbWorkers) {
1009 CHECK_Z(ZSTD_CCtx_setParameter(cctx, ZSTD_c_nbWorkers, nbWorkers));

Completed in 83 milliseconds