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