Searched refs:queue_mutex (Results 1 – 1 of 1) sorted by relevance
47 static pthread_mutex_t queue_mutex = PTHREAD_MUTEX_INITIALIZER; variable145 pthread_mutex_lock(&queue_mutex); in writerTask()146 if (queue->waitForSpace(&queue_mutex)) { in writerTask()151 pthread_mutex_unlock(&queue_mutex); in writerTask()159 pthread_mutex_lock(&queue_mutex); in writerTask()166 pthread_mutex_unlock(&queue_mutex); in writerTask()336 pthread_mutex_lock(&queue_mutex); in poll()361 pthread_cond_wait(&data_available_cond, &queue_mutex); in poll()366 pthread_mutex_unlock(&queue_mutex); in poll()