Lines Matching refs:jobPtr
1069 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1070 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1071 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1073 size_t const flushed = ZSTD_isError(cResult) ? 0 : jobPtr->dstFlushed; in ZSTDMT_getFrameProgression()
1075 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1076 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1079 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1097 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1098 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1099 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1101 size_t const flushed = ZSTD_isError(cResult) ? 0 : jobPtr->dstFlushed; in ZSTDMT_toFlushNow()
1103 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
1111 assert(jobPtr->consumed < jobPtr->src.size); in ZSTDMT_toFlushNow()