Searched refs:zq_mutex (Results 1 – 1 of 1) sorted by relevance
144 pthread_mutex_t zq_mutex; member320 pthread_mutex_init(&queue->zq_mutex, NULL); in zstream_queue_create()542 pthread_mutex_lock(&to_score->zq_mutex); in assign_queue_and_get_work()544 pthread_mutex_unlock(&to_score->zq_mutex); in assign_queue_and_get_work()554 pthread_mutex_lock(&(*queue)->zq_mutex); in assign_queue_and_get_work()556 pthread_mutex_unlock(&(*queue)->zq_mutex); in assign_queue_and_get_work()596 pthread_mutex_lock(&queue->zq_mutex); in queue_worker()601 pthread_mutex_unlock(&queue->zq_mutex); in queue_worker()682 pthread_mutex_lock(&queue->zq_mutex); in zstream_enqueue()686 pthread_cond_wait(&queue->zq_cond.dequeued, &queue->zq_mutex); in zstream_enqueue()[all …]