816     inBuff_t inBuff;  member
964     mtctx->inBuff.buffer = g_nullBuffer;  in ZSTDMT_releaseAllJobResources()
965     mtctx->inBuff.filled = 0;  in ZSTDMT_releaseAllJobResources()
1057     fps.ingested = mtctx->consumed + mtctx->inBuff.filled;  in ZSTDMT_getFrameProgression()
1282     mtctx->inBuff.buffer = g_nullBuffer;  in ZSTDMT_initCStream_internal()
1283     mtctx->inBuff.filled = 0;  in ZSTDMT_initCStream_internal()
1284     mtctx->inBuff.prefix = kNullRange;  in ZSTDMT_initCStream_internal()
1333         BYTE const* src = (BYTE const*)mtctx->inBuff.buffer.start;  in ZSTDMT_createCompressionJob()
1335                     mtctx->nextJobID, (U32)srcSize, (U32)mtctx->inBuff.prefix.size);  in ZSTDMT_createCompressionJob()
1338         assert(mtctx->inBuff.filled >= srcSize);  in ZSTDMT_createCompressionJob()
1339         mtctx->jobs[jobID].prefix = mtctx->inBuff.prefix;  in ZSTDMT_createCompressionJob()
1358         mtctx->inBuff.buffer = g_nullBuffer;  in ZSTDMT_createCompressionJob()
1359         mtctx->inBuff.filled = 0;  in ZSTDMT_createCompressionJob()
1363             mtctx->inBuff.prefix.start = src + srcSize - newPrefixSize;  in ZSTDMT_createCompressionJob()
1364             mtctx->inBuff.prefix.size = newPrefixSize;  in ZSTDMT_createCompressionJob()
1366             mtctx->inBuff.prefix = kNullRange;  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()
1597     assert(mtctx->inBuff.buffer.start == NULL);  in ZSTDMT_tryGetInputRange()
1605         size_t const prefixSize = mtctx->inBuff.prefix.size;  in ZSTDMT_tryGetInputRange()
1614         ZSTD_memmove(start, mtctx->inBuff.prefix.start, prefixSize);  in ZSTDMT_tryGetInputRange()
1615         mtctx->inBuff.prefix.start = start;  in ZSTDMT_tryGetInputRange()
1625     assert(!ZSTDMT_isOverlapped(buffer, mtctx->inBuff.prefix));  in ZSTDMT_tryGetInputRange()
1630                 (size_t)mtctx->inBuff.prefix.start,  in ZSTDMT_tryGetInputRange()
1631                 (size_t)mtctx->inBuff.prefix.start + mtctx->inBuff.prefix.size);  in ZSTDMT_tryGetInputRange()
1637     mtctx->inBuff.buffer = buffer;  in ZSTDMT_tryGetInputRange()
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()
1705         prev = (BYTE const*)mtctx->inBuff.buffer.start - pos;  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()
1760         if (mtctx->inBuff.buffer.start == NULL) {  in ZSTDMT_compressStream_generic()
1761             assert(mtctx->inBuff.filled == 0); /* Can't fill an empty buffer */  in ZSTDMT_compressStream_generic()
1769 …tInputRange completed successfully : mtctx->inBuff.buffer.start = %p", mtctx->inBuff.buffer.start);  in ZSTDMT_compressStream_generic()
1771         if (mtctx->inBuff.buffer.start != NULL) {  in ZSTDMT_compressStream_generic()
1776             assert(mtctx->inBuff.buffer.capacity >= mtctx->targetSectionSize);  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()