844     inBuff_t inBuff;  member
992     mtctx->inBuff.buffer = g_nullBuffer;  in ZSTDMT_releaseAllJobResources()
993     mtctx->inBuff.filled = 0;  in ZSTDMT_releaseAllJobResources()
1085     fps.ingested = mtctx->consumed + mtctx->inBuff.filled;  in ZSTDMT_getFrameProgression()
1312     mtctx->inBuff.buffer = g_nullBuffer;  in ZSTDMT_initCStream_internal()
1313     mtctx->inBuff.filled = 0;  in ZSTDMT_initCStream_internal()
1314     mtctx->inBuff.prefix = kNullRange;  in ZSTDMT_initCStream_internal()
1363         BYTE const* src = (BYTE const*)mtctx->inBuff.buffer.start;  in ZSTDMT_createCompressionJob()
1365                     mtctx->nextJobID, (U32)srcSize, (U32)mtctx->inBuff.prefix.size);  in ZSTDMT_createCompressionJob()
1368         assert(mtctx->inBuff.filled >= srcSize);  in ZSTDMT_createCompressionJob()
1369         mtctx->jobs[jobID].prefix = mtctx->inBuff.prefix;  in ZSTDMT_createCompressionJob()
1388         mtctx->inBuff.buffer = g_nullBuffer;  in ZSTDMT_createCompressionJob()
1389         mtctx->inBuff.filled = 0;  in ZSTDMT_createCompressionJob()
1393             mtctx->inBuff.prefix.start = src + srcSize - newPrefixSize;  in ZSTDMT_createCompressionJob()
1394             mtctx->inBuff.prefix.size = newPrefixSize;  in ZSTDMT_createCompressionJob()
1396             mtctx->inBuff.prefix = kNullRange;  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()
1631     assert(mtctx->inBuff.buffer.start == NULL);  in ZSTDMT_tryGetInputRange()
1639         size_t const prefixSize = mtctx->inBuff.prefix.size;  in ZSTDMT_tryGetInputRange()
1648         ZSTD_memmove(start, mtctx->inBuff.prefix.start, prefixSize);  in ZSTDMT_tryGetInputRange()
1649         mtctx->inBuff.prefix.start = start;  in ZSTDMT_tryGetInputRange()
1659     assert(!ZSTDMT_isOverlapped(buffer, mtctx->inBuff.prefix));  in ZSTDMT_tryGetInputRange()
1664                 (size_t)mtctx->inBuff.prefix.start,  in ZSTDMT_tryGetInputRange()
1665                 (size_t)mtctx->inBuff.prefix.start + mtctx->inBuff.prefix.size);  in ZSTDMT_tryGetInputRange()
1671     mtctx->inBuff.buffer = buffer;  in ZSTDMT_tryGetInputRange()
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()
1808         if (mtctx->inBuff.buffer.start == NULL) {  in ZSTDMT_compressStream_generic()
1809             assert(mtctx->inBuff.filled == 0); /* Can't fill an empty buffer */  in ZSTDMT_compressStream_generic()
1817 …tInputRange completed successfully : mtctx->inBuff.buffer.start = %p", mtctx->inBuff.buffer.start);  in ZSTDMT_compressStream_generic()
1819         if (mtctx->inBuff.buffer.start != NULL) {  in ZSTDMT_compressStream_generic()
1824             assert(mtctx->inBuff.buffer.capacity >= mtctx->targetSectionSize);  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()