lib/zstd/compress/zstd_compress.c

6023

assert((U32)flushMode <= (U32)ZSTD_e_end);

lib/zstd/compress/zstd_compress.c

6032

if ( (flushMode == ZSTD_e_end)

lib/zstd/compress/zstd_compress.c

6094

unsigned const lastBlock = (flushMode == ZSTD_e_end) && (ip==iend);

lib/zstd/compress/zstd_compress.c

6112

unsigned const lastBlock = (flushMode == ZSTD_e_end) && (ip + iSize == iend);

lib/zstd/compress/zstd_compress.c

6246

if (endOp == ZSTD_e_end) cctx->pledgedSrcSizePlusOne = inSize + 1; /* auto-determine pledgedSrcSize */

lib/zstd/compress/zstd_compress.c

6300

RETURN_ERROR_IF((U32)endOp > (U32)ZSTD_e_end, parameter_outOfBound, "invalid endDirective");

lib/zstd/compress/zstd_compress.c

6375

ZSTD_e_end);

lib/zstd/compress/zstd_compress.c

6865

FORWARD_IF_ERROR(ZSTD_CCtx_init_compressStream2(cctx, ZSTD_e_end, srcSize), "CCtx initialization failed");

lib/zstd/compress/zstd_compress.c

7391

FORWARD_IF_ERROR(ZSTD_CCtx_init_compressStream2(cctx, ZSTD_e_end, decompressedSize), "CCtx initialization failed");

lib/zstd/compress/zstd_compress.c

7448

size_t const remainingToFlush = ZSTD_compressStream2(zcs, output, &input, ZSTD_e_end);