Searched refs:flushMin (Results 1 – 2 of 2) sorted by relevance
4022 size_t flushMin; in ZSTD_compressStream2() local4029 flushMin = ZSTDMT_compressStream_generic(cctx->mtctx, output, input, endOp); in ZSTD_compressStream2()4030 if ( ZSTD_isError(flushMin) in ZSTD_compressStream2()4031 || (endOp == ZSTD_e_end && flushMin == 0) ) { /* compression completed */ in ZSTD_compressStream2()4034 FORWARD_IF_ERROR(flushMin, "ZSTDMT_compressStream_generic failed"); in ZSTD_compressStream2()4035 } while (forceMaxProgress && flushMin != 0 && output->pos < output->size); in ZSTD_compressStream2()4040 assert(!forceMaxProgress || flushMin == 0 || output->pos == output->size); in ZSTD_compressStream2()4041 return flushMin; in ZSTD_compressStream2()
5657 size_t flushMin; in ZSTD_compressStream2() local5665 flushMin = ZSTDMT_compressStream_generic(cctx->mtctx, output, input, endOp); in ZSTD_compressStream2()5668 if ( ZSTD_isError(flushMin) in ZSTD_compressStream2()5669 || (endOp == ZSTD_e_end && flushMin == 0) ) { /* compression completed */ in ZSTD_compressStream2()5670 if (flushMin == 0) in ZSTD_compressStream2()5674 FORWARD_IF_ERROR(flushMin, "ZSTDMT_compressStream_generic failed"); in ZSTD_compressStream2()5688 if (flushMin == 0 || output->pos == output->size) in ZSTD_compressStream2()5696 assert(endOp == ZSTD_e_continue || flushMin == 0 || output->pos == output->size); in ZSTD_compressStream2()5698 return flushMin; in ZSTD_compressStream2()