Home
last modified time | relevance | path

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

/freebsd/sys/contrib/zstd/lib/compress/
H A Dzstdmt_compress.c269 #define BUF_POOL_MAX_NB_BUFFERS(nbWorkers) 2*nbWorkers + 3 argument
273 #define SEQ_POOL_MAX_NB_BUFFERS(nbWorkers) nbWorkers argument
325 static ZSTDMT_seqPool* ZSTDMT_createSeqPool(unsigned nbWorkers, ZSTD_customMem cMem) in ZSTDMT_createSeqPool() argument
327 … ZSTDMT_seqPool* const seqPool = ZSTDMT_createBufferPool(SEQ_POOL_MAX_NB_BUFFERS(nbWorkers), cMem); in ZSTDMT_createSeqPool()
338 static ZSTDMT_seqPool* ZSTDMT_expandSeqPool(ZSTDMT_seqPool* pool, U32 nbWorkers) in ZSTDMT_expandSeqPool() argument
340 return ZSTDMT_expandBufferPool(pool, SEQ_POOL_MAX_NB_BUFFERS(nbWorkers)); in ZSTDMT_expandSeqPool()
367 static ZSTDMT_CCtxPool* ZSTDMT_createCCtxPool(int nbWorkers, in ZSTDMT_createCCtxPool() argument
371 sizeof(ZSTDMT_CCtxPool) + (nbWorkers-1)*sizeof(ZSTD_CCtx*), cMem); in ZSTDMT_createCCtxPool()
372 assert(nbWorkers > 0); in ZSTDMT_createCCtxPool()
379 cctxPool->totalCCtx = nbWorkers; in ZSTDMT_createCCtxPool()
[all …]
H A Dzstdmt_compress.h53 ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced(unsigned nbWorkers,
H A Dzstd_compress.c803 CCtxParams->nbWorkers = value; in ZSTD_CCtxParams_setParameter()
804 return CCtxParams->nbWorkers; in ZSTD_CCtxParams_setParameter()
981 assert(CCtxParams->nbWorkers == 0); in ZSTD_CCtxParams_getParameter()
983 *value = CCtxParams->nbWorkers; in ZSTD_CCtxParams_getParameter()
1510 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCCtxSize_usingCCtxParams()
1562 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCStreamSize_usingCCtxParams()
1621 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_getFrameProgression()
1645 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_toFlushNow()
4632 …nst streaming = cctx->inBuffSize > 0 || cctx->outBuffSize > 0 || cctx->appliedParams.nbWorkers > 0; in ZSTD_CCtx_trace()
5498 if (cctx->appliedParams.nbWorkers >= 1) { in ZSTD_nextInputSizeHint_MTorST()
[all …]
H A Dzstd_compress_internal.h303 int nbWorkers; member
/freebsd/sys/contrib/zstd/programs/
H A Dzstdcli.c791 nbWorkers = 0, in main() local
855 nbWorkers = init_nbThreads(); in main()
859 if (exeNameMatch(programName, ZSTD_ZSTDMT)) nbWorkers=0, singleThread=0; in main()
927 … if (!strcmp(argument, "--single-thread")) { nbWorkers = 0; singleThread = 1; continue; } in main()
982 if (longCommandWArg(&argument, "--threads")) { NEXT_UINT32(nbWorkers); continue; } in main()
1167 nbWorkers = (int)readU32FromChar(&argument); in main()
1207 if ((nbWorkers==0) && (!singleThread)) { in main()
1210 nbWorkers = UTIL_countLogicalCores(); in main()
1211 DISPLAYLEVEL(3, "Note: %d logical core(s) detected \n", nbWorkers); in main()
1213 nbWorkers = UTIL_countPhysicalCores(); in main()
[all …]
H A Dfileio.c331 int nbWorkers; member
379 ret->nbWorkers = 1; in FIO_createPreferences()
456 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers) { in FIO_setNbWorkers() argument
458 if (nbWorkers > 0) DISPLAYLEVEL(2, "Note : multi-threading is disabled \n"); in FIO_setNbWorkers()
460 prefs->nbWorkers = nbWorkers; in FIO_setNbWorkers()
468 if (blockSize && prefs->nbWorkers==0) in FIO_setBlockSize()
474 if (overlapLog && prefs->nbWorkers==0) in FIO_setOverlapLog()
480 if ((adapt>0) && (prefs->nbWorkers==0)) in FIO_setAdaptiveMode()
490 if ((rsyncable>0) && (prefs->nbWorkers==0)) in FIO_setRsyncable()
1048 DISPLAYLEVEL(5,"set nb workers = %u \n", prefs->nbWorkers); in FIO_createCResources()
[all …]
H A Dbenchzstd.h111 int nbWorkers; /* multithreading */ member
H A Dfileio.h92 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()
/freebsd/sys/contrib/openzfs/module/zstd/lib/compress/
H A Dzstd_compress.c632 CCtxParams->nbWorkers = value; in ZSTD_CCtxParams_setParameter()
633 return CCtxParams->nbWorkers; in ZSTD_CCtxParams_setParameter()
771 assert(CCtxParams->nbWorkers == 0); in ZSTD_CCtxParams_getParameter()
773 *value = CCtxParams->nbWorkers; in ZSTD_CCtxParams_getParameter()
1128 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCCtxSize_usingCCtxParams()
1192 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCStreamSize_usingCCtxParams()
1236 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_getFrameProgression()
1260 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_toFlushNow()
3947 if (cctx->appliedParams.nbWorkers >= 1) { in ZSTD_nextInputSizeHint_MTorST()
3989 params.nbWorkers = 0; /* do not invoke multi-threading when src size is too small */ in ZSTD_compressStream2()
[all …]
H A Dzstd_compress_internal.h223 int nbWorkers; member
/freebsd/sys/contrib/zstd/
H A DCHANGELOG364 api : `nbThreads` becomes `nbWorkers` : 1 triggers asynchronous mode