269 #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()
383     DEBUGLOG(3, "cctxPool created, with %u workers", nbWorkers);  in ZSTDMT_createCCtxPool()
388                                               int nbWorkers)  in ZSTDMT_expandCCtxPool()  argument
391     if (nbWorkers <= srcPool->totalCCtx) return srcPool;   /* good enough */  in ZSTDMT_expandCCtxPool()
395         return ZSTDMT_createCCtxPool(nbWorkers, cMem);  in ZSTDMT_expandCCtxPool()
403     {   unsigned const nbWorkers = cctxPool->totalCCtx;  in ZSTDMT_sizeof_CCtxPool()  local
405                                 + (nbWorkers-1) * sizeof(ZSTD_CCtx*);  in ZSTDMT_sizeof_CCtxPool()
408         for (u=0; u<nbWorkers; u++) {  in ZSTDMT_sizeof_CCtxPool()
412         assert(nbWorkers > 0);  in ZSTDMT_sizeof_CCtxPool()
693     jobParams.nbWorkers = 0;  in ZSTDMT_compressionJob()
897 static size_t ZSTDMT_expandJobsTable (ZSTDMT_CCtx* mtctx, U32 nbWorkers) {  in ZSTDMT_expandJobsTable()  argument
898     U32 nbJobs = nbWorkers + 2;  in ZSTDMT_expandJobsTable()
913 static size_t ZSTDMT_CCtxParam_setNbWorkers(ZSTD_CCtx_params* params, unsigned nbWorkers)  in ZSTDMT_CCtxParam_setNbWorkers()  argument
915     return ZSTD_CCtxParams_setParameter(params, ZSTD_c_nbWorkers, (int)nbWorkers);  in ZSTDMT_CCtxParam_setNbWorkers()
918 MEM_STATIC ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced_internal(unsigned nbWorkers, ZSTD_customMem cMem…  in ZSTDMT_createCCtx_advanced_internal()  argument
921     U32 nbJobs = nbWorkers + 2;  in ZSTDMT_createCCtx_advanced_internal()
923     DEBUGLOG(3, "ZSTDMT_createCCtx_advanced (nbWorkers = %u)", nbWorkers);  in ZSTDMT_createCCtx_advanced_internal()
925     if (nbWorkers < 1) return NULL;  in ZSTDMT_createCCtx_advanced_internal()
926     nbWorkers = MIN(nbWorkers , ZSTDMT_NBWORKERS_MAX);  in ZSTDMT_createCCtx_advanced_internal()
933     ZSTDMT_CCtxParam_setNbWorkers(&mtctx->params, nbWorkers);  in ZSTDMT_createCCtx_advanced_internal()
941       mtctx->factory = POOL_create_advanced(nbWorkers, 0, cMem);  in ZSTDMT_createCCtx_advanced_internal()
947     mtctx->bufPool = ZSTDMT_createBufferPool(BUF_POOL_MAX_NB_BUFFERS(nbWorkers), cMem);  in ZSTDMT_createCCtx_advanced_internal()
948     mtctx->cctxPool = ZSTDMT_createCCtxPool(nbWorkers, cMem);  in ZSTDMT_createCCtx_advanced_internal()
949     mtctx->seqPool = ZSTDMT_createSeqPool(nbWorkers, cMem);  in ZSTDMT_createCCtx_advanced_internal()
956     DEBUGLOG(3, "mt_cctx created, for %u threads", nbWorkers);  in ZSTDMT_createCCtx_advanced_internal()
960 ZSTDMT_CCtx* ZSTDMT_createCCtx_advanced(unsigned nbWorkers, ZSTD_customMem cMem, ZSTD_threadPool* p…  in ZSTDMT_createCCtx_advanced()  argument
963     return ZSTDMT_createCCtx_advanced_internal(nbWorkers, cMem, pool);  in ZSTDMT_createCCtx_advanced()
965     (void)nbWorkers;  in ZSTDMT_createCCtx_advanced()
1046 static size_t ZSTDMT_resize(ZSTDMT_CCtx* mtctx, unsigned nbWorkers)  in ZSTDMT_resize()  argument
1048     if (POOL_resize(mtctx->factory, nbWorkers)) return ERROR(memory_allocation);  in ZSTDMT_resize()
1049     FORWARD_IF_ERROR( ZSTDMT_expandJobsTable(mtctx, nbWorkers) , "");  in ZSTDMT_resize()
1050     mtctx->bufPool = ZSTDMT_expandBufferPool(mtctx->bufPool, BUF_POOL_MAX_NB_BUFFERS(nbWorkers));  in ZSTDMT_resize()
1052     mtctx->cctxPool = ZSTDMT_expandCCtxPool(mtctx->cctxPool, nbWorkers);  in ZSTDMT_resize()
1054     mtctx->seqPool = ZSTDMT_expandSeqPool(mtctx->seqPool, nbWorkers);  in ZSTDMT_resize()
1056     ZSTDMT_CCtxParam_setNbWorkers(&mtctx->params, nbWorkers);  in ZSTDMT_resize()
1224                 (U32)pledgedSrcSize, params.nbWorkers, mtctx->cctxPool->totalCCtx);  in ZSTDMT_initCStream_internal()
1231     if (params.nbWorkers != mtctx->params.nbWorkers)  in ZSTDMT_initCStream_internal()
1232         FORWARD_IF_ERROR( ZSTDMT_resize(mtctx, params.nbWorkers) , "");  in ZSTDMT_initCStream_internal()
1237     DEBUGLOG(4, "ZSTDMT_initCStream_internal: %u workers", params.nbWorkers);  in ZSTDMT_initCStream_internal()
1296         size_t const nbWorkers = MAX(mtctx->params.nbWorkers, 1);  in ZSTDMT_initCStream_internal()  local
1297         size_t const sectionsSize = mtctx->targetSectionSize * nbWorkers;  in ZSTDMT_initCStream_internal()