Home | History | Annotate | Download | only in compress

Lines Matching defs:inBuff

840   size_t pos;       /* The position of the current inBuff in the round
841                      * buffer. Updated past the end if the inBuff once
842                      * the inBuff is sent to the worker thread.
876     InBuff_t inBuff;
1024     mtctx->inBuff.buffer = g_nullBuffer;
1025     mtctx->inBuff.filled = 0;
1117     fps.ingested = mtctx->consumed + mtctx->inBuff.filled;
1311     DEBUGLOG(4, "inBuff Size : %u KB", (U32)(mtctx->targetSectionSize>>10));
1341     mtctx->inBuff.buffer = g_nullBuffer;
1342     mtctx->inBuff.filled = 0;
1343     mtctx->inBuff.prefix = kNullRange;
1357             mtctx->inBuff.prefix.start = (const BYTE*)dict;
1358             mtctx->inBuff.prefix.size = dictSize;
1415         BYTE const* src = (BYTE const*)mtctx->inBuff.buffer.start;
1417                     mtctx->nextJobID, (U32)srcSize, (U32)mtctx->inBuff.prefix.size);
1420         assert(mtctx->inBuff.filled >= srcSize);
1421         mtctx->jobs[jobID].prefix = mtctx->inBuff.prefix;
1440         mtctx->inBuff.buffer = g_nullBuffer;
1441         mtctx->inBuff.filled = 0;
1445             mtctx->inBuff.prefix.start = src + srcSize - newPrefixSize;
1446             mtctx->inBuff.prefix.size = newPrefixSize;
1448             mtctx->inBuff.prefix = kNullRange;
1568     if (mtctx->inBuff.filled > 0) return 1;   /* input is not empty, and still needs to be converted into a job */
1676  * Attempts to set the inBuff to the next section to fill.
1688     assert(mtctx->inBuff.buffer.start == NULL);
1696         size_t const prefixSize = mtctx->inBuff.prefix.size;
1705         ZSTD_memmove(start, mtctx->inBuff.prefix.start, prefixSize);
1706         mtctx->inBuff.prefix.start = start;
1716     assert(!ZSTDMT_isOverlapped(buffer, mtctx->inBuff.prefix));
1721                 (size_t)mtctx->inBuff.prefix.start,
1722                 (size_t)mtctx->inBuff.prefix.start + mtctx->inBuff.prefix.size);
1728     mtctx->inBuff.buffer = buffer;
1729     mtctx->inBuff.filled = 0;
1757     syncPoint.toLoad = MIN(input.size - input.pos, mtctx->targetSectionSize - mtctx->inBuff.filled);
1762     if (mtctx->inBuff.filled + input.size - input.pos < RSYNC_MIN_BLOCK_SIZE)
1767     if (mtctx->inBuff.filled + syncPoint.toLoad < RSYNC_LENGTH)
1777     if (mtctx->inBuff.filled < RSYNC_MIN_BLOCK_SIZE) {
1782         pos = RSYNC_MIN_BLOCK_SIZE - mtctx->inBuff.filled;
1787             assert(mtctx->inBuff.filled >= RSYNC_LENGTH);
1788             prev = (BYTE const*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled - RSYNC_LENGTH;
1797         assert(mtctx->inBuff.filled >= RSYNC_MIN_BLOCK_SIZE);
1800         prev = (BYTE const*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled - RSYNC_LENGTH;
1830         assert(mtctx->inBuff.filled + pos >= RSYNC_MIN_BLOCK_SIZE);
1844     size_t hintInSize = mtctx->targetSectionSize - mtctx->inBuff.filled;
1872         if (mtctx->inBuff.buffer.start == NULL) {
1873             assert(mtctx->inBuff.filled == 0); /* Can't fill an empty buffer */
1881                 DEBUGLOG(5, "ZSTDMT_tryGetInputRange completed successfully : mtctx->inBuff.buffer.start = %p", mtctx->inBuff.buffer.start);
1883         if (mtctx->inBuff.buffer.start != NULL) {
1888             assert(mtctx->inBuff.buffer.capacity >= mtctx->targetSectionSize);
1890                         (U32)syncPoint.toLoad, (U32)mtctx->inBuff.filled, (U32)mtctx->targetSectionSize);
1891             ZSTD_memcpy((char*)mtctx->inBuff.buffer.start + mtctx->inBuff.filled, (const char*)input->src + input->pos, syncPoint.toLoad);
1893             mtctx->inBuff.filled += syncPoint.toLoad;
1900             * - mtctx->inBuff is NULL & empty: we couldn't get an input buffer so don't create a new job.
1904         assert(mtctx->inBuff.filled == 0 || mtctx->inBuff.filled == mtctx->targetSectionSize || mtctx->params.rsyncable);
1909       || (mtctx->inBuff.filled >= mtctx->targetSectionSize)  /* filled enough : let's compress */
1910       || ((endOp != ZSTD_e_continue) && (mtctx->inBuff.filled > 0))  /* something to flush : let's go */
1912         size_t const jobSize = mtctx->inBuff.filled;
1913         assert(mtctx->inBuff.filled <= mtctx->targetSectionSize);