Searched refs:InQueue (Results 1 – 2 of 2) sorted by relevance
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
1836 InQueue, in run() enumerator1844 (&self.in_queue_evt, Token::InQueue), in run()1869 Token::InQueue => { in run()