Lines Matching refs:filled
798 size_t filled; member
993 mtctx->inBuff.filled = 0; in ZSTDMT_releaseAllJobResources()
1085 fps.ingested = mtctx->consumed + mtctx->inBuff.filled; in ZSTDMT_getFrameProgression()
1313 mtctx->inBuff.filled = 0; in ZSTDMT_initCStream_internal()
1368 assert(mtctx->inBuff.filled >= srcSize); in ZSTDMT_createCompressionJob()
1389 mtctx->inBuff.filled = 0; in ZSTDMT_createCompressionJob()
1516 …if (mtctx->inBuff.filled > 0) return 1; /* input is not empty, and still needs to be converted i… in ZSTDMT_flushProduced()
1672 mtctx->inBuff.filled = 0; in ZSTDMT_tryGetInputRange()
1700 syncPoint.toLoad = MIN(input.size - input.pos, mtctx->targetSectionSize - mtctx->inBuff.filled); in findSynchronizationPoint()
1705 if (mtctx->inBuff.filled + input.size - input.pos < RSYNC_MIN_BLOCK_SIZE) in findSynchronizationPoint()
1710 if (mtctx->inBuff.filled + syncPoint.toLoad < RSYNC_LENGTH) in findSynchronizationPoint()
1720 if (mtctx->inBuff.filled < RSYNC_MIN_BLOCK_SIZE) { in findSynchronizationPoint()
1725 pos = RSYNC_MIN_BLOCK_SIZE - mtctx->inBuff.filled; in findSynchronizationPoint()
1730 assert(mtctx->inBuff.filled >= RSYNC_LENGTH); in findSynchronizationPoint()
1731 prev = (BYTE const*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled - RSYNC_LENGTH; in findSynchronizationPoint()
1740 assert(mtctx->inBuff.filled >= RSYNC_MIN_BLOCK_SIZE); in findSynchronizationPoint()
1743 prev = (BYTE const*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled - RSYNC_LENGTH; in findSynchronizationPoint()
1768 assert(mtctx->inBuff.filled + pos >= RSYNC_MIN_BLOCK_SIZE); in findSynchronizationPoint()
1780 size_t hintInSize = mtctx->targetSectionSize - mtctx->inBuff.filled; in ZSTDMT_nextInputSizeHint()
1809 assert(mtctx->inBuff.filled == 0); /* Can't fill an empty buffer */ in ZSTDMT_compressStream_generic()
1826 … (U32)syncPoint.toLoad, (U32)mtctx->inBuff.filled, (U32)mtctx->targetSectionSize); in ZSTDMT_compressStream_generic()
1827 …ZSTD_memcpy((char*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled, (const char*)input->src + in… in ZSTDMT_compressStream_generic()
1829 mtctx->inBuff.filled += syncPoint.toLoad; in ZSTDMT_compressStream_generic()
1840 …assert(mtctx->inBuff.filled == 0 || mtctx->inBuff.filled == mtctx->targetSectionSize || mtctx->par… in ZSTDMT_compressStream_generic()
1845 || (mtctx->inBuff.filled >= mtctx->targetSectionSize) /* filled enough : let's compress */ in ZSTDMT_compressStream_generic()
1846 … || ((endOp != ZSTD_e_continue) && (mtctx->inBuff.filled > 0)) /* something to flush : let's go */ in ZSTDMT_compressStream_generic()
1848 size_t const jobSize = mtctx->inBuff.filled; in ZSTDMT_compressStream_generic()
1849 assert(mtctx->inBuff.filled <= mtctx->targetSectionSize); in ZSTDMT_compressStream_generic()