Home
last modified time | relevance | path

Searched refs:nbWorkers (Results 1 – 10 of 10) sorted by relevance

/dragonfly/contrib/zstd/lib/compress/
H A Dzstdmt_compress.c364 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 Dzstdmt_compress.h53 ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced(unsigned nbWorkers,
H A Dzstd_compress.c693 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 Dzstd_compress_internal.h230 int nbWorkers; member
/dragonfly/contrib/zstd/programs/
H A Dzstdcli.c703 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 Dfileio.c317 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 Dbenchzstd.h111 int nbWorkers; /* multithreading */ member
H A Dfileio.h89 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers);
H A Dbenchzstd.c172 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 DCHANGELOG259 api : `nbThreads` becomes `nbWorkers` : 1 triggers asynchronous mode