Searched refs:nbWorkers (Results 1 – 10 of 10) sorted by relevance
/dragonfly/contrib/zstd/lib/compress/ |
H A D | zstdmt_compress.c | 364 assert(nbWorkers > 0); in ZSTDMT_createCCtxPool() 371 cctxPool->totalCCtx = nbWorkers; in ZSTDMT_createCCtxPool() 400 for (u=0; u<nbWorkers; u++) { in ZSTDMT_sizeof_CCtxPool() 404 assert(nbWorkers > 0); in ZSTDMT_sizeof_CCtxPool() 870 U32 nbJobs = nbWorkers + 2; in ZSTDMT_expandJobsTable() 893 U32 nbJobs = nbWorkers + 2; in ZSTDMT_createCCtx_advanced_internal() 897 if (nbWorkers < 1) return NULL; in ZSTDMT_createCCtx_advanced_internal() 898 nbWorkers = MIN(nbWorkers , ZSTDMT_NBWORKERS_MAX); in ZSTDMT_createCCtx_advanced_internal() 937 (void)nbWorkers; in ZSTDMT_createCCtx_advanced() 1203 if (params.nbWorkers != mtctx->params.nbWorkers) in ZSTDMT_initCStream_internal() [all …]
|
H A D | zstdmt_compress.h | 53 ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced(unsigned nbWorkers,
|
H A D | zstd_compress.c | 693 CCtxParams->nbWorkers = value; in ZSTD_CCtxParams_setParameter() 694 return CCtxParams->nbWorkers; in ZSTD_CCtxParams_setParameter() 856 assert(CCtxParams->nbWorkers == 0); in ZSTD_CCtxParams_getParameter() 858 *value = CCtxParams->nbWorkers; in ZSTD_CCtxParams_getParameter() 1427 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_getFrameProgression() 1451 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_toFlushNow() 4295 if (cctx->appliedParams.nbWorkers >= 1) { in ZSTD_nextInputSizeHint_MTorST() 4378 if (params.nbWorkers > 0) { in ZSTD_CCtx_init_compressStream2() 4382 params.nbWorkers); in ZSTD_CCtx_init_compressStream2() 4403 assert(cctx->appliedParams.nbWorkers == 0); in ZSTD_CCtx_init_compressStream2() [all …]
|
H A D | zstd_compress_internal.h | 230 int nbWorkers; member
|
/dragonfly/contrib/zstd/programs/ |
H A D | zstdcli.c | 703 nbWorkers = 0, in main() local 762 nbWorkers = init_nbThreads(); in main() 766 if (exeNameMatch(programName, ZSTD_ZSTDMT)) nbWorkers=0, singleThread=0; in main() 1059 nbWorkers = (int)readU32FromChar(&argument); in main() 1099 if ((nbWorkers==0) && (!singleThread)) { in main() 1101 nbWorkers = UTIL_countPhysicalCores(); in main() 1105 (void)singleThread; (void)nbWorkers; in main() 1161 benchParams.nbWorkers = nbWorkers; in main() 1213 coverParams.nbThreads = (unsigned)nbWorkers; in main() 1218 fastCoverParams.nbThreads = (unsigned)nbWorkers; in main() [all …]
|
H A D | fileio.c | 317 int nbWorkers; member 364 ret->nbWorkers = 1; in FIO_createPreferences() 440 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers) { in FIO_setNbWorkers() argument 442 if (nbWorkers > 0) DISPLAYLEVEL(2, "Note : multi-threading is disabled \n"); in FIO_setNbWorkers() 444 prefs->nbWorkers = nbWorkers; in FIO_setNbWorkers() 450 if (blockSize && prefs->nbWorkers==0) in FIO_setBlockSize() 456 if (overlapLog && prefs->nbWorkers==0) in FIO_setOverlapLog() 462 if ((adapt>0) && (prefs->nbWorkers==0)) in FIO_setAdaptiveMode() 468 if ((rsyncable>0) && (prefs->nbWorkers==0)) in FIO_setRsyncable() 991 DISPLAYLEVEL(5,"set nb workers = %u \n", prefs->nbWorkers); in FIO_createCResources() [all …]
|
H A D | benchzstd.h | 111 int nbWorkers; /* multithreading */ member
|
H A D | fileio.h | 89 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers);
|
H A D | benchzstd.c | 172 if (adv->nbWorkers==1) { in BMK_initCCtx() 175 CHECK_Z(ZSTD_CCtx_setParameter(ctx, ZSTD_c_nbWorkers, adv->nbWorkers)); in BMK_initCCtx()
|
/dragonfly/contrib/zstd/ |
H A D | CHANGELOG | 259 api : `nbThreads` becomes `nbWorkers` : 1 triggers asynchronous mode
|