Searched refs:OutQueue (Results 1 – 3 of 3) sorted by relevance
76 std::shared_ptr<Queue> OutQueue) in QueueChannel() argument77 : InQueue(InQueue), OutQueue(OutQueue) {} in QueueChannel()129 std::unique_lock<std::mutex> Lock(OutQueue->getMutex()); in appendBytes()131 if (Error Err = OutQueue->checkWriteError()) in appendBytes()133 OutQueue->push(*Src++); in appendBytes()136 OutQueue->getCondVar().notify_one(); in appendBytes()149 OutQueue->setReadError(ChannelClosed); in close()150 OutQueue->setWriteError(ChannelClosed); in close()164 std::shared_ptr<Queue> OutQueue; variable
30 QueueChannel(Queue &InQueue, Queue &OutQueue) in QueueChannel() argument31 : InQueue(InQueue), OutQueue(OutQueue) {} in QueueChannel()51 std::lock_guard<std::mutex> Lock(OutQueue.getLock()); in appendBytes()53 OutQueue.push(*Src++); in appendBytes()61 Queue &OutQueue; member in QueueChannel
1508 OutQueue, in run() enumerator1516 (&out_queue_evt, Token::OutQueue), in run()1574 Token::OutQueue => { in run()