Home
last modified time | relevance | path

Searched refs:dstFlushed (Results 1 – 1 of 1) sorted by relevance

/dragonfly/contrib/zstd/lib/compress/
H A Dzstdmt_compress.c649 size_t dstFlushed; /* used only by mtctx */ member
1072 size_t const flushed = ZSTD_isError(cResult) ? 0 : jobPtr->dstFlushed; in ZSTDMT_getFrameProgression()
1100 size_t const flushed = ZSTD_isError(cResult) ? 0 : jobPtr->dstFlushed; in ZSTDMT_toFlushNow()
1354 mtctx->jobs[jobID].dstFlushed = 0; in ZSTDMT_createCompressionJob()
1416 assert(mtctx->jobs[wJobID].dstFlushed <= mtctx->jobs[wJobID].cSize); in ZSTDMT_flushProduced()
1417 … while (mtctx->jobs[wJobID].dstFlushed == mtctx->jobs[wJobID].cSize) { /* nothing to flush */ in ZSTDMT_flushProduced()
1424 mtctx->doneJobID, (U32)mtctx->jobs[wJobID].dstFlushed); in ZSTDMT_flushProduced()
1457 assert(cSize >= mtctx->jobs[wJobID].dstFlushed); in ZSTDMT_flushProduced()
1461 (const char*)mtctx->jobs[wJobID].dstBuff.start + mtctx->jobs[wJobID].dstFlushed, in ZSTDMT_flushProduced()
1470 mtctx->doneJobID, (U32)mtctx->jobs[wJobID].dstFlushed); in ZSTDMT_flushProduced()
[all …]