Searched refs:queue_mutex (Results 1 – 5 of 5) 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()
190 mutex queue_mutex; in GetMatchingPaths() local199 &queue_mutex](int i) { in GetMatchingPaths()255 mutex_lock l(queue_mutex); in GetMatchingPaths()
235 Ok(queue_mutex) => queue_mutex.into_inner(), in stop_queue()
295 Ok(queue_mutex) => Ok(queue_mutex.into_inner()), in stop_queue()
2111 static std::mutex queue_mutex; in TEST_P() local2162 std::lock_guard<std::mutex> qm(queue_mutex); in TEST_P()