Searched refs:queue_mutex (Results 1 – 2 of 2) sorted by relevance
46 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()163 pthread_mutex_lock(&queue_mutex); in writerTask()170 pthread_mutex_unlock(&queue_mutex); in writerTask()367 pthread_mutex_lock(&queue_mutex); in poll()392 pthread_cond_wait(&data_available_cond, &queue_mutex); in poll()397 pthread_mutex_unlock(&queue_mutex); in poll()
2111 static std::mutex queue_mutex; in TEST_P() local2162 std::lock_guard<std::mutex> qm(queue_mutex); in TEST_P()