123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420 |
- #include "stdafx.h"
- #include "Serial.h"
- DCB *CBaseSerial::GetState()
- {
- return IsOpen() && ::GetCommState(_hCommHandle, &_DCB) == TRUE ? &_DCB : NULL;
- }
- bool CBaseSerial::SetState(DCB *pdcb )
- {
- return IsOpen() ? ::SetCommState(_hCommHandle, pdcb == NULL ? &_DCB : pdcb) == TRUE : false;
- }
- bool CBaseSerial::SetState(TCHAR *lpszSetStr )
- {
- if (lpszSetStr && lpszSetStr[0] != '\0' && IsOpen())
- {
- if (::GetCommState(_hCommHandle, &_DCB) != TRUE)
- return false;
-
- if (::BuildCommDCB(lpszSetStr, &_DCB) != TRUE)
- return false;
- return ::SetCommState(_hCommHandle, &_DCB) == TRUE;
- }
- return false;
- }
- bool CBaseSerial::SetState(DWORD dwBaudRate, DWORD dwByteSize , DWORD dwParity , DWORD dwStopBits )
- {
- if (!IsOpen()) return false;
- if (::GetCommState(_hCommHandle, &_DCB) != TRUE)
- return false;
- _DCB.BaudRate = dwBaudRate;
- _DCB.ByteSize = (BYTE)dwByteSize;
- _DCB.Parity = (BYTE)dwParity;
- _DCB.StopBits = (BYTE)dwStopBits;
- return ::SetCommState(_hCommHandle, &_DCB) == TRUE;
- }
- LPCOMMTIMEOUTS CBaseSerial::GetTimeouts()
- {
- return IsOpen() && ::GetCommTimeouts(_hCommHandle, &_CO) == TRUE ? &_CO : NULL;
- }
- bool CBaseSerial::SetTimeouts(DWORD ReadIntervalTimeout , DWORD ReadTotalTimeoutMultiplier , DWORD ReadTotalTimeoutConstant , DWORD WriteTotalTimeoutMultiplier , DWORD WriteTotalTimeoutConstant )
- {
- COMMTIMEOUTS CO = {
- ReadIntervalTimeout,
- ReadTotalTimeoutMultiplier,
- ReadTotalTimeoutConstant,
- WriteTotalTimeoutMultiplier,
- WriteTotalTimeoutConstant
- };
- return IsOpen() ? ::SetCommTimeouts(_hCommHandle, &CO) == TRUE : false;
- }
- bool CBaseSerial::SetTimeouts(LPCOMMTIMEOUTS lpCO)
- {
- return IsOpen() ? ::SetCommTimeouts(_hCommHandle, lpCO) == TRUE : false;
- }
- bool CBaseSerial::SetBufferSize(DWORD dwInputSize, DWORD dwOutputSize)
- {
-
- return IsOpen() ? ::SetupComm(_hCommHandle, dwInputSize, dwOutputSize) == TRUE : false;
- }
- void CBaseSerial::SetMaskEvent(DWORD dwEvent )
- {
- _dwMaskEvent = dwEvent;
- }
- int CBaseSerial::GetInputSize()
- {
- COMSTAT Stat;
- DWORD dwError;
- return ::ClearCommError(_hCommHandle, &dwError, &Stat) == TRUE ? Stat.cbInQue : (DWORD)-1L;
- }
- bool CBaseSerial::Open(DWORD dwPort)
- {
- return Open(dwPort, 19200);
- }
- bool CBaseSerial::Open(DWORD dwPort, DWORD dwBaudRate)
- {
- if (dwPort < 1 || dwPort > 1024)
- return false;
- BindCommPort(dwPort);
- if (!OpenCommPort())
- return false;
- if (!SetupPort())
- return false;
- return SetState(dwBaudRate);
- }
- bool CBaseSerial::Open(DWORD dwPort, TCHAR *lpszSetStr )
- {
- if (dwPort < 1 || dwPort > 1024)
- return false;
- BindCommPort(dwPort);
- if (!OpenCommPort())
- return false;
- if (!SetupPort())
- return false;
- return SetState(lpszSetStr);
- }
- DWORD CBaseSerial::Read(LPVOID Buffer, DWORD dwBufferLength, DWORD dwWaitTime )
- {
- if (!IsOpen())
- return 0;
- COMSTAT Stat;
- DWORD dwError;
- if (::ClearCommError(_hCommHandle, &dwError, &Stat) && dwError > 0) {
- ::PurgeComm(_hCommHandle, PURGE_RXABORT | PURGE_RXCLEAR);
- return 0;
- }
- #if 0
-
- if (!Stat.cbInQue)
- return 0;
- #endif
- utils::_dprintf("缓冲区数据量:%ld", Stat.cbInQue);
- unsigned long uReadLength = 0;
-
- if (!::ReadFile(_hCommHandle, Buffer, dwBufferLength, &uReadLength, &_ReadOverlapped)) {
- WaitForSingleObject(_ReadOverlapped.hEvent, dwWaitTime);
- if (::GetLastError() == ERROR_IO_PENDING) {
- while (!::GetOverlappedResult(_hCommHandle, &_ReadOverlapped, &uReadLength, false)) {
- dwError = ::GetLastError();
- if ( dwError == ERROR_IO_PENDING ) {
- Sleep(50);
- utils::_dprintf("读等待:%ld", dwError);
- } else if ( dwError == ERROR_SUCCESS || dwError == ERROR_IO_INCOMPLETE ) {
- utils::_dprintf("读完成:%ld,%ld,%ld", dwError, uReadLength,_ReadOverlapped.InternalHigh);
-
- if ( _ReadOverlapped.InternalHigh )
- uReadLength = _ReadOverlapped.InternalHigh;
- else
- uReadLength = Stat.cbInQue;
- break;
- } else {
- utils::_dprintf("读错误:%ld", dwError);
- uReadLength = 0;
- break;
- }
- }
- }
- }
- return uReadLength;
- }
- char* CBaseSerial::ReadString(char *szBuffer, DWORD dwBufferLength, DWORD dwWaitTime )
- {
- unsigned long uReadLength = Read(szBuffer, dwBufferLength - 1, dwWaitTime);
- szBuffer[uReadLength] = '\0';
- return szBuffer;
- }
- DWORD CBaseSerial::Write(LPVOID Buffer, DWORD dwBufferLength)
- {
- if (!IsOpen())
- return 0;
- DWORD dwError;
- if (::ClearCommError(_hCommHandle, &dwError, NULL) && dwError > 0)
- ::PurgeComm(_hCommHandle, PURGE_TXABORT | PURGE_TXCLEAR);
-
- unsigned long uWriteLength = 0;
- if (!::WriteFile(_hCommHandle, Buffer, dwBufferLength, &uWriteLength, &_WriteOverlapped)) {
- if (ERROR_IO_PENDING == GetLastError()) {
- while (!GetOverlappedResult(_hCommHandle, &_WriteOverlapped, &uWriteLength, FALSE)) {
- dwError = GetLastError();
- if (ERROR_IO_PENDING == dwError) {
- utils::_dprintf("写等待");
- continue;
- } else if (dwError == ERROR_SUCCESS || dwError == ERROR_IO_INCOMPLETE){
- uWriteLength = _WriteOverlapped.InternalHigh;
- utils::_dprintf("写完成:%ld", dwError);
- break;
- } else {
- utils::_dprintf("写出错:%ld",dwError);
- uWriteLength = 0;
- ClearCommError(_hCommHandle, &dwError, NULL);
- break;
- }
- }
- }
- }
- return uWriteLength;
- }
- DWORD CBaseSerial::Write(const TCHAR *szBuffer)
- {
- assert(szBuffer);
- return Write((void *)szBuffer, _tclen(szBuffer));
- }
- DWORD CBaseSerial::ReadSync(LPVOID Buffer, DWORD dwBufferLength)
- {
- if (!IsOpen())
- return 0;
-
- COMSTAT Stat;
- DWORD dwError;
- DWORD dwLastLen = 0;
- ULONGLONG ulTick = GetTickCount();
-
- while (true) {
- if (GetTickCount() - ulTick > 3000) {
- utils::_dprintf("读出错: 超过3秒仍未读完");
- break;
- }
- if ( ::ClearCommError(_hCommHandle, &dwError, &Stat) && dwError > 0 ) {
- ::PurgeComm(_hCommHandle, PURGE_RXABORT | PURGE_RXCLEAR);
- utils::_dprintf("读出错: ClearCommError出错");
- break;
- }
-
- if (Stat.cbInQue != 0 && dwLastLen == Stat.cbInQue)
- break;
- dwLastLen = Stat.cbInQue;
- Sleep(100);
- }
- if (Stat.cbInQue == 0) {
-
- return 0;
- }
- if (dwBufferLength < Stat.cbInQue) {
- utils::_dprintf("读出错: 缓冲数据过大 %ld > %ld", dwBufferLength, Stat.cbInQue);
- }
- DWORD uReadLength = 0;
- if ( !::ReadFile(_hCommHandle, Buffer, dwBufferLength, &uReadLength, NULL) )
- {
- DWORD dwError = GetLastError();
- utils::_dprintf("读出错:%ld", dwError);
- }
- return uReadLength;
- }
- DWORD CBaseSerial::WriteSync(LPVOID Buffer, DWORD dwBufferLength)
- {
- if (!IsOpen())
- return 0;
-
- DWORD dwError;
- if (::ClearCommError(_hCommHandle, &dwError, NULL) && dwError > 0)
- ::PurgeComm(_hCommHandle, PURGE_TXABORT | PURGE_TXCLEAR);
-
- unsigned long uWriteLength = 0;
- if ( !::WriteFile(_hCommHandle, Buffer, dwBufferLength, &uWriteLength, NULL) )
- {
- DWORD dwError = GetLastError();
- utils::_dprintf("写出错:%ld", dwError);
- }
- return uWriteLength;
- }
- DWORD CBaseSerial::Write(TCHAR *szBuffer, DWORD dwBufferLength, TCHAR *szFormat, ...)
- {
- if (!IsOpen())
- return 0;
-
- va_list va;
- va_start(va, szFormat);
- #if _MSC_VER < 1500
- _vsnprintf(szBuffer, dwBufferLength, szFormat, va);
- #elif _MSC_VER >=1500
-
- _vsntprintf_s(szBuffer, dwBufferLength, _TRUNCATE, szFormat, va);
- #endif
- va_end(va);
- return Write(szBuffer);
- }
- DWORD CBaseSerial::Write(TCHAR *szBuffer, TCHAR *szFormat, ...)
- {
- if (!IsOpen())
- return 0;
-
- va_list va;
- va_start(va, szFormat);
- #if _MSC_VER < 1500
- vsprintf(szBuffer, szFormat, va);
- #elif _MSC_VER >=1500
- _vstprintf(szBuffer, szFormat, va);
- #endif
- va_end(va);
- return Write(szBuffer);
- }
- void CBaseSerial::Close()
- {
- if (!IsOpen()) return;
- PurgeComm(_hCommHandle, PURGE_TXABORT | PURGE_TXCLEAR);
- ::CloseHandle(_hCommHandle);
- _hCommHandle = INVALID_HANDLE_VALUE;
- }
- bool CBaseSerial::SetDTR(bool OnOrOff)
- {
- return IsOpen() ? EscapeCommFunction(_hCommHandle, OnOrOff ? SETDTR : CLRDTR) : false;
- }
- bool CBaseSerial::SetRTS(bool OnOrOff)
- {
- return IsOpen() ? EscapeCommFunction(_hCommHandle, OnOrOff ? SETRTS : CLRRTS) : false;
- }
- bool CBaseSerial::SetBreak(bool OnOrOff)
- {
- return IsOpen() ? EscapeCommFunction(_hCommHandle, OnOrOff ? SETBREAK : CLRBREAK) : false;
- }
- void CBaseSerial::Init()
- {
- memset(_szCommStr, 0, 20*sizeof(TCHAR));
- memset(&_DCB, 0, sizeof(_DCB));
- _DCB.DCBlength = sizeof(_DCB);
- _hCommHandle = INVALID_HANDLE_VALUE;
- memset(&_ReadOverlapped, 0, sizeof(_ReadOverlapped));
- memset(&_WriteOverlapped, 0, sizeof(_WriteOverlapped));
- _ReadOverlapped.hEvent = ::CreateEvent(NULL, true, false, NULL);
- assert(_ReadOverlapped.hEvent != INVALID_HANDLE_VALUE);
- _WriteOverlapped.hEvent = ::CreateEvent(NULL, true, false, NULL);
- assert(_WriteOverlapped.hEvent != INVALID_HANDLE_VALUE);
- _hNotifyWnd = NULL;
- _dwNotifyNum = 0;
- _dwMaskEvent = DEFAULT_COM_MASK_EVENT;
- memset(&_WaitOverlapped, 0, sizeof(_WaitOverlapped));
- _WaitOverlapped.hEvent = ::CreateEvent(NULL, true, false, NULL);
- assert(_WaitOverlapped.hEvent != INVALID_HANDLE_VALUE);
- }
- void CBaseSerial::UnInit()
- {
- if (_ReadOverlapped.hEvent != INVALID_HANDLE_VALUE)
- CloseHandle(_ReadOverlapped.hEvent);
- if (_WriteOverlapped.hEvent != INVALID_HANDLE_VALUE)
- CloseHandle(_WriteOverlapped.hEvent);
- if (_WaitOverlapped.hEvent != INVALID_HANDLE_VALUE)
- CloseHandle(_WaitOverlapped.hEvent);
- }
- void CBaseSerial::BindCommPort(DWORD dwPort)
- {
- assert(dwPort >= 1 && dwPort <= 1024);
- TCHAR p[5] = {0};
- _dwPort = dwPort;
- #if _MSC_VER >= 1200 && _MSC_VER < 1500
- strcpy(_szCommStr, _T("\\\\.\\COM"));
- ltoa(_dwPort, p, 10);
- strcat(_szCommStr, p);
- #elif _MSC_VER >= 1500
- _tcscpy_s(_szCommStr, _T("\\\\.\\COM"));
- _ltot_s(_dwPort, p, 10);
- _tcscat_s(_szCommStr, p);
- #endif
- }
- bool CBaseSerial::OpenCommPort()
- {
- if (IsOpen())
- Close();
- _hCommHandle = ::CreateFile(_szCommStr, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL | _dwIOMode, NULL);
- return IsOpen();
- }
- bool CBaseSerial::SetupPort()
- {
- if (!IsOpen())
- return false;
-
- if (!::SetupComm(_hCommHandle, 8192, 8192))
- return false;
- if (!::GetCommTimeouts(_hCommHandle, &_CO))
- return false;
- _CO.ReadIntervalTimeout = 0;
- _CO.ReadTotalTimeoutMultiplier = 10;
- _CO.ReadTotalTimeoutConstant = 1500;
- _CO.WriteTotalTimeoutMultiplier = 10;
- _CO.WriteTotalTimeoutConstant = 1500;
- if (!::SetCommTimeouts(_hCommHandle, &_CO))
- return false;
-
- if (!::PurgeComm(_hCommHandle, PURGE_TXABORT | PURGE_RXABORT | PURGE_TXCLEAR | PURGE_RXCLEAR))
- return false;
- return true;
- }
|