638 …size_t   consumed;                   /* SHARED - set0 by mtctx, then modified by worker AND read b…  member
747             job->consumed = chunkSize * chunkNb;  in ZSTDMT_compressionJob()
785 …job->consumed = job->src.size;  /* when job->consumed == job->src.size , compression job is presum…  in ZSTDMT_compressionJob()
854     unsigned long long consumed;  member
1003         while (mtctx->jobs[jobID].consumed < mtctx->jobs[jobID].src.size) {  in ZSTDMT_waitForAllJobsCompleted()
1078  * tells how much data has been consumed (input) and produced (output) for current frame.
1085     fps.ingested = mtctx->consumed + mtctx->inBuff.filled;  in ZSTDMT_getFrameProgression()
1086     fps.consumed = mtctx->consumed;  in ZSTDMT_getFrameProgression()
1103                 fps.consumed += jobPtr->consumed;  in ZSTDMT_getFrameProgression()
1106                 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size);  in ZSTDMT_getFrameProgression()
1130             assert(jobPtr->consumed <= jobPtr->src.size);  in ZSTDMT_toFlushNow()
1136              * Therefore, some input has not yet been consumed. */  in ZSTDMT_toFlushNow()
1138                 assert(jobPtr->consumed < jobPtr->src.size);  in ZSTDMT_toFlushNow()
1319     mtctx->consumed = 0;  in ZSTDMT_initCStream_internal()
1348     assert(job->consumed == 0);  in ZSTDMT_writeLastEmptyBlock()
1370         mtctx->jobs[jobID].consumed = 0;  in ZSTDMT_createCompressionJob()
1448             if (mtctx->jobs[wJobID].consumed == mtctx->jobs[wJobID].src.size) {  in ZSTDMT_flushProduced()
1449 … DEBUGLOG(5, "job %u is completely consumed (%u == %u) => don't wait for cond, there will be none",  in ZSTDMT_flushProduced()
1450 …           mtctx->doneJobID, (U32)mtctx->jobs[wJobID].consumed, (U32)mtctx->jobs[wJobID].src.size);  in ZSTDMT_flushProduced()
1460         size_t const srcConsumed = mtctx->jobs[wJobID].consumed;   /* shared */  in ZSTDMT_flushProduced()
1505                 mtctx->consumed += srcSize;  in ZSTDMT_flushProduced()
1535         size_t consumed;  in ZSTDMT_getInputDataInUse()  local
1538         consumed = mtctx->jobs[wJobID].consumed;  in ZSTDMT_getInputDataInUse()
1541         if (consumed < mtctx->jobs[wJobID].src.size) {  in ZSTDMT_getInputDataInUse()
1834         /* Can't end yet because the input is not fully consumed.  in ZSTDMT_compressStream_generic()
1855 …if (input->pos < input->size) return MAX(remainingToFlush, 1);  /* input not consumed : do not end…  in ZSTDMT_compressStream_generic()