Lines Matching refs:queueMutex
53 ZSTD_pthread_mutex_t queueMutex; member
72 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
80 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
83 ZSTD_pthread_cond_wait(&ctx->queuePopCond, &ctx->queueMutex); in POOL_thread()
92 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
97 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
100 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
136 error |= ZSTD_pthread_mutex_init(&ctx->queueMutex, NULL); in POOL_create_advanced()
167 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_join()
169 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_join()
183 ZSTD_pthread_mutex_destroy(&ctx->queueMutex); in POOL_free()
195 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_joinJobs()
197 ZSTD_pthread_cond_wait(&ctx->queuePushCond, &ctx->queueMutex); in POOL_joinJobs()
199 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_joinJobs()
248 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_resize()
251 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_resize()
289 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_add()
292 ZSTD_pthread_cond_wait(&ctx->queuePushCond, &ctx->queueMutex); in POOL_add()
295 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_add()
302 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_tryAdd()
304 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()
308 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()