ByteStreamPlayback/DataStream.cpp at master · SymphonyOfDream/ByteStreamPlayback · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
#include "StdAfx.h"
#include "DataStream.h"


extern "C"
{


DataStream::DataStream(const wchar_t wszFilename[], const int iComPortToPlayOn)
: m_iComPortToPlayOn(iComPortToPlayOn)
, m_hFile(INVALID_HANDLE_VALUE)
, m_hComPort(INVALID_HANDLE_VALUE)
, m_bStopThread(FALSE)
, m_dwTotalBytesPlayed(0)
, m_pDataPacketRootNode(NULL)
, m_pDataPacketTailNode(NULL)
, m_dwDataPacketCount(0)
{
	memset(m_wszFilename, 0, sizeof(m_wszFilename));
	wcscpy(m_wszFilename, wszFilename);
}


DataStream::~DataStream(void)
{
	if (m_pDataPacketRootNode != NULL)
	{
		while (m_pDataPacketRootNode->m_pNext != NULL)
		{
			DataPacket* pDataPacket = m_pDataPacketRootNode;
			m_pDataPacketRootNode = m_pDataPacketRootNode->m_pNext;
			delete pDataPacket;
		}

		delete m_pDataPacketRootNode;
	}
}


void DataStream::AddDataPacket(const DataPacket* pDataPacket)
{
	DataPacket* pNewDataPacket = new DataPacket(pDataPacket);

	if (m_pDataPacketRootNode == NULL)
	{
		m_pDataPacketRootNode = m_pDataPacketTailNode = pNewDataPacket;
	}
	else
	{
		m_pDataPacketTailNode->m_pNext = pNewDataPacket;
		m_pDataPacketTailNode = pNewDataPacket;
	}

	++m_dwDataPacketCount;
}


};