| /freebsd/sys/contrib/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 278 #define BUF_POOL_MAX_NB_BUFFERS(nbWorkers) (2*(nbWorkers) + 3) argument
282 #define SEQ_POOL_MAX_NB_BUFFERS(nbWorkers) (nbWorkers) argument
334 static ZSTDMT_seqPool* ZSTDMT_createSeqPool(unsigned nbWorkers, ZSTD_customMem cMem) in ZSTDMT_createSeqPool() argument
336 … ZSTDMT_seqPool* const seqPool = ZSTDMT_createBufferPool(SEQ_POOL_MAX_NB_BUFFERS(nbWorkers), cMem); in ZSTDMT_createSeqPool()
347 static ZSTDMT_seqPool* ZSTDMT_expandSeqPool(ZSTDMT_seqPool* pool, U32 nbWorkers) in ZSTDMT_expandSeqPool() argument
349 return ZSTDMT_expandBufferPool(pool, SEQ_POOL_MAX_NB_BUFFERS(nbWorkers)); in ZSTDMT_expandSeqPool()
380 static ZSTDMT_CCtxPool* ZSTDMT_createCCtxPool(int nbWorkers, in ZSTDMT_createCCtxPool() argument
385 assert(nbWorkers > 0); in ZSTDMT_createCCtxPool()
391 cctxPool->totalCCtx = nbWorkers; in ZSTDMT_createCCtxPool()
392 cctxPool->cctxs = (ZSTD_CCtx**)ZSTD_customCalloc(nbWorkers * sizeof(ZSTD_CCtx*), cMem); in ZSTDMT_createCCtxPool()
[all …]
|
| H A D | zstdmt_compress.h | 47 ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced(unsigned nbWorkers,
|
| H A D | zstd_compress.c | 872 CCtxParams->nbWorkers = value; in ZSTD_CCtxParams_setParameter()
873 return (size_t)(CCtxParams->nbWorkers); in ZSTD_CCtxParams_setParameter()
1080 assert(CCtxParams->nbWorkers == 0); in ZSTD_CCtxParams_getParameter()
1082 *value = CCtxParams->nbWorkers; in ZSTD_CCtxParams_getParameter()
1761 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCCtxSize_usingCCtxParams()
1813 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCStreamSize_usingCCtxParams()
1872 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_getFrameProgression()
1896 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_toFlushNow()
3532 int nbWorkers; in ZSTD_generateSequences() local
3533 FORWARD_IF_ERROR(ZSTD_CCtx_getParameter(zc, ZSTD_c_nbWorkers, &nbWorkers), ""); in ZSTD_generateSequences()
[all …]
|
| H A D | zstd_compress_internal.h | 381 int nbWorkers; member
|
| /freebsd/sys/contrib/zstd/programs/ |
| H A D | zstdcli.c | 871 int nbWorkers = -1; /* -1 means unset */ in main() local
921 if (exeNameMatch(programName, ZSTD_ZSTDMT)) nbWorkers=0, singleThread=0; in main()
997 … if (!strcmp(argument, "--single-thread")) { nbWorkers = 0; singleThread = 1; continue; } in main()
1072 if (longCommandWArg(&argument, "--threads")) { NEXT_UINT32(nbWorkers); continue; } in main()
1276 nbWorkers = readU32FromChar(&argument); in main()
1321 if ((operation==zom_decompress) && (nbWorkers > 1)) { in main()
1324 if ((nbWorkers==0) && (!singleThread)) { in main()
1327 nbWorkers = (unsigned)UTIL_countLogicalCores(); in main()
1328 DISPLAYLEVEL(3, "Note: %d logical core(s) detected \n", nbWorkers); in main()
1330 nbWorkers = (unsigned)UTIL_countPhysicalCores(); in main()
[all …]
|
| H A D | fileio_types.h | 65 int nbWorkers; member
|
| H A D | benchzstd.h | 99 int nbWorkers; /* multithreading */ member
|
| H A D | fileio.c | 290 ret->nbWorkers = 1; in FIO_createPreferences()
369 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers) { in FIO_setNbWorkers() argument
371 if (nbWorkers > 0) DISPLAYLEVEL(2, "Note : multi-threading is disabled \n"); in FIO_setNbWorkers()
373 prefs->nbWorkers = nbWorkers; in FIO_setNbWorkers()
381 if (blockSize && prefs->nbWorkers==0) in FIO_setBlockSize()
387 if (overlapLog && prefs->nbWorkers==0) in FIO_setOverlapLog()
393 if ((adapt>0) && (prefs->nbWorkers==0)) in FIO_setAdaptiveMode()
403 if ((rsyncable>0) && (prefs->nbWorkers==0)) in FIO_setRsyncable()
1184 DISPLAYLEVEL(5,"set nb workers = %u \n", prefs->nbWorkers); in FIO_createCResources()
1185 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_nbWorkers, prefs->nbWorkers) ); in FIO_createCResources()
[all …]
|
| H A D | fileio.h | 82 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers);
|
| H A D | benchzstd.c | 254 if (adv->nbWorkers == 1) { in BMK_initCCtx()
257 CHECK_Z(ZSTD_CCtx_setParameter(ctx, ZSTD_c_nbWorkers, adv->nbWorkers)); in BMK_initCCtx()
547 if (!UTIL_support_MT_measurements() && adv->nbWorkers > 1) { in BMK_benchMemAdvancedNoAlloc()
|
| /freebsd/sys/contrib/openzfs/module/zstd/lib/compress/ |
| H A D | zstd_compress.c | 873 CCtxParams->nbWorkers = value; in ZSTD_CCtxParams_setParameter()
874 return (size_t)(CCtxParams->nbWorkers); in ZSTD_CCtxParams_setParameter()
1081 assert(CCtxParams->nbWorkers == 0); in ZSTD_CCtxParams_getParameter()
1083 *value = CCtxParams->nbWorkers; in ZSTD_CCtxParams_getParameter()
1762 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCCtxSize_usingCCtxParams()
1814 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCStreamSize_usingCCtxParams()
1873 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_getFrameProgression()
1897 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_toFlushNow()
3533 int nbWorkers; in ZSTD_generateSequences() local
3534 FORWARD_IF_ERROR(ZSTD_CCtx_getParameter(zc, ZSTD_c_nbWorkers, &nbWorkers), ""); in ZSTD_generateSequences()
[all …]
|
| H A D | zstd_compress_internal.h | 382 int nbWorkers; member
|
| /freebsd/sys/contrib/zstd/ |
| H A D | CHANGELOG | 506 api : `nbThreads` becomes `nbWorkers` : 1 triggers asynchronous mode
|