Searched refs:flushMin (Results 1 – 2 of 2) sorted by relevance
4444 size_t flushMin; in ZSTD_compressStream2() local4452 flushMin = ZSTDMT_compressStream_generic(cctx->mtctx, output, input, endOp); in ZSTD_compressStream2()4453 if ( ZSTD_isError(flushMin) in ZSTD_compressStream2()4454 || (endOp == ZSTD_e_end && flushMin == 0) ) { /* compression completed */ in ZSTD_compressStream2()4457 FORWARD_IF_ERROR(flushMin, "ZSTDMT_compressStream_generic failed"); in ZSTD_compressStream2()4471 if (flushMin == 0 || output->pos == output->size) in ZSTD_compressStream2()4479 assert(endOp == ZSTD_e_continue || flushMin == 0 || output->pos == output->size); in ZSTD_compressStream2()4481 return flushMin; in ZSTD_compressStream2()
17106 size_t flushMin; in ZSTD_compressStream2() local17113 flushMin = ZSTDMT_compressStream_generic(cctx->mtctx, output, input, endOp); in ZSTD_compressStream2()17114 if ( ZSTD_isError(flushMin) in ZSTD_compressStream2()17115 || (endOp == ZSTD_e_end && flushMin == 0) ) { /* compression completed */ in ZSTD_compressStream2()17118 FORWARD_IF_ERROR(flushMin, "ZSTDMT_compressStream_generic failed"); in ZSTD_compressStream2()17119 } while (forceMaxProgress && flushMin != 0 && output->pos < output->size); in ZSTD_compressStream2()17124 assert(!forceMaxProgress || flushMin == 0 || output->pos == output->size); in ZSTD_compressStream2()17125 return flushMin; in ZSTD_compressStream2()