Searched refs:m_ReceiveQueue (Results 1 – 1 of 1) sorted by relevance
34 nn::os::BlockingQueue m_ReceiveQueue; member in sample::fs::streaming::RealTimeFileWriter77 …m_ReceiveQueue.Initialize(m_ReceiveQueueBuffer, sizeof(m_ReceiveQueueBuffer) / sizeof(m_ReceiveQue… in Start()114 PacketData *packet = new PacketData(ptr, MEMO_BUFFER_SIZE, m_ReceiveQueue); in CreatePacket()127 m_ReceiveQueue.Enqueue(NULL); in End()192 packet[writePacketNum] = m_ReceiveQueue.Dequeue(); in ThreadFunc()255 m_ReceiveQueue.Enqueue(reinterpret_cast<uptr>(packet)); in SetData()