Lines Matching refs:queueMutex
7024 ZSTD_pthread_mutex_t queueMutex; member
7043 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
7051 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
7054 ZSTD_pthread_cond_wait(&ctx->queuePopCond, &ctx->queueMutex); in POOL_thread()
7063 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
7068 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()
7073 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()
7103 error |= ZSTD_pthread_mutex_init(&ctx->queueMutex, NULL); in POOL_create_advanced()
7134 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_join()
7136 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_join()
7150 ZSTD_pthread_mutex_destroy(&ctx->queueMutex); in POOL_free()
7202 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_resize()
7205 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_resize()
7240 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_add()
7243 ZSTD_pthread_cond_wait(&ctx->queuePushCond, &ctx->queueMutex); in POOL_add()
7246 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_add()
7253 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_tryAdd()
7255 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()
7259 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_tryAdd()