Searched refs:OutQueue (Results 1 – 2 of 2) sorted by relevance
76 std::shared_ptr<Queue> OutQueue) in QueueChannel() argument77 : InQueue(InQueue), OutQueue(OutQueue) {} in QueueChannel()105 std::unique_lock<std::mutex> Lock(OutQueue->getMutex()); in appendBytes()107 if (Error Err = OutQueue->checkWriteError()) in appendBytes()109 OutQueue->push(*Src++); in appendBytes()112 OutQueue->getCondVar().notify_one(); in appendBytes()122 OutQueue->setReadError(ChannelClosed); in close()123 OutQueue->setWriteError(ChannelClosed); in close()132 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