Lines Matching refs:filled
779 size_t filled; member
965 mtctx->inBuff.filled = 0; in ZSTDMT_releaseAllJobResources()
1057 fps.ingested = mtctx->consumed + mtctx->inBuff.filled; in ZSTDMT_getFrameProgression()
1283 mtctx->inBuff.filled = 0; in ZSTDMT_initCStream_internal()
1338 assert(mtctx->inBuff.filled >= srcSize); in ZSTDMT_createCompressionJob()
1359 mtctx->inBuff.filled = 0; in ZSTDMT_createCompressionJob()
1486 …if (mtctx->inBuff.filled > 0) return 1; /* input is not empty, and still needs to be converted i… in ZSTDMT_flushProduced()
1638 mtctx->inBuff.filled = 0; in ZSTDMT_tryGetInputRange()
1666 syncPoint.toLoad = MIN(input.size - input.pos, mtctx->targetSectionSize - mtctx->inBuff.filled); in findSynchronizationPoint()
1671 if (mtctx->inBuff.filled + syncPoint.toLoad < RSYNC_LENGTH) in findSynchronizationPoint()
1681 if (mtctx->inBuff.filled >= RSYNC_LENGTH) { in findSynchronizationPoint()
1686 prev = (BYTE const*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled - RSYNC_LENGTH; in findSynchronizationPoint()
1704 pos = RSYNC_LENGTH - mtctx->inBuff.filled; in findSynchronizationPoint()
1706 hash = ZSTD_rollingHash_compute(mtctx->inBuff.buffer.start, mtctx->inBuff.filled); in findSynchronizationPoint()
1732 size_t hintInSize = mtctx->targetSectionSize - mtctx->inBuff.filled; in ZSTDMT_nextInputSizeHint()
1761 assert(mtctx->inBuff.filled == 0); /* Can't fill an empty buffer */ in ZSTDMT_compressStream_generic()
1778 … (U32)syncPoint.toLoad, (U32)mtctx->inBuff.filled, (U32)mtctx->targetSectionSize); in ZSTDMT_compressStream_generic()
1779 …ZSTD_memcpy((char*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled, (const char*)input->src + in… in ZSTDMT_compressStream_generic()
1781 mtctx->inBuff.filled += syncPoint.toLoad; in ZSTDMT_compressStream_generic()
1792 …assert(mtctx->inBuff.filled == 0 || mtctx->inBuff.filled == mtctx->targetSectionSize || mtctx->par… in ZSTDMT_compressStream_generic()
1797 || (mtctx->inBuff.filled >= mtctx->targetSectionSize) /* filled enough : let's compress */ in ZSTDMT_compressStream_generic()
1798 … || ((endOp != ZSTD_e_continue) && (mtctx->inBuff.filled > 0)) /* something to flush : let's go */ in ZSTDMT_compressStream_generic()
1800 size_t const jobSize = mtctx->inBuff.filled; in ZSTDMT_compressStream_generic()
1801 assert(mtctx->inBuff.filled <= mtctx->targetSectionSize); in ZSTDMT_compressStream_generic()