Home
last modified time | relevance | path

Searched refs:mtctx (Results 1 – 6 of 6) sorted by relevance

/freebsd-12.1/sys/contrib/zstd/lib/compress/
H A Dzstdmt_compress.c839 …if (!mtctx->factory | !mtctx->jobs | !mtctx->bufPool | !mtctx->cctxPool | !mtctx->seqPool | initEr… in ZSTDMT_createCCtx_advanced()
874 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
891 ZSTDMT_freeJobsTable(mtctx->jobs, mtctx->jobIDMask+1, mtctx->cMem); in ZSTDMT_freeCCtx()
899 ZSTD_free(mtctx, mtctx->cMem); in ZSTDMT_freeCCtx()
1095 ZSTDMT_freeJobsTable(mtctx->jobs, mtctx->jobIDMask+1, mtctx->cMem); in ZSTDMT_compress_advanced_internal()
1262 mtctx->cdict = mtctx->cdictLocal; in ZSTDMT_initCStream_internal()
1396 if (mtctx->nextJobID > mtctx->doneJobID + mtctx->jobIDMask) { in ZSTDMT_createCompressionJob()
1398 assert((mtctx->nextJobID & mtctx->jobIDMask) == (mtctx->doneJobID & mtctx->jobIDMask)); in ZSTDMT_createCompressionJob()
1412 mtctx->jobs[jobID].params = mtctx->params; in ZSTDMT_createCompressionJob()
1413 mtctx->jobs[jobID].cdict = mtctx->nextJobID==0 ? mtctx->cdict : NULL; in ZSTDMT_createCompressionJob()
[all …]
H A Dzstdmt_compress.h36 ZSTDLIB_API size_t ZSTDMT_freeCCtx(ZSTDMT_CCtx* mtctx);
38 ZSTDLIB_API size_t ZSTDMT_sizeof_CCtx(ZSTDMT_CCtx* mtctx);
43 ZSTDLIB_API size_t ZSTDMT_compressCCtx(ZSTDMT_CCtx* mtctx,
52 ZSTDLIB_API size_t ZSTDMT_initCStream(ZSTDMT_CCtx* mtctx, int compressionLevel);
67 ZSTDLIB_API size_t ZSTDMT_compress_advanced(ZSTDMT_CCtx* mtctx,
74 ZSTDLIB_API size_t ZSTDMT_initCStream_advanced(ZSTDMT_CCtx* mtctx,
79 ZSTDLIB_API size_t ZSTDMT_initCStream_usingCDict(ZSTDMT_CCtx* mtctx,
106 ZSTDLIB_API size_t ZSTDMT_compressStream_generic(ZSTDMT_CCtx* mtctx,
127 void ZSTDMT_updateCParams_whileCompressing(ZSTDMT_CCtx* mtctx, const ZSTD_CCtx_params* cctxParams);
132 unsigned ZSTDMT_getNbWorkers(const ZSTDMT_CCtx* mtctx);
[all …]
H A Dzstd_compress.c112 ZSTDMT_freeCCtx(cctx->mtctx); cctx->mtctx = NULL; in ZSTD_freeCCtx()
122 return ZSTDMT_sizeof_CCtx(cctx->mtctx); in ZSTD_sizeof_mtctx()
778 return ZSTDMT_getFrameProgression(cctx->mtctx); in ZSTD_getFrameProgression()
3216 if (cctx->mtctx == NULL || (params.nbWorkers != ZSTDMT_getNbWorkers(cctx->mtctx))) { in ZSTD_compress_generic()
3219 if (cctx->mtctx != NULL) in ZSTD_compress_generic()
3221 ZSTDMT_getNbWorkers(cctx->mtctx)); in ZSTD_compress_generic()
3222 ZSTDMT_freeCCtx(cctx->mtctx); in ZSTD_compress_generic()
3223 cctx->mtctx = ZSTDMT_createCCtx_advanced(params.nbWorkers, cctx->customMem); in ZSTD_compress_generic()
3224 if (cctx->mtctx == NULL) return ERROR(memory_allocation); in ZSTD_compress_generic()
3229 cctx->mtctx, in ZSTD_compress_generic()
[all …]
H A Dzstd_compress_internal.h234 ZSTDMT_CCtx* mtctx; member
/freebsd-12.1/sys/contrib/zstd/tests/
H A Dfuzzer.c496 { ZSTDMT_CCtx* mtctx = ZSTDMT_createCCtx(2); in basicUnitTests() local
497 if (mtctx==NULL) { in basicUnitTests()
505 CHECKPLUS(r, ZSTDMT_compressCCtx(mtctx, in basicUnitTests()
536 CHECKPLUS(r, ZSTDMT_compress_advanced(mtctx, in basicUnitTests()
549 ZSTDMT_freeCCtx(mtctx); in basicUnitTests()
H A Dzstreamtest.c225 ZSTDMT_CCtx* mtctx = ZSTDMT_createCCtx(2); in basicUnitTests() local
751 CHECK_Z( ZSTDMT_initCStream_advanced(mtctx, CNBuffer, dictSize, params, CNBufferSize) ); in basicUnitTests()
759 …{ size_t const compressResult = ZSTDMT_compressStream_generic(mtctx, &outBuff, &inBuff, ZSTD_e_e… in basicUnitTests()
908 ZSTDMT_freeCCtx(mtctx); in basicUnitTests()