Searched refs:InQueue (Results 1 – 4 of 4) sorted by relevance
75 QueueChannel(std::shared_ptr<Queue> InQueue, in QueueChannel() argument77 : InQueue(InQueue), OutQueue(OutQueue) {} in QueueChannel()109 std::unique_lock<std::mutex> Lock(InQueue->getMutex()); in readBytes()112 Error Err = InQueue->checkReadError(); in readBytes()113 while (!Err && InQueue->empty()) { in readBytes()114 InQueue->getCondVar().wait(Lock); in readBytes()115 Err = InQueue->checkReadError(); in readBytes()120 *Dst++ = InQueue->front(); in readBytes()123 InQueue->pop(); in readBytes()147 InQueue->setReadError(ChannelClosed); in close()[all …]
30 QueueChannel(Queue &InQueue, Queue &OutQueue) in QueueChannel() argument31 : InQueue(InQueue), OutQueue(OutQueue) {} in QueueChannel()36 while (InQueue.empty()) in readBytes()40 std::lock_guard<std::mutex> Lock(InQueue.getLock()); in readBytes()41 while (!InQueue.empty() && Size) { in readBytes()42 *Dst++ = InQueue.front(); in readBytes()44 InQueue.pop(); in readBytes()60 Queue &InQueue; member in QueueChannel
94 llvm::StringSet<> InQueue; in load() local97 InQueue.insert(MainFile); in load()106 auto It = InQueue.insert(Edge); in load()
1507 InQueue, in run() enumerator1515 (&in_queue_evt, Token::InQueue), in run()1549 Token::InQueue => { in run()