660     ZSTD_PTHREAD_MUTEX_LOCK(&job->job_mutex);   \
661     job->cSize = e;                             \
662     ZSTD_pthread_mutex_unlock(&job->job_mutex); \
669     ZSTDMT_jobDescription* const job = (ZSTDMT_jobDescription*)jobDescription;  in ZSTDMT_compressionJob()  local
670 …ZSTD_CCtx_params jobParams = job->params;   /* do not modify job->params ! copy it, modify the cop…  in ZSTDMT_compressionJob()
671     ZSTD_CCtx* const cctx = ZSTDMT_getCCtx(job->cctxPool);  in ZSTDMT_compressionJob()
672     rawSeqStore_t rawSeqStore = ZSTDMT_getSeq(job->seqPool);  in ZSTDMT_compressionJob()
673     buffer_t dstBuff = job->dstBuff;  in ZSTDMT_compressionJob()
679         dstBuff = ZSTDMT_getBuffer(job->bufPool);  in ZSTDMT_compressionJob()
681 …job->dstBuff = dstBuff;   /* this value can be read in ZSTDMT_flush, when it copies the whole job …  in ZSTDMT_compressionJob()
689     if (job->jobID != 0) jobParams.fParams.checksumFlag = 0;  in ZSTDMT_compressionJob()
697     if (job->cdict) {  in ZSTDMT_compressionJob()
698 …dvanced_internal(cctx, NULL, 0, ZSTD_dct_auto, ZSTD_dtlm_fast, job->cdict, &jobParams, job->fullFr…  in ZSTDMT_compressionJob()
699         assert(job->firstJob);  /* only allowed for first job */  in ZSTDMT_compressionJob()
702         U64 const pledgedSrcSize = job->firstJob ? job->fullFrameSize : job->src.size;  in ZSTDMT_compressionJob()
703 …forceWindowError = ZSTD_CCtxParams_setParameter(&jobParams, ZSTD_c_forceMaxWindow, !job->firstJob);  in ZSTDMT_compressionJob()
706         if (!job->firstJob) {  in ZSTDMT_compressionJob()
711 …job->prefix.start, job->prefix.size, ZSTD_dct_rawContent, /* load dictionary in "content-only" mod…  in ZSTDMT_compressionJob()
719     ZSTDMT_serialState_update(job->serial, cctx, rawSeqStore, job->src, job->jobID);  in ZSTDMT_compressionJob()
721     if (!job->firstJob) {  /* flush and overwrite frame header when it's not first job */  in ZSTDMT_compressionJob()
722 …size_t const hSize = ZSTD_compressContinue(cctx, dstBuff.start, dstBuff.capacity, job->src.start, …  in ZSTDMT_compressionJob()
730         int const nbChunks = (int)((job->src.size + (chunkSize-1)) / chunkSize);  in ZSTDMT_compressionJob()
731         const BYTE* ip = (const BYTE*) job->src.start;  in ZSTDMT_compressionJob()
736 …if (sizeof(size_t) > sizeof(int)) assert(job->src.size < ((size_t)INT_MAX) * chunkSize);   /* chec…  in ZSTDMT_compressionJob()
737 …DEBUGLOG(5, "ZSTDMT_compressionJob: compress %u bytes in %i blocks", (U32)job->src.size, nbChunks);  in ZSTDMT_compressionJob()
738         assert(job->cSize == 0);  in ZSTDMT_compressionJob()
745             ZSTD_PTHREAD_MUTEX_LOCK(&job->job_mutex);  in ZSTDMT_compressionJob()
746             job->cSize += cSize;  in ZSTDMT_compressionJob()
747             job->consumed = chunkSize * chunkNb;  in ZSTDMT_compressionJob()
749                         (U32)cSize, (U32)job->cSize);  in ZSTDMT_compressionJob()
750 …      ZSTD_pthread_cond_signal(&job->job_cond);   /* warns some more data is ready to be flushed */  in ZSTDMT_compressionJob()
751             ZSTD_pthread_mutex_unlock(&job->job_mutex);  in ZSTDMT_compressionJob()
756         if ((nbChunks > 0) | job->lastJob /*must output a "last block" flag*/ ) {  in ZSTDMT_compressionJob()
757             size_t const lastBlockSize1 = job->src.size & (chunkSize-1);  in ZSTDMT_compressionJob()
758 …size_t const lastBlockSize = ((lastBlockSize1==0) & (job->src.size>=chunkSize)) ? chunkSize : last…  in ZSTDMT_compressionJob()
759             size_t const cSize = (job->lastJob) ?  in ZSTDMT_compressionJob()
765     if (!job->firstJob) {  in ZSTDMT_compressionJob()
774     ZSTDMT_serialState_ensureFinished(job->serial, job->jobID, job->cSize);  in ZSTDMT_compressionJob()
775     if (job->prefix.size > 0)  in ZSTDMT_compressionJob()
776         DEBUGLOG(5, "Finished with prefix: %zx", (size_t)job->prefix.start);  in ZSTDMT_compressionJob()
777     DEBUGLOG(5, "Finished with source: %zx", (size_t)job->src.start);  in ZSTDMT_compressionJob()
779     ZSTDMT_releaseSeq(job->seqPool, rawSeqStore);  in ZSTDMT_compressionJob()
780     ZSTDMT_releaseCCtx(job->cctxPool, cctx);  in ZSTDMT_compressionJob()
782     ZSTD_PTHREAD_MUTEX_LOCK(&job->job_mutex);  in ZSTDMT_compressionJob()
783     if (ZSTD_isError(job->cSize)) assert(lastCBlockSize == 0);  in ZSTDMT_compressionJob()
784     job->cSize += lastCBlockSize;  in ZSTDMT_compressionJob()
785 …job->consumed = job->src.size;  /* when job->consumed == job->src.size , compression job is presum…  in ZSTDMT_compressionJob()
786     ZSTD_pthread_cond_signal(&job->job_cond);  in ZSTDMT_compressionJob()
787     ZSTD_pthread_mutex_unlock(&job->job_mutex);  in ZSTDMT_compressionJob()
1333 static void ZSTDMT_writeLastEmptyBlock(ZSTDMT_jobDescription* job)  in ZSTDMT_writeLastEmptyBlock()  argument
1335     assert(job->lastJob == 1);  in ZSTDMT_writeLastEmptyBlock()
1336 …assert(job->src.size == 0);   /* last job is empty -> will be simplified into a last empty block */  in ZSTDMT_writeLastEmptyBlock()
1337     assert(job->firstJob == 0);   /* cannot be first job, as it also needs to create frame header */  in ZSTDMT_writeLastEmptyBlock()
1338 …assert(job->dstBuff.start == NULL);   /* invoked from streaming variant only (otherwise, dstBuff m…  in ZSTDMT_writeLastEmptyBlock()
1339     job->dstBuff = ZSTDMT_getBuffer(job->bufPool);  in ZSTDMT_writeLastEmptyBlock()
1340     if (job->dstBuff.start == NULL) {  in ZSTDMT_writeLastEmptyBlock()
1341       job->cSize = ERROR(memory_allocation);  in ZSTDMT_writeLastEmptyBlock()
1344 … assert(job->dstBuff.capacity >= ZSTD_blockHeaderSize);   /* no buffer should ever be that small */  in ZSTDMT_writeLastEmptyBlock()
1345     job->src = kNullRange;  in ZSTDMT_writeLastEmptyBlock()
1346     job->cSize = ZSTD_writeLastEmptyBlock(job->dstBuff.start, job->dstBuff.capacity);  in ZSTDMT_writeLastEmptyBlock()
1347     assert(!ZSTD_isError(job->cSize));  in ZSTDMT_writeLastEmptyBlock()
1348     assert(job->consumed == 0);  in ZSTDMT_writeLastEmptyBlock()