Lines Matching defs:endOp
1391 static size_t ZSTDMT_createCompressionJob(ZSTDMT_CCtx* mtctx, size_t srcSize, ZSTD_EndDirective endOp)
1394 int const endFrame = (endOp == ZSTD_e_end);
1446 assert(endOp == ZSTD_e_end); /* only possible case : need to end the frame with an empty last block */
1712 ZSTD_EndDirective endOp)
1715 DEBUGLOG(5, "ZSTDMT_compressStream_generic (endOp=%u, srcSize=%u)",
1716 (U32)endOp, (U32)(input->size - input->pos));
1721 return ZSTD_compressStream_generic(mtctx->cctxPool->cctx[0], output, input, endOp);
1724 if ((mtctx->frameEnded) && (endOp==ZSTD_e_continue)) {
1733 && (endOp == ZSTD_e_end) /* end order */
1769 if ((input->pos < input->size) && (endOp == ZSTD_e_end))
1770 endOp = ZSTD_e_flush; /* can't end now : not all input consumed */
1775 || ((endOp != ZSTD_e_continue) && (mtctx->inBuff.filled > 0)) /* something to flush : let's go */
1776 || ((endOp == ZSTD_e_end) && (!mtctx->frameEnded)) ) { /* must finish the frame with a zero-size block */
1779 CHECK_F( ZSTDMT_createCompressionJob(mtctx, jobSize, endOp) );
1783 { size_t const remainingToFlush = ZSTDMT_flushProduced(mtctx, output, !forwardInputProgress, endOp); /* block if there was no forward input progress */