Lines Matching refs:nbWorkers
803 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()
5582 params.nbWorkers = 0; /* do not invoke multi-threading when src size is too small */ in ZSTD_CCtx_init_compressStream2()
5584 if (params.nbWorkers > 0) { in ZSTD_CCtx_init_compressStream2()
5591 params.nbWorkers); in ZSTD_CCtx_init_compressStream2()
5592 … cctx->mtctx = ZSTDMT_createCCtx_advanced((U32)params.nbWorkers, cctx->customMem, cctx->pool); in ZSTD_CCtx_init_compressStream2()
5596 DEBUGLOG(4, "call ZSTDMT_initCStream_internal as nbWorkers=%u", params.nbWorkers); in ZSTD_CCtx_init_compressStream2()
5616 assert(cctx->appliedParams.nbWorkers == 0); in ZSTD_CCtx_init_compressStream2()
5656 if (cctx->appliedParams.nbWorkers > 0) { in ZSTD_compressStream2()
6172 if (zcs->appliedParams.nbWorkers > 0) return remainingToFlush; /* minimal estimation */ in ZSTD_endStream()