1351 …tic size_t ZSTDMT_createCompressionJob(ZSTDMT_CCtx* mtctx, size_t srcSize, ZSTD_EndDirective endOp)  in ZSTDMT_createCompressionJob()  argument
1354     int const endFrame = (endOp == ZSTD_e_end);  in ZSTDMT_createCompressionJob()
1406 …assert(endOp == ZSTD_e_end);  /* only possible case : need to end the frame with an empty last blo…  in ZSTDMT_createCompressionJob()
1792                                      ZSTD_EndDirective endOp)  in ZSTDMT_compressStream_generic()  argument
1796                 (U32)endOp, (U32)(input->size - input->pos));  in ZSTDMT_compressStream_generic()
1800     if ((mtctx->frameEnded) && (endOp==ZSTD_e_continue)) {  in ZSTDMT_compressStream_generic()
1821             if (syncPoint.flush && endOp == ZSTD_e_continue) {  in ZSTDMT_compressStream_generic()
1822                 endOp = ZSTD_e_flush;  in ZSTDMT_compressStream_generic()
1833     if ((input->pos < input->size) && (endOp == ZSTD_e_end)) {  in ZSTDMT_compressStream_generic()
1841         endOp = ZSTD_e_flush;  in ZSTDMT_compressStream_generic()
1846 … || ((endOp != ZSTD_e_continue) && (mtctx->inBuff.filled > 0))  /* something to flush : let's go */  in ZSTDMT_compressStream_generic()
1847 …|| ((endOp == ZSTD_e_end) && (!mtctx->frameEnded)) ) {   /* must finish the frame with a zero-size…  in ZSTDMT_compressStream_generic()
1850         FORWARD_IF_ERROR( ZSTDMT_createCompressionJob(mtctx, jobSize, endOp) , "");  in ZSTDMT_compressStream_generic()
1854 …iningToFlush = ZSTDMT_flushProduced(mtctx, output, !forwardInputProgress, endOp); /* block if ther…  in ZSTDMT_compressStream_generic()