lib/compress/zstdmt_compress.c

798     size_t filled;
993     mtctx->inBuff.filled = 0;
1085     fps.ingested = mtctx->consumed + mtctx->inBuff.filled;
1313     mtctx->inBuff.filled = 0;
1368         assert(mtctx->inBuff.filled >= srcSize);
1389         mtctx->inBuff.filled = 0;
1516     if (mtctx->inBuff.filled > 0) return 1;   /* input is not empty, and still needs to be converted into a job */
1621  * Returns non-zero if the buffer is filled.
1672     mtctx->inBuff.filled = 0;
1700     syncPoint.toLoad = MIN(input.size - input.pos, mtctx->targetSectionSize - mtctx->inBuff.filled);
1705     if (mtctx->inBuff.filled + input.size - input.pos < RSYNC_MIN_BLOCK_SIZE)
1710     if (mtctx->inBuff.filled + syncPoint.toLoad < RSYNC_LENGTH)
1720     if (mtctx->inBuff.filled < RSYNC_MIN_BLOCK_SIZE) {
1725         pos = RSYNC_MIN_BLOCK_SIZE - mtctx->inBuff.filled;
1730             assert(mtctx->inBuff.filled >= RSYNC_LENGTH);
1731             prev = (BYTE const*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled - RSYNC_LENGTH;
1740         assert(mtctx->inBuff.filled >= RSYNC_MIN_BLOCK_SIZE);
1743         prev = (BYTE const*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled - RSYNC_LENGTH;
1768         assert(mtctx->inBuff.filled + pos >= RSYNC_MIN_BLOCK_SIZE);
1780     size_t hintInSize = mtctx->targetSectionSize - mtctx->inBuff.filled;
1809             assert(mtctx->inBuff.filled == 0); /* Can't fill an empty buffer */
1826                         (U32)syncPoint.toLoad, (U32)mtctx->inBuff.filled, (U32)mtctx->targetSectionSize);
1827             ZSTD_memcpy((char*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled, (const char*)input->src + input->pos, syncPoint.toLoad);
1829             mtctx->inBuff.filled += syncPoint.toLoad;
1837             * - We filled the input buffer: flush this job but don't end the frame.
1840         assert(mtctx->inBuff.filled == 0 || mtctx->inBuff.filled == mtctx->targetSectionSize || mtctx->params.rsyncable);
1845       || (mtctx->inBuff.filled >= mtctx->targetSectionSize)  /* filled enough : let's compress */
1846       || ((endOp != ZSTD_e_continue) && (mtctx->inBuff.filled > 0))  /* something to flush : let's go */
1848         size_t const jobSize = mtctx->inBuff.filled;
1849         assert(mtctx->inBuff.filled <= mtctx->targetSectionSize);