Lines Matching full:flushed

264 /* We need 2 output buffers per worker since each dstBuff must be flushed after it is released.
750 … ZSTD_pthread_cond_signal(&job->job_cond); /* warns some more data is ready to be flushed */ in ZSTDMT_compressionJob()
1087 fps.produced = fps.flushed = mtctx->produced; in ZSTDMT_getFrameProgression()
1100 size_t const flushed = ZSTD_isError(cResult) ? 0 : jobPtr->dstFlushed; in ZSTDMT_getFrameProgression() local
1101 assert(flushed <= produced); in ZSTDMT_getFrameProgression()
1105 fps.flushed += flushed; in ZSTDMT_getFrameProgression()
1122 /* look into oldest non-fully-flushed job */ in ZSTDMT_toFlushNow()
1128 size_t const flushed = ZSTD_isError(cResult) ? 0 : jobPtr->dstFlushed; in ZSTDMT_toFlushNow() local
1129 assert(flushed <= produced); in ZSTDMT_toFlushNow()
1131 toFlush = produced - flushed; in ZSTDMT_toFlushNow()
1134 * if jobID was already completed and fully flushed, in ZSTDMT_toFlushNow()
1431 * flush whatever data has been produced but not yet flushed in current job.
1432 * move to next job if current one is fully flushed.
1433 * `output` : `pos` will be updated with amount of data flushed .
1453 DEBUGLOG(5, "waiting for something to flush from job %u (currently flushed: %u bytes)", in ZSTDMT_flushProduced()
1498 …&& (mtctx->jobs[wJobID].dstFlushed == cSize) ) { /* output buffer fully flushed => free this job… in ZSTDMT_flushProduced()
1517 …mtctx->allJobsCompleted = mtctx->frameEnded; /* all jobs are entirely flushed => if this one is … in ZSTDMT_flushProduced()
1518 …e_end, question becomes : is frame completed ? instead of : are internal buffers fully flushed ? */ in ZSTDMT_flushProduced()
1519 return 0; /* internal buffers fully flushed */ in ZSTDMT_flushProduced()
1853 /* check for potential compressed data ready to be flushed */ in ZSTDMT_compressStream_generic()