Lines Matching refs:queueMutex
51 ZSTD_pthread_mutex_t queueMutex; member
70 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
73 ZSTD_pthread_cond_wait(&ctx->queuePopCond, &ctx->queueMutex); in POOL_thread()
77 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
86 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
93 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
95 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
123 (void)ZSTD_pthread_mutex_init(&ctx->queueMutex, NULL); in POOL_create_advanced()
151 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_join()
153 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_join()
167 ZSTD_pthread_mutex_destroy(&ctx->queueMutex); in POOL_free()
213 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_add()
216 ZSTD_pthread_cond_wait(&ctx->queuePushCond, &ctx->queueMutex); in POOL_add()
219 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_add()
226 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_tryAdd()
228 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()
232 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()