Lines Matching refs:syncPoint

1695     syncPoint_t syncPoint;  in findSynchronizationPoint()  local
1700 syncPoint.toLoad = MIN(input.size - input.pos, mtctx->targetSectionSize - mtctx->inBuff.filled); in findSynchronizationPoint()
1701 syncPoint.flush = 0; in findSynchronizationPoint()
1704 return syncPoint; in findSynchronizationPoint()
1709 return syncPoint; in findSynchronizationPoint()
1710 if (mtctx->inBuff.filled + syncPoint.toLoad < RSYNC_LENGTH) in findSynchronizationPoint()
1718 return syncPoint; in findSynchronizationPoint()
1751 syncPoint.toLoad = 0; in findSynchronizationPoint()
1752 syncPoint.flush = 1; in findSynchronizationPoint()
1753 return syncPoint; in findSynchronizationPoint()
1764 for (; pos < syncPoint.toLoad; ++pos) { in findSynchronizationPoint()
1770 syncPoint.toLoad = pos + 1; in findSynchronizationPoint()
1771 syncPoint.flush = 1; in findSynchronizationPoint()
1775 return syncPoint; in findSynchronizationPoint()
1820 syncPoint_t const syncPoint = findSynchronizationPoint(mtctx, *input); in ZSTDMT_compressStream_generic() local
1821 if (syncPoint.flush && endOp == ZSTD_e_continue) { in ZSTDMT_compressStream_generic()
1826 … (U32)syncPoint.toLoad, (U32)mtctx->inBuff.filled, (U32)mtctx->targetSectionSize); in ZSTDMT_compressStream_generic()
1827 …nBuff.buffer.start + mtctx->inBuff.filled, (const char*)input->src + input->pos, syncPoint.toLoad); in ZSTDMT_compressStream_generic()
1828 input->pos += syncPoint.toLoad; in ZSTDMT_compressStream_generic()
1829 mtctx->inBuff.filled += syncPoint.toLoad; in ZSTDMT_compressStream_generic()
1830 forwardInputProgress = syncPoint.toLoad>0; in ZSTDMT_compressStream_generic()