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