lib/compress/zstdmt_compress.c

564                                       range_t src, unsigned jobID)
568     while (serialState->nextJobID < jobID) {
573     if (serialState->nextJobID == jobID) {
612                                               unsigned jobID, size_t cSize)
615     if (serialState->nextJobID <= jobID) {
617         DEBUGLOG(5, "Skipping past job %u because of error", jobID);
618         serialState->nextJobID = jobID + 1;
649     unsigned jobID;                      /* set by mtctx, then read by worker => no barrier */
689     if (job->jobID != 0) jobParams.fParams.checksumFlag = 0;
719     ZSTDMT_serialState_update(job->serial, cctx, rawSeqStore, job->src, job->jobID);
774     ZSTDMT_serialState_ensureFinished(job->serial, job->jobID, job->cSize);
977     unsigned jobID;
979     for (jobID=0; jobID <= mtctx->jobIDMask; jobID++) {
981         ZSTD_pthread_mutex_t const mutex = mtctx->jobs[jobID].job_mutex;
982         ZSTD_pthread_cond_t const cond = mtctx->jobs[jobID].job_cond;
984         DEBUGLOG(4, "job%02u: release dst address %08X", jobID, (U32)(size_t)mtctx->jobs[jobID].dstBuff.start);
985         ZSTDMT_releaseBuffer(mtctx->bufPool, mtctx->jobs[jobID].dstBuff);
988         ZSTD_memset(&mtctx->jobs[jobID], 0, sizeof(mtctx->jobs[jobID]));
989         mtctx->jobs[jobID].job_mutex = mutex;
990         mtctx->jobs[jobID].job_cond = cond;
1001         unsigned const jobID = mtctx->doneJobID & mtctx->jobIDMask;
1002         ZSTD_PTHREAD_MUTEX_LOCK(&mtctx->jobs[jobID].job_mutex);
1003         while (mtctx->jobs[jobID].consumed < mtctx->jobs[jobID].src.size) {
1005             ZSTD_pthread_cond_wait(&mtctx->jobs[jobID].job_cond, &mtctx->jobs[jobID].job_mutex);
1007         ZSTD_pthread_mutex_unlock(&mtctx->jobs[jobID].job_mutex);
1118     unsigned const jobID = mtctx->doneJobID;
1119     assert(jobID <= mtctx->nextJobID);
1120     if (jobID == mtctx->nextJobID) return 0;   /* no active job => nothing to flush */
1123     {   unsigned const wJobID = jobID & mtctx->jobIDMask;
1133              * However, jobID is expected to still be active:
1134              * if jobID was already completed and fully flushed,
1353     unsigned const jobID = mtctx->nextJobID & mtctx->jobIDMask;
1366         mtctx->jobs[jobID].src.start = src;
1367         mtctx->jobs[jobID].src.size = srcSize;
1369         mtctx->jobs[jobID].prefix = mtctx->inBuff.prefix;
1370         mtctx->jobs[jobID].consumed = 0;
1371         mtctx->jobs[jobID].cSize = 0;
1372         mtctx->jobs[jobID].params = mtctx->params;
1373         mtctx->jobs[jobID].cdict = mtctx->nextJobID==0 ? mtctx->cdict : NULL;
1374         mtctx->jobs[jobID].fullFrameSize = mtctx->frameContentSize;
1375         mtctx->jobs[jobID].dstBuff = g_nullBuffer;
1376         mtctx->jobs[jobID].cctxPool = mtctx->cctxPool;
1377         mtctx->jobs[jobID].bufPool = mtctx->bufPool;
1378         mtctx->jobs[jobID].seqPool = mtctx->seqPool;
1379         mtctx->jobs[jobID].serial = &mtctx->serial;
1380         mtctx->jobs[jobID].jobID = mtctx->nextJobID;
1381         mtctx->jobs[jobID].firstJob = (mtctx->nextJobID==0);
1382         mtctx->jobs[jobID].lastJob = endFrame;
1383         mtctx->jobs[jobID].frameChecksumNeeded = mtctx->params.fParams.checksumFlag && endFrame && (mtctx->nextJobID>0);
1384         mtctx->jobs[jobID].dstFlushed = 0;
1407             ZSTDMT_writeLastEmptyBlock(mtctx->jobs + jobID);
1415                 (U32)mtctx->jobs[jobID].src.size,
1416                 mtctx->jobs[jobID].lastJob,
1418                 jobID);
1419     if (POOL_tryAdd(mtctx->factory, ZSTDMT_compressionJob, &mtctx->jobs[jobID])) {
1531     unsigned jobID;
1533     for (jobID = firstJobID; jobID < lastJobID; ++jobID) {
1534         unsigned const wJobID = jobID & mtctx->jobIDMask;