Searched refs:InQueue (Results 1 – 2 of 2) sorted by relevance
75 QueueChannel(std::shared_ptr<Queue> InQueue, in QueueChannel() argument77 : InQueue(InQueue), OutQueue(OutQueue) {} in QueueChannel()85 std::unique_lock<std::mutex> Lock(InQueue->getMutex()); in readBytes()88 Error Err = InQueue->checkReadError(); in readBytes()89 while (!Err && InQueue->empty()) { in readBytes()90 InQueue->getCondVar().wait(Lock); in readBytes()91 Err = InQueue->checkReadError(); in readBytes()96 *Dst++ = InQueue->front(); in readBytes()99 InQueue->pop(); in readBytes()120 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