Home
last modified time | relevance | path

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

/external/zstd/lib/compress/
Dzstdmt_compress.c869 static size_t ZSTDMT_expandJobsTable (ZSTDMT_CCtx* mtctx, U32 nbWorkers) { in ZSTDMT_expandJobsTable() argument
871 if (nbJobs > mtctx->jobIDMask+1) { /* need more job capacity */ in ZSTDMT_expandJobsTable()
872 ZSTDMT_freeJobsTable(mtctx->jobs, mtctx->jobIDMask+1, mtctx->cMem); in ZSTDMT_expandJobsTable()
873 mtctx->jobIDMask = 0; in ZSTDMT_expandJobsTable()
874 mtctx->jobs = ZSTDMT_createJobsTable(&nbJobs, mtctx->cMem); in ZSTDMT_expandJobsTable()
875 if (mtctx->jobs==NULL) return ERROR(memory_allocation); in ZSTDMT_expandJobsTable()
877 mtctx->jobIDMask = nbJobs - 1; in ZSTDMT_expandJobsTable()
892 ZSTDMT_CCtx* mtctx; in ZSTDMT_createCCtx_advanced_internal() local
903 mtctx = (ZSTDMT_CCtx*) ZSTD_customCalloc(sizeof(ZSTDMT_CCtx), cMem); in ZSTDMT_createCCtx_advanced_internal()
904 if (!mtctx) return NULL; in ZSTDMT_createCCtx_advanced_internal()
[all …]
Dzstdmt_compress.h56 size_t ZSTDMT_freeCCtx(ZSTDMT_CCtx* mtctx);
58 size_t ZSTDMT_sizeof_CCtx(ZSTDMT_CCtx* mtctx);
62 size_t ZSTDMT_nextInputSizeHint(const ZSTDMT_CCtx* mtctx);
81 size_t ZSTDMT_compressStream_generic(ZSTDMT_CCtx* mtctx,
92 size_t ZSTDMT_toFlushNow(ZSTDMT_CCtx* mtctx);
97 void ZSTDMT_updateCParams_whileCompressing(ZSTDMT_CCtx* mtctx, const ZSTD_CCtx_params* cctxParams);
103 ZSTD_frameProgression ZSTDMT_getFrameProgression(ZSTDMT_CCtx* mtctx);
Dzstd_compress.c155 ZSTDMT_freeCCtx(cctx->mtctx); cctx->mtctx = NULL; in ZSTD_freeCCtxContent()
179 return ZSTDMT_sizeof_CCtx(cctx->mtctx); in ZSTD_sizeof_mtctx()
1428 return ZSTDMT_getFrameProgression(cctx->mtctx); in ZSTD_getFrameProgression()
1452 return ZSTDMT_toFlushNow(cctx->mtctx); in ZSTD_toFlushNow()
4296 assert(cctx->mtctx != NULL); in ZSTD_nextInputSizeHint_MTorST()
4297 return ZSTDMT_nextInputSizeHint(cctx->mtctx); in ZSTD_nextInputSizeHint_MTorST()
4380 if (cctx->mtctx == NULL) { in ZSTD_CCtx_init_compressStream2()
4383 … cctx->mtctx = ZSTDMT_createCCtx_advanced((U32)params.nbWorkers, cctx->customMem, cctx->pool); in ZSTD_CCtx_init_compressStream2()
4384 RETURN_ERROR_IF(cctx->mtctx == NULL, memory_allocation, "NULL pointer!"); in ZSTD_CCtx_init_compressStream2()
4389 cctx->mtctx, in ZSTD_CCtx_init_compressStream2()
[all …]
Dzstd_compress_internal.h322 ZSTDMT_CCtx* mtctx; member
/external/zstd/tests/
Dfuzzer.c1437 { ZSTD_CCtx* const mtctx = ZSTD_createCCtx(); in basicUnitTests() local
1438 if (mtctx==NULL) { in basicUnitTests()
1443 CHECK( ZSTD_CCtx_setParameter(mtctx, ZSTD_c_nbWorkers, 2) ); in basicUnitTests()
1444 CHECK( ZSTD_CCtx_setParameter(mtctx, ZSTD_c_compressionLevel, 1) ); in basicUnitTests()
1448 CHECK_VAR(cSize, ZSTD_compress2(mtctx, in basicUnitTests()
1474 CHECK( ZSTD_CCtx_setParameter(mtctx, ZSTD_c_checksumFlag, 1) ); in basicUnitTests()
1475 CHECK( ZSTD_CCtx_setParameter(mtctx, ZSTD_c_contentSizeFlag, 1) ); in basicUnitTests()
1476 CHECK( ZSTD_CCtx_setParameter(mtctx, ZSTD_c_overlapLog, 3) ); in basicUnitTests()
1477 CHECK_VAR(cSize, ZSTD_compress2(mtctx, in basicUnitTests()
1487 ZSTD_freeCCtx(mtctx); in basicUnitTests()
Dzstreamtest.c276 ZSTD_CCtx* mtctx = ZSTD_createCCtx(); in basicUnitTests() local
285 if (!CNBuffer || !compressedBuffer || !decodedBuffer || !zc || !zd || !mtctx) { in basicUnitTests()
291 CHECK_Z(ZSTD_CCtx_setParameter(mtctx, ZSTD_c_nbWorkers, 2)); in basicUnitTests()
1309 CHECK_Z( ZSTD_CCtx_getParameter(mtctx, ZSTD_c_jobSize, &jobSize)); in basicUnitTests()
1311 CHECK_Z( ZSTD_CCtx_getParameter(mtctx, ZSTD_c_jobSize, &jobSize)); in basicUnitTests()
1320 { size_t const compressResult = ZSTD_compressStream2(mtctx, &outBuff, &inBuff, ZSTD_e_end); in basicUnitTests()
1678 ZSTD_freeCCtx(mtctx); in basicUnitTests()