Lines Matching refs:zcs
3730 ZSTDLIB_API size_t ZSTD_freeCStream(ZSTD_CStream* zcs);
3805 ZSTDLIB_API size_t ZSTD_initCStream(ZSTD_CStream* zcs, int compressionLevel);
3812 ZSTDLIB_API size_t ZSTD_compressStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output, ZSTD_inBuffer* in…
3814 ZSTDLIB_API size_t ZSTD_flushStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output);
3816 ZSTDLIB_API size_t ZSTD_endStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output);
4097 ZSTDLIB_API size_t ZSTD_sizeof_CStream(const ZSTD_CStream* zcs);
4812 ZSTD_initCStream_srcSize(ZSTD_CStream* zcs,
4829 ZSTD_initCStream_usingDict(ZSTD_CStream* zcs,
4849 ZSTD_initCStream_advanced(ZSTD_CStream* zcs,
4862 ZSTDLIB_API size_t ZSTD_initCStream_usingCDict(ZSTD_CStream* zcs, const ZSTD_CDict* cdict);
4880 ZSTD_initCStream_usingCDict_advanced(ZSTD_CStream* zcs,
4900 ZSTDLIB_API size_t ZSTD_resetCStream(ZSTD_CStream* zcs, unsigned long long pledgedSrcSize);
9922 size_t ZSTDMT_initCStream_internal(ZSTDMT_CCtx* zcs,
10980 size_t ZSTD_initCStream_internal(ZSTD_CStream* zcs,
13266 size_t ZSTD_sizeof_CStream(const ZSTD_CStream* zcs) in ZSTD_sizeof_CStream() argument
13268 return ZSTD_sizeof_CCtx(zcs); /* same object */ in ZSTD_sizeof_CStream()
16709 size_t ZSTD_freeCStream(ZSTD_CStream* zcs) in ZSTD_freeCStream() argument
16711 return ZSTD_freeCCtx(zcs); /* same object */ in ZSTD_freeCStream()
16755 size_t ZSTD_resetCStream(ZSTD_CStream* zcs, unsigned long long pss) in ZSTD_resetCStream() argument
16763 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_resetCStream()
16764 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , ""); in ZSTD_resetCStream()
16772 size_t ZSTD_initCStream_internal(ZSTD_CStream* zcs, in ZSTD_initCStream_internal() argument
16778 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_initCStream_internal()
16779 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , ""); in ZSTD_initCStream_internal()
16781 zcs->requestedParams = *params; in ZSTD_initCStream_internal()
16784 FORWARD_IF_ERROR( ZSTD_CCtx_loadDictionary(zcs, dict, dictSize) , ""); in ZSTD_initCStream_internal()
16787 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, cdict) , ""); in ZSTD_initCStream_internal()
16794 size_t ZSTD_initCStream_usingCDict_advanced(ZSTD_CStream* zcs, in ZSTD_initCStream_usingCDict_advanced() argument
16800 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_initCStream_usingCDict_advanced()
16801 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , ""); in ZSTD_initCStream_usingCDict_advanced()
16802 zcs->requestedParams.fParams = fParams; in ZSTD_initCStream_usingCDict_advanced()
16803 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, cdict) , ""); in ZSTD_initCStream_usingCDict_advanced()
16808 size_t ZSTD_initCStream_usingCDict(ZSTD_CStream* zcs, const ZSTD_CDict* cdict) in ZSTD_initCStream_usingCDict() argument
16811 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_initCStream_usingCDict()
16812 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, cdict) , ""); in ZSTD_initCStream_usingCDict()
16821 size_t ZSTD_initCStream_advanced(ZSTD_CStream* zcs, in ZSTD_initCStream_advanced() argument
16831 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_initCStream_advanced()
16832 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , ""); in ZSTD_initCStream_advanced()
16834 zcs->requestedParams = ZSTD_assignParamsToCCtxParams(&zcs->requestedParams, ¶ms); in ZSTD_initCStream_advanced()
16835 FORWARD_IF_ERROR( ZSTD_CCtx_loadDictionary(zcs, dict, dictSize) , ""); in ZSTD_initCStream_advanced()
16839 size_t ZSTD_initCStream_usingDict(ZSTD_CStream* zcs, const void* dict, size_t dictSize, int compres… in ZSTD_initCStream_usingDict() argument
16842 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_initCStream_usingDict()
16843 FORWARD_IF_ERROR( ZSTD_CCtx_setParameter(zcs, ZSTD_c_compressionLevel, compressionLevel) , ""); in ZSTD_initCStream_usingDict()
16844 FORWARD_IF_ERROR( ZSTD_CCtx_loadDictionary(zcs, dict, dictSize) , ""); in ZSTD_initCStream_usingDict()
16848 size_t ZSTD_initCStream_srcSize(ZSTD_CStream* zcs, int compressionLevel, unsigned long long pss) in ZSTD_initCStream_srcSize() argument
16856 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_initCStream_srcSize()
16857 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, NULL) , ""); in ZSTD_initCStream_srcSize()
16858 FORWARD_IF_ERROR( ZSTD_CCtx_setParameter(zcs, ZSTD_c_compressionLevel, compressionLevel) , ""); in ZSTD_initCStream_srcSize()
16859 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , ""); in ZSTD_initCStream_srcSize()
16863 size_t ZSTD_initCStream(ZSTD_CStream* zcs, int compressionLevel) in ZSTD_initCStream() argument
16866 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , ""); in ZSTD_initCStream()
16867 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, NULL) , ""); in ZSTD_initCStream()
16868 FORWARD_IF_ERROR( ZSTD_CCtx_setParameter(zcs, ZSTD_c_compressionLevel, compressionLevel) , ""); in ZSTD_initCStream()
16885 static size_t ZSTD_compressStream_generic(ZSTD_CStream* zcs, in ZSTD_compressStream_generic() argument
16900 assert(zcs->inBuff != NULL); in ZSTD_compressStream_generic()
16901 assert(zcs->inBuffSize > 0); in ZSTD_compressStream_generic()
16902 assert(zcs->outBuff != NULL); in ZSTD_compressStream_generic()
16903 assert(zcs->outBuffSize > 0); in ZSTD_compressStream_generic()
16908 switch(zcs->streamStage) in ZSTD_compressStream_generic()
16916 && (zcs->inBuffPos == 0) ) { in ZSTD_compressStream_generic()
16918 size_t const cSize = ZSTD_compressEnd(zcs, in ZSTD_compressStream_generic()
16924 zcs->frameEnded = 1; in ZSTD_compressStream_generic()
16925 ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only); in ZSTD_compressStream_generic()
16929 { size_t const toLoad = zcs->inBuffTarget - zcs->inBuffPos; in ZSTD_compressStream_generic()
16931 zcs->inBuff + zcs->inBuffPos, toLoad, in ZSTD_compressStream_generic()
16933 zcs->inBuffPos += loaded; in ZSTD_compressStream_generic()
16937 && (zcs->inBuffPos < zcs->inBuffTarget) ) { in ZSTD_compressStream_generic()
16942 && (zcs->inBuffPos == zcs->inToCompress) ) { in ZSTD_compressStream_generic()
16951 size_t const iSize = zcs->inBuffPos - zcs->inToCompress; in ZSTD_compressStream_generic()
16957 cDst = zcs->outBuff, oSize = zcs->outBuffSize; in ZSTD_compressStream_generic()
16959 ZSTD_compressEnd(zcs, cDst, oSize, in ZSTD_compressStream_generic()
16960 zcs->inBuff + zcs->inToCompress, iSize) : in ZSTD_compressStream_generic()
16961 ZSTD_compressContinue(zcs, cDst, oSize, in ZSTD_compressStream_generic()
16962 zcs->inBuff + zcs->inToCompress, iSize); in ZSTD_compressStream_generic()
16964 zcs->frameEnded = lastBlock; in ZSTD_compressStream_generic()
16966 zcs->inBuffTarget = zcs->inBuffPos + zcs->blockSize; in ZSTD_compressStream_generic()
16967 if (zcs->inBuffTarget > zcs->inBuffSize) in ZSTD_compressStream_generic()
16968 zcs->inBuffPos = 0, zcs->inBuffTarget = zcs->blockSize; in ZSTD_compressStream_generic()
16970 (unsigned)zcs->inBuffTarget, (unsigned)zcs->inBuffSize); in ZSTD_compressStream_generic()
16972 assert(zcs->inBuffTarget <= zcs->inBuffSize); in ZSTD_compressStream_generic()
16973 zcs->inToCompress = zcs->inBuffPos; in ZSTD_compressStream_generic()
16976 if (zcs->frameEnded) { in ZSTD_compressStream_generic()
16979 ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only); in ZSTD_compressStream_generic()
16983 zcs->outBuffContentSize = cSize; in ZSTD_compressStream_generic()
16984 zcs->outBuffFlushedSize = 0; in ZSTD_compressStream_generic()
16985 zcs->streamStage = zcss_flush; /* pass-through to flush stage */ in ZSTD_compressStream_generic()
16990 { size_t const toFlush = zcs->outBuffContentSize - zcs->outBuffFlushedSize; in ZSTD_compressStream_generic()
16992 zcs->outBuff + zcs->outBuffFlushedSize, toFlush); in ZSTD_compressStream_generic()
16997 zcs->outBuffFlushedSize += flushed; in ZSTD_compressStream_generic()
17004 zcs->outBuffContentSize = zcs->outBuffFlushedSize = 0; in ZSTD_compressStream_generic()
17005 if (zcs->frameEnded) { in ZSTD_compressStream_generic()
17008 ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only); in ZSTD_compressStream_generic()
17011 zcs->streamStage = zcss_load; in ZSTD_compressStream_generic()
17022 if (zcs->frameEnded) return 0; in ZSTD_compressStream_generic()
17023 return ZSTD_nextInputSizeHint(zcs); in ZSTD_compressStream_generic()
17038 size_t ZSTD_compressStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output, ZSTD_inBuffer* input) in ZSTD_compressStream() argument
17040 FORWARD_IF_ERROR( ZSTD_compressStream2(zcs, output, input, ZSTD_e_continue) , ""); in ZSTD_compressStream()
17041 return ZSTD_nextInputSizeHint_MTorST(zcs); in ZSTD_compressStream()
17172 size_t ZSTD_flushStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output) in ZSTD_flushStream() argument
17175 return ZSTD_compressStream2(zcs, output, &input, ZSTD_e_flush); in ZSTD_flushStream()
17179 size_t ZSTD_endStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output) in ZSTD_endStream() argument
17182 size_t const remainingToFlush = ZSTD_compressStream2(zcs, output, &input, ZSTD_e_end); in ZSTD_endStream()
17184 if (zcs->appliedParams.nbWorkers > 0) return remainingToFlush; /* minimal estimation */ in ZSTD_endStream()
17186 { size_t const lastBlockSize = zcs->frameEnded ? 0 : ZSTD_BLOCKHEADERSIZE; in ZSTD_endStream()
17187 …size_t const checksumSize = (size_t)(zcs->frameEnded ? 0 : zcs->appliedParams.fParams.checksumFlag… in ZSTD_endStream()