460     unsigned nextJobID;  member
486     serialState->nextJobID = 0;  in ZSTDMT_serialState_reset()
568     while (serialState->nextJobID < jobID) {  in ZSTDMT_serialState_update()
573     if (serialState->nextJobID == jobID) {  in ZSTDMT_serialState_update()
598     serialState->nextJobID++;  in ZSTDMT_serialState_update()
615     if (serialState->nextJobID <= jobID) {  in ZSTDMT_serialState_ensureFinished()
618         serialState->nextJobID = jobID + 1;  in ZSTDMT_serialState_ensureFinished()
850     unsigned nextJobID;  member
1000     while (mtctx->doneJobID < mtctx->nextJobID) {  in ZSTDMT_waitForAllJobsCompleted()
1088     fps.currentJobID = mtctx->nextJobID;  in ZSTDMT_getFrameProgression()
1091         unsigned lastJobNb = mtctx->nextJobID + mtctx->jobReady; assert(mtctx->jobReady <= 1);  in ZSTDMT_getFrameProgression()
1119     assert(jobID <= mtctx->nextJobID);  in ZSTDMT_toFlushNow()
1120     if (jobID == mtctx->nextJobID) return 0;   /* no active job => nothing to flush */  in ZSTDMT_toFlushNow()
1316     mtctx->nextJobID = 0;  in ZSTDMT_initCStream_internal()
1353     unsigned const jobID = mtctx->nextJobID & mtctx->jobIDMask;  in ZSTDMT_createCompressionJob()
1356     if (mtctx->nextJobID > mtctx->doneJobID + mtctx->jobIDMask) {  in ZSTDMT_createCompressionJob()
1358         assert((mtctx->nextJobID & mtctx->jobIDMask) == (mtctx->doneJobID & mtctx->jobIDMask));  in ZSTDMT_createCompressionJob()
1365                     mtctx->nextJobID, (U32)srcSize, (U32)mtctx->inBuff.prefix.size);  in ZSTDMT_createCompressionJob()
1373         mtctx->jobs[jobID].cdict = mtctx->nextJobID==0 ? mtctx->cdict : NULL;  in ZSTDMT_createCompressionJob()
1380         mtctx->jobs[jobID].jobID = mtctx->nextJobID;  in ZSTDMT_createCompressionJob()
1381         mtctx->jobs[jobID].firstJob = (mtctx->nextJobID==0);  in ZSTDMT_createCompressionJob()
1383 …obID].frameChecksumNeeded = mtctx->params.fParams.checksumFlag && endFrame && (mtctx->nextJobID>0);  in ZSTDMT_createCompressionJob()
1398             if (mtctx->nextJobID == 0) {  in ZSTDMT_createCompressionJob()
1404           && (mtctx->nextJobID>0)/*single job must also write frame header*/ ) {  in ZSTDMT_createCompressionJob()
1408             mtctx->nextJobID++;  in ZSTDMT_createCompressionJob()
1414                 mtctx->nextJobID,  in ZSTDMT_createCompressionJob()
1417                 mtctx->nextJobID,  in ZSTDMT_createCompressionJob()
1420         mtctx->nextJobID++;  in ZSTDMT_createCompressionJob()
1423 …      DEBUGLOG(5, "ZSTDMT_createCompressionJob: no worker available for job %u", mtctx->nextJobID);  in ZSTDMT_createCompressionJob()
1440                 blockToFlush, mtctx->doneJobID, mtctx->nextJobID);  in ZSTDMT_flushProduced()
1445       && (mtctx->doneJobID < mtctx->nextJobID) ) {  in ZSTDMT_flushProduced()
1486             assert(mtctx->doneJobID < mtctx->nextJobID);  in ZSTDMT_flushProduced()
1514     if (mtctx->doneJobID < mtctx->nextJobID) return 1;   /* some more jobs ongoing */  in ZSTDMT_flushProduced()
1530     unsigned const lastJobID = mtctx->nextJobID;  in ZSTDMT_getInputDataInUse()
1815                 assert(mtctx->doneJobID != mtctx->nextJobID);  in ZSTDMT_compressStream_generic()