Searched refs:toFlush (Results 1 – 2 of 2) sorted by relevance
| /dragonfly/contrib/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 1089 size_t toFlush; in ZSTDMT_toFlushNow() local
1103 toFlush = produced - flushed; in ZSTDMT_toFlushNow()
1109 if (toFlush==0) { in ZSTDMT_toFlushNow()
1116 return toFlush; in ZSTDMT_toFlushNow()
1453 … size_t const toFlush = MIN(cSize - mtctx->jobs[wJobID].dstFlushed, output->size - output->pos); in ZSTDMT_flushProduced() local
1455 (U32)toFlush, mtctx->doneJobID, (U32)srcConsumed, (U32)srcSize, (U32)cSize); in ZSTDMT_flushProduced()
1459 if (toFlush > 0) { in ZSTDMT_flushProduced()
1462 toFlush); in ZSTDMT_flushProduced()
1464 output->pos += toFlush; in ZSTDMT_flushProduced()
1465 … mtctx->jobs[wJobID].dstFlushed += toFlush; /* can write : this value is only used by mtctx */ in ZSTDMT_flushProduced()
|
| H A D | zstd_compress.c | 4256 { size_t const toFlush = zcs->outBuffContentSize - zcs->outBuffFlushedSize; in ZSTD_compressStream_generic() local
4258 zcs->outBuff + zcs->outBuffFlushedSize, toFlush); in ZSTD_compressStream_generic()
4260 (unsigned)toFlush, (unsigned)(oend-op), (unsigned)flushed); in ZSTD_compressStream_generic()
4264 if (toFlush!=flushed) { in ZSTD_compressStream_generic()
4958 size_t const toFlush = remainingToFlush + lastBlockSize + checksumSize; in ZSTD_endStream() local
4959 DEBUGLOG(4, "ZSTD_endStream : remaining to flush : %u", (unsigned)toFlush); in ZSTD_endStream()
4960 return toFlush; in ZSTD_endStream()
|