Searched refs:srcConsumed (Results 1 – 1 of 1) sorted by relevance
1460 size_t const srcConsumed = mtctx->jobs[wJobID].consumed; /* shared */ in ZSTDMT_flushProduced() local1471 assert(srcConsumed <= srcSize); in ZSTDMT_flushProduced()1472 if ( (srcConsumed == srcSize) /* job completed -> worker no longer active */ in ZSTDMT_flushProduced()1485 (U32)toFlush, mtctx->doneJobID, (U32)srcConsumed, (U32)srcSize, (U32)cSize); in ZSTDMT_flushProduced()1497 if ( (srcConsumed == srcSize) /* job is completed */ in ZSTDMT_flushProduced()1512 if (srcSize > srcConsumed) return 1; /* current job not completely compressed */ in ZSTDMT_flushProduced()