serialcomm.h

自己项目组开发的自组网传输中串口通信程序

// SerialComm.h: interface for the CSerialComm class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_SERIALCOMM_H__C4E17ABF_B04E_4D85_8527_383185203BC1__INCLUDED_)
#define AFX_SERIALCOMM_H__C4E17ABF_B04E_4D85_8527_383185203BC1__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000
#include <string>
#include "Serial.h"

#define SearchFrameBegin   0
#define RecvHeadFrame      1
#define RecvData           2
#define RecvDBCHAR         3
#define RecvDCCHAR         4
#define RECVDDCHAR         5


#define MAX_BUFFER_SIZE 2048

typedef enum tagSERIAL_STATE
{
	SS_Unknown,
	SS_UnInit,
	SS_Init,
	SS_Started,
	SS_Stopped,
} SERIAL_STATE;


class CSerialComm  
{
private:
	SERIAL_STATE m_eState;

	bool m_abIsConnected;
	void InvalidateHandle(HANDLE &hHandle);//引用的方式
	void CloseAndCleanHandle(HANDLE &hHandle);
	//CSerialBUffer m_theSerialBuffer;
	
	
public:
	CSerialComm();
	virtual ~CSerialComm();
	HANDLE m_hCommPort;
	CRITICAL_SECTION m_csLock;
	UINT8 recvbuffer[MAX_BUFFER_SIZE];
	UINT8 sendbuffer[MAX_BUFFER_SIZE];
	bool CanRead;
	SERIAL_STATE GetCurrentState()    { return m_eState; }
	inline void LockThis()             { EnterCriticalSection(&m_csLock); }
	inline void UnLockThis()           { LeaveCriticalSection(&m_csLock); }
	inline void InitLock()		   { InitializeCriticalSection(&m_csLock); }
	inline void DelLock()              { DeleteCriticalSection(&m_csLock); }
	
	inline bool isConnection()         { return m_abIsConnected; }
//	inline void SetDataReadEvent()     { SetEvent(m_hDataRx); }
	HRESULT ReadProtocol(std::string &data, DWORD alCount, long Timeout);
	HRESULT WRITEProtocol(const BYTE *data, DWORD dwSize);
	HRESULT SerialWriteData(const BYTE *msg, DWORD size);
	HRESULT Init(std::string szPortName=_T("COM1"), std::string dwBaudRate=_T("9600"),
				 std::string byParity =_T("None"),  std::string byStopBit =_T("1"),
				 std::string byByteSize =_T("8"));
	HRESULT Start();
	HRESULT Stop();
	HRESULT UnINit();
	static unsigned _stdcall ThreadFn(void *pcParam);
	//helper fn
	HRESULT CanProcess();
};

#endif // !defined(AFX_SERIALCOMM_H__C4E17ABF_B04E_4D85_8527_383185203BC1__INCLUDED_)