HomeSort by: relevance | last modified time | path
    Searched refs:nbWorkers (Results 1 - 12 of 12) sorted by relevancy

  /src/external/bsd/zstd/dist/lib/compress/
zstdmt_compress.h 47 ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced(unsigned nbWorkers,
zstdmt_compress.c 278 #define BUF_POOL_MAX_NB_BUFFERS(nbWorkers) (2*(nbWorkers) + 3)
282 #define SEQ_POOL_MAX_NB_BUFFERS(nbWorkers) (nbWorkers)
334 static ZSTDMT_seqPool* ZSTDMT_createSeqPool(unsigned nbWorkers, ZSTD_customMem cMem)
336 ZSTDMT_seqPool* const seqPool = ZSTDMT_createBufferPool(SEQ_POOL_MAX_NB_BUFFERS(nbWorkers), cMem);
347 static ZSTDMT_seqPool* ZSTDMT_expandSeqPool(ZSTDMT_seqPool* pool, U32 nbWorkers)
349 return ZSTDMT_expandBufferPool(pool, SEQ_POOL_MAX_NB_BUFFERS(nbWorkers));
379 * implies nbWorkers >= 1 , checked by caller ZSTDMT_createCCtx() */
380 static ZSTDMT_CCtxPool* ZSTDMT_createCCtxPool(int nbWorkers,
    [all...]
zstd_compress.c 872 CCtxParams->nbWorkers = value;
873 return (size_t)(CCtxParams->nbWorkers);
1080 assert(CCtxParams->nbWorkers == 0);
1082 *value = CCtxParams->nbWorkers;
1761 RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-threaded compression only.");
1813 RETURN_ERROR_IF(params->nbWorkers > 0, GENERIC, "Estimate CCtx size is supported for single-threaded compression only.");
1872 if (cctx->appliedParams.nbWorkers > 0) {
1891 * Only useful for multithreading scenarios currently (nbWorkers >= 1).
1896 if (cctx->appliedParams.nbWorkers > 0) {
3532 int nbWorkers;
    [all...]
zstd_compress_internal.h 381 int nbWorkers;
  /src/external/bsd/zstd/dist/programs/
fileio_types.h 65 int nbWorkers;
benchzstd.h 99 int nbWorkers; /* multithreading */
zstdcli.c 871 int nbWorkers = -1; /* -1 means unset */
921 if (exeNameMatch(programName, ZSTD_ZSTDMT)) nbWorkers=0, singleThread=0;
997 if (!strcmp(argument, "--single-thread")) { nbWorkers = 0; singleThread = 1; continue; }
1072 if (longCommandWArg(&argument, "--threads")) { NEXT_UINT32(nbWorkers); continue; }
1276 nbWorkers = readU32FromChar(&argument);
1321 if ((operation==zom_decompress) && (nbWorkers > 1)) {
1324 if ((nbWorkers==0) && (!singleThread)) {
1327 nbWorkers = (unsigned)UTIL_countLogicalCores();
1328 DISPLAYLEVEL(3, "Note: %d logical core(s) detected \n", nbWorkers);
1330 nbWorkers = (unsigned)UTIL_countPhysicalCores()
    [all...]
fileio.h 82 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers);
fileio.c 290 ret->nbWorkers = 1;
369 void FIO_setNbWorkers(FIO_prefs_t* const prefs, int nbWorkers) {
371 if (nbWorkers > 0) DISPLAYLEVEL(2, "Note : multi-threading is disabled \n");
373 prefs->nbWorkers = nbWorkers;
381 if (blockSize && prefs->nbWorkers==0)
387 if (overlapLog && prefs->nbWorkers==0)
393 if ((adapt>0) && (prefs->nbWorkers==0))
403 if ((rsyncable>0) && (prefs->nbWorkers==0))
1184 DISPLAYLEVEL(5,"set nb workers = %u \n", prefs->nbWorkers);
    [all...]
benchzstd.c 213 0, /* nbWorkers */
254 if (adv->nbWorkers == 1) {
257 CHECK_Z(ZSTD_CCtx_setParameter(ctx, ZSTD_c_nbWorkers, adv->nbWorkers));
547 if (!UTIL_support_MT_measurements() && adv->nbWorkers > 1) {
  /src/external/bsd/zstd/dist/tests/
zstreamtest.c 1497 { U32 const nbWorkers = 2;
1499 size_t const srcSize = jobSize * nbWorkers; /* we want each job to have predictable size */
1507 CHECK_Z( ZSTD_CCtx_setParameter(zc, ZSTD_c_nbWorkers, nbWorkers) );
2046 /* Test that compression returns the correct error with nbWorkers > 0 */
3099 int nbWorkers;
3110 /* Adjust number of workers occasionally - result must be deterministic independent of nbWorkers */
3111 CHECK_Z(ZSTD_CCtx_getParameter(zc, ZSTD_c_nbWorkers, &nbWorkers));
3112 if (nbWorkers > 0 && (FUZ_rand(&lseed) & 7) == 0) {
3113 DISPLAYLEVEL(6, "t%u: Modify nbWorkers: %d -> %d \n", testNb, nbWorkers, nbWorkers + iter)
    [all...]
fuzzer.c 1091 int nbWorkers;
1093 for (nbWorkers = 0; nbWorkers < 3; ++nbWorkers) {
1097 CHECK_Z(ZSTD_CCtx_setParameter(cctx, ZSTD_c_nbWorkers, nbWorkers));

Completed in 69 milliseconds