Lines Matching refs:queueMutex
54 ZSTD_pthread_mutex_t queueMutex; member
73 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
81 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
84 ZSTD_pthread_cond_wait(&ctx->queuePopCond, &ctx->queueMutex); in POOL_thread()
93 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
98 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
103 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
133 error |= ZSTD_pthread_mutex_init(&ctx->queueMutex, NULL); in POOL_create_advanced()
164 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_join()
166 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_join()
180 ZSTD_pthread_mutex_destroy(&ctx->queueMutex); in POOL_free()
232 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_resize()
235 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_resize()
270 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_add()
273 ZSTD_pthread_cond_wait(&ctx->queuePushCond, &ctx->queueMutex); in POOL_add()
276 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_add()
283 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_tryAdd()
285 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()
289 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()