Lines Matching defs:zcs
202 size_t ZSTD_sizeof_CStream(const ZSTD_CStream* zcs)
204 return ZSTD_sizeof_CCtx(zcs); /* same object */
5053 size_t ZSTD_freeCStream(ZSTD_CStream* zcs)
5055 return ZSTD_freeCCtx(zcs); /* same object */
5079 size_t ZSTD_resetCStream(ZSTD_CStream* zcs, unsigned long long pss)
5087 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5088 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , "");
5096 size_t ZSTD_initCStream_internal(ZSTD_CStream* zcs,
5102 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5103 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , "");
5105 zcs->requestedParams = *params;
5108 FORWARD_IF_ERROR( ZSTD_CCtx_loadDictionary(zcs, dict, dictSize) , "");
5111 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, cdict) , "");
5118 size_t ZSTD_initCStream_usingCDict_advanced(ZSTD_CStream* zcs,
5124 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5125 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , "");
5126 zcs->requestedParams.fParams = fParams;
5127 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, cdict) , "");
5132 size_t ZSTD_initCStream_usingCDict(ZSTD_CStream* zcs, const ZSTD_CDict* cdict)
5135 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5136 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, cdict) , "");
5145 size_t ZSTD_initCStream_advanced(ZSTD_CStream* zcs,
5155 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5156 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , "");
5158 ZSTD_CCtxParams_setZstdParams(&zcs->requestedParams, ¶ms);
5159 FORWARD_IF_ERROR( ZSTD_CCtx_loadDictionary(zcs, dict, dictSize) , "");
5163 size_t ZSTD_initCStream_usingDict(ZSTD_CStream* zcs, const void* dict, size_t dictSize, int compressionLevel)
5166 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5167 FORWARD_IF_ERROR( ZSTD_CCtx_setParameter(zcs, ZSTD_c_compressionLevel, compressionLevel) , "");
5168 FORWARD_IF_ERROR( ZSTD_CCtx_loadDictionary(zcs, dict, dictSize) , "");
5172 size_t ZSTD_initCStream_srcSize(ZSTD_CStream* zcs, int compressionLevel, unsigned long long pss)
5180 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5181 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, NULL) , "");
5182 FORWARD_IF_ERROR( ZSTD_CCtx_setParameter(zcs, ZSTD_c_compressionLevel, compressionLevel) , "");
5183 FORWARD_IF_ERROR( ZSTD_CCtx_setPledgedSrcSize(zcs, pledgedSrcSize) , "");
5187 size_t ZSTD_initCStream(ZSTD_CStream* zcs, int compressionLevel)
5190 FORWARD_IF_ERROR( ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only) , "");
5191 FORWARD_IF_ERROR( ZSTD_CCtx_refCDict(zcs, NULL) , "");
5192 FORWARD_IF_ERROR( ZSTD_CCtx_setParameter(zcs, ZSTD_c_compressionLevel, compressionLevel) , "");
5209 static size_t ZSTD_compressStream_generic(ZSTD_CStream* zcs,
5224 if (zcs->appliedParams.inBufferMode == ZSTD_bm_buffered) {
5225 assert(zcs->inBuff != NULL);
5226 assert(zcs->inBuffSize > 0);
5228 if (zcs->appliedParams.outBufferMode == ZSTD_bm_buffered) {
5229 assert(zcs->outBuff != NULL);
5230 assert(zcs->outBuffSize > 0);
5237 switch(zcs->streamStage)
5245 || zcs->appliedParams.outBufferMode == ZSTD_bm_stable) /* OR we are allowed to return dstSizeTooSmall */
5246 && (zcs->inBuffPos == 0) ) {
5248 size_t const cSize = ZSTD_compressEnd(zcs,
5254 zcs->frameEnded = 1;
5255 ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only);
5259 if (zcs->appliedParams.inBufferMode == ZSTD_bm_buffered) {
5260 size_t const toLoad = zcs->inBuffTarget - zcs->inBuffPos;
5262 zcs->inBuff + zcs->inBuffPos, toLoad,
5264 zcs->inBuffPos += loaded;
5268 && (zcs->inBuffPos < zcs->inBuffTarget) ) {
5273 && (zcs->inBuffPos == zcs->inToCompress) ) {
5280 { int const inputBuffered = (zcs->appliedParams.inBufferMode == ZSTD_bm_buffered);
5285 ? zcs->inBuffPos - zcs->inToCompress
5286 : MIN((size_t)(iend - ip), zcs->blockSize);
5287 if (oSize >= ZSTD_compressBound(iSize) || zcs->appliedParams.outBufferMode == ZSTD_bm_stable)
5290 cDst = zcs->outBuff, oSize = zcs->outBuffSize;
5294 ZSTD_compressEnd(zcs, cDst, oSize,
5295 zcs->inBuff + zcs->inToCompress, iSize) :
5296 ZSTD_compressContinue(zcs, cDst, oSize,
5297 zcs->inBuff + zcs->inToCompress, iSize);
5299 zcs->frameEnded = lastBlock;
5301 zcs->inBuffTarget = zcs->inBuffPos + zcs->blockSize;
5302 if (zcs->inBuffTarget > zcs->inBuffSize)
5303 zcs->inBuffPos = 0, zcs->inBuffTarget = zcs->blockSize;
5305 (unsigned)zcs->inBuffTarget, (unsigned)zcs->inBuffSize);
5307 assert(zcs->inBuffTarget <= zcs->inBuffSize);
5308 zcs->inToCompress = zcs->inBuffPos;
5313 ZSTD_compressEnd(zcs, cDst, oSize, ip, iSize) :
5314 ZSTD_compressContinue(zcs, cDst, oSize, ip, iSize);
5319 zcs->frameEnded = lastBlock;
5325 if (zcs->frameEnded) {
5328 ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only);
5332 zcs->outBuffContentSize = cSize;
5333 zcs->outBuffFlushedSize = 0;
5334 zcs->streamStage = zcss_flush; /* pass-through to flush stage */
5339 assert(zcs->appliedParams.outBufferMode == ZSTD_bm_buffered);
5340 { size_t const toFlush = zcs->outBuffContentSize - zcs->outBuffFlushedSize;
5342 zcs->outBuff + zcs->outBuffFlushedSize, toFlush);
5347 zcs->outBuffFlushedSize += flushed;
5354 zcs->outBuffContentSize = zcs->outBuffFlushedSize = 0;
5355 if (zcs->frameEnded) {
5358 ZSTD_CCtx_reset(zcs, ZSTD_reset_session_only);
5361 zcs->streamStage = zcss_load;
5372 if (zcs->frameEnded) return 0;
5373 return ZSTD_nextInputSizeHint(zcs);
5382 size_t ZSTD_compressStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output, ZSTD_inBuffer* input)
5384 FORWARD_IF_ERROR( ZSTD_compressStream2(zcs, output, input, ZSTD_e_continue) , "");
5385 return ZSTD_nextInputSizeHint_MTorST(zcs);
5960 size_t ZSTD_flushStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output)
5963 return ZSTD_compressStream2(zcs, output, &input, ZSTD_e_flush);
5967 size_t ZSTD_endStream(ZSTD_CStream* zcs, ZSTD_outBuffer* output)
5970 size_t const remainingToFlush = ZSTD_compressStream2(zcs, output, &input, ZSTD_e_end);
5972 if (zcs->appliedParams.nbWorkers > 0) return remainingToFlush; /* minimal estimation */
5974 { size_t const lastBlockSize = zcs->frameEnded ? 0 : ZSTD_BLOCKHEADERSIZE;
5975 size_t const checksumSize = (size_t)(zcs->frameEnded ? 0 : zcs->appliedParams.fParams.checksumFlag * 4);