Home
last modified time | relevance | path

Searched refs:packet (Results 1 – 3 of 3) sorted by relevance

/CTR-SDK-4.2.7-SampleDemos/fs/Streaming/
DFsSampleStreamingWriter.cpp114 PacketData *packet = new PacketData(ptr, MEMO_BUFFER_SIZE, m_ReceiveQueue); in CreatePacket() local
117 m_ReturnQueue.Enqueue(reinterpret_cast<uptr>(packet)); in CreatePacket()
186 uptr packet[BUFFER_SIZE / MEMO_BUFFER_SIZE]; in ThreadFunc() local
190 … for (writePacketNum = 0; writePacketNum < sizeof(packet) / sizeof(packet[0]); ++writePacketNum) in ThreadFunc()
192 packet[writePacketNum] = m_ReceiveQueue.Dequeue(); in ThreadFunc()
195 if (packet[writePacketNum] == NULL) in ThreadFunc()
206 …NN_ERR_THROW_FATAL_ALL(m_File.TryWrite(&size, reinterpret_cast<PacketData*>(packet[0])->GetData(),… in ThreadFunc()
215 m_ReturnQueue.Enqueue(packet[i]); in ThreadFunc()
247 PacketData *packet = reinterpret_cast<PacketData*>(out); in SetData() local
249 NN_PANIC_IF_FALSE(size == packet->GetSize()); in SetData()
[all …]
DFsSampleStreamingReader.cpp128 PacketData *packet = new PacketData(ptr, MEMO_BUFFER_SIZE, m_ReturnQueue); in RefillBuffer() local
129 NN_PANIC_IF_NULL(packet); in RefillBuffer()
132 m_SendQueue.Enqueue(reinterpret_cast<uptr>(packet)); in RefillBuffer()
133 ptr += packet->GetSize(); in RefillBuffer()
180 PacketData *packet = reinterpret_cast<PacketData*>(m_ReturnQueue.Dequeue()); in ThreadFunc() local
181 delete packet; in ThreadFunc()
DFsSampleStreamingFrame.cpp368 PacketData *packet; in ProceedMainTask() local
369 if (!LoadMemo(&packet)) in ProceedMainTask()
373 else if (packet) in ProceedMainTask()
375 std::memcpy(s_MemoBuffer, packet->GetData(), packet->GetSize()); in ProceedMainTask()
376 packet->Free(); in ProceedMainTask()