Lines Matching refs:job_mutex

640     ZSTD_pthread_mutex_t job_mutex;      /* Thread-safe - used by mtctx and worker */  member
660 ZSTD_PTHREAD_MUTEX_LOCK(&job->job_mutex); \
662 ZSTD_pthread_mutex_unlock(&job->job_mutex); \
745 ZSTD_PTHREAD_MUTEX_LOCK(&job->job_mutex); in ZSTDMT_compressionJob()
751 ZSTD_pthread_mutex_unlock(&job->job_mutex); in ZSTDMT_compressionJob()
782 ZSTD_PTHREAD_MUTEX_LOCK(&job->job_mutex); in ZSTDMT_compressionJob()
787 ZSTD_pthread_mutex_unlock(&job->job_mutex); in ZSTDMT_compressionJob()
867 ZSTD_pthread_mutex_destroy(&jobTable[jobNb].job_mutex); in ZSTDMT_freeJobsTable()
887 initError |= ZSTD_pthread_mutex_init(&jobTable[jobNb].job_mutex, NULL); in ZSTDMT_createJobsTable()
981 ZSTD_pthread_mutex_t const mutex = mtctx->jobs[jobID].job_mutex; in ZSTDMT_releaseAllJobResources()
989 mtctx->jobs[jobID].job_mutex = mutex; in ZSTDMT_releaseAllJobResources()
1002 ZSTD_PTHREAD_MUTEX_LOCK(&mtctx->jobs[jobID].job_mutex); in ZSTDMT_waitForAllJobsCompleted()
1005 ZSTD_pthread_cond_wait(&mtctx->jobs[jobID].job_cond, &mtctx->jobs[jobID].job_mutex); in ZSTDMT_waitForAllJobsCompleted()
1007 ZSTD_pthread_mutex_unlock(&mtctx->jobs[jobID].job_mutex); in ZSTDMT_waitForAllJobsCompleted()
1097 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1108 ZSTD_pthread_mutex_unlock(&mtctx->jobs[wJobID].job_mutex); in ZSTDMT_getFrameProgression()
1125 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1141 ZSTD_pthread_mutex_unlock(&mtctx->jobs[wJobID].job_mutex); in ZSTDMT_toFlushNow()
1443 ZSTD_PTHREAD_MUTEX_LOCK(&mtctx->jobs[wJobID].job_mutex); in ZSTDMT_flushProduced()
1455 …ZSTD_pthread_cond_wait(&mtctx->jobs[wJobID].job_cond, &mtctx->jobs[wJobID].job_mutex); /* block w… in ZSTDMT_flushProduced()
1462 ZSTD_pthread_mutex_unlock(&mtctx->jobs[wJobID].job_mutex); in ZSTDMT_flushProduced()
1537 ZSTD_PTHREAD_MUTEX_LOCK(&mtctx->jobs[wJobID].job_mutex); in ZSTDMT_getInputDataInUse()
1539 ZSTD_pthread_mutex_unlock(&mtctx->jobs[wJobID].job_mutex); in ZSTDMT_getInputDataInUse()