Home
last modified time | relevance | path

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

/external/zstd/lib/compress/
Dzstdmt_compress.c105 static ZSTDMT_bufferPool* ZSTDMT_createBufferPool(unsigned nbWorkers, ZSTD_customMem cMem) in ZSTDMT_createBufferPool() argument
107 unsigned const maxNbBuffers = 2*nbWorkers + 3; in ZSTDMT_createBufferPool()
163 static ZSTDMT_bufferPool* ZSTDMT_expandBufferPool(ZSTDMT_bufferPool* srcBufPool, U32 nbWorkers) in ZSTDMT_expandBufferPool() argument
165 unsigned const maxNbBuffers = 2*nbWorkers + 3; in ZSTDMT_expandBufferPool()
174 newBufPool = ZSTDMT_createBufferPool(nbWorkers, cMem); in ZSTDMT_expandBufferPool()
317 static ZSTDMT_seqPool* ZSTDMT_createSeqPool(unsigned nbWorkers, ZSTD_customMem cMem) in ZSTDMT_createSeqPool() argument
319 ZSTDMT_seqPool* const seqPool = ZSTDMT_createBufferPool(nbWorkers, cMem); in ZSTDMT_createSeqPool()
330 static ZSTDMT_seqPool* ZSTDMT_expandSeqPool(ZSTDMT_seqPool* pool, U32 nbWorkers) in ZSTDMT_expandSeqPool() argument
332 return ZSTDMT_expandBufferPool(pool, nbWorkers); in ZSTDMT_expandSeqPool()
359 static ZSTDMT_CCtxPool* ZSTDMT_createCCtxPool(int nbWorkers, in ZSTDMT_createCCtxPool() argument
[all …]
Dzstdmt_compress.h53 ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced(unsigned nbWorkers,
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()
1347 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCCtxSize_usingCCtxParams()
1380 …RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-thread… in ZSTD_estimateCStreamSize_usingCCtxParams()
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()
4376 params.nbWorkers = 0; /* do not invoke multi-threading when src size is too small */ in ZSTD_CCtx_init_compressStream2()
[all …]
Dzstd_compress_internal.h230 int nbWorkers; member
/external/zstd/programs/
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()
832 … if (!strcmp(argument, "--single-thread")) { nbWorkers = 0; singleThread = 1; continue; } in main()
886 if (longCommandWArg(&argument, "--threads")) { NEXT_UINT32(nbWorkers); continue; } in main()
1059 nbWorkers = (int)readU32FromChar(&argument); in main()
1099 if ((nbWorkers==0) && (!singleThread)) { in main()
1101 nbWorkers = UTIL_countPhysicalCores(); in main()
1102 DISPLAYLEVEL(3, "Note: %d physical core(s) detected \n", nbWorkers); in main()
1105 (void)singleThread; (void)nbWorkers; in main()
[all …]
Dbenchzstd.h111 int nbWorkers; /* multithreading */ member
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 …]
Dfileio.h89 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers);
Dbenchzstd.c172 if (adv->nbWorkers==1) { in BMK_initCCtx()
175 CHECK_Z(ZSTD_CCtx_setParameter(ctx, ZSTD_c_nbWorkers, adv->nbWorkers)); in BMK_initCCtx()
/external/zstd/tests/
Dzstreamtest.c1330 { U32 const nbWorkers = 2; in basicUnitTests() local
1332 size_t const srcSize = jobSize * nbWorkers; /* we want each job to have predictable size */ in basicUnitTests()
1340 CHECK_Z( ZSTD_CCtx_setParameter(zc, ZSTD_c_nbWorkers, nbWorkers) ); in basicUnitTests()
2246 int nbWorkers; in fuzzerTests_newAPI() local
2258 CHECK_Z(ZSTD_CCtx_getParameter(zc, ZSTD_c_nbWorkers, &nbWorkers)); in fuzzerTests_newAPI()
2259 if (nbWorkers > 0 && (FUZ_rand(&lseed) & 7) == 0) { in fuzzerTests_newAPI()
2260 … DISPLAYLEVEL(6, "t%u: Modify nbWorkers: %d -> %d \n", testNb, nbWorkers, nbWorkers + iter); in fuzzerTests_newAPI()
2261 CHECK_Z(ZSTD_CCtx_setParameter(zc, ZSTD_c_nbWorkers, nbWorkers + iter)); in fuzzerTests_newAPI()
Dfuzzer.c706 int nbWorkers; in basicUnitTests() local
708 for (nbWorkers = 0; nbWorkers < 3; ++nbWorkers) { in basicUnitTests()
712 CHECK_Z(ZSTD_CCtx_setParameter(cctx, ZSTD_c_nbWorkers, nbWorkers)); in basicUnitTests()
/external/zstd/
DCHANGELOG256 api : `nbThreads` becomes `nbWorkers` : 1 triggers asynchronous mode