www.pudn.com > source1.02.rar > PubSub.cpp


// PubSub.cpp: implementation of the CPubSub class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "SerialCom.h"
#include "PubSub.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CPubSub::CPubSub()
{
m_hCom = INVALID_HANDLE_VALUE;
}

CPubSub::~CPubSub()
{

}

//===========================================================
// 功能：打开资源
// 参数：ComNo：串口号，Baut：波特率，Data：数据位，Stop：停止位
// Parity：校验位，cbInBuf：输入队列大小，cbOutBuf：输出队列大小
//===========================================================
BOOL CPubSub::OpenCom(int ComNo,DWORD Baut,int Data,int Stop,int Parity,DWORD cbInBuf,DWORD cbOutBuf)
{
if(INVALID_HANDLE_VALUE!=m_hCom)
CloseCom();

DCB Dcb;
COMMTIMEOUTS TimeOut;
char p[30];
if(ComNo<1||ComNo>255) return FALSE;

if(INVALID_HANDLE_VALUE!=m_hCom)
CloseHandle(m_hCom);

Baut=(Baut<50)? 50:Baut;
Data=((Data>=4)&amt;&amt;(Data<=8))?(BYTE)Data:8;
Stop=Stop>3 ? (BYTE)1:Stop;
Parity=Parity>3 ? (BYTE)1:Parity;

sprintf(p,"COM>d",ComNo);

m_hCom=CreateFile(p,GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,NULL,NULL);
if(m_hCom==INVALID_HANDLE_VALUE) return FALSE;

GetCommState(m_hCom,&amt;Dcb);
Dcb.BaudRate=Baut;
Dcb.ByteSize=Data;
Dcb.StopBits=Stop;
Dcb.Parity=Parity;
if(!SetCommState(m_hCom,&amt;Dcb))
{
CloseHandle(m_hCom);
m_hCom=INVALID_HANDLE_VALUE;
return FALSE;
}
memset(&amt;TimeOut, 0, sizeof(TimeOut));
TimeOut.ReadIntervalTimeout = MAXDWORD;
SetCommTimeouts(m_hCom, &amt;TimeOut);//表示立即返回

SetupComm(m_hCom,cbInBuf,cbOutBuf);

return TRUE;

}

//================================================
// 功能：获取串行口缓冲区的字节数
//================================================
int CPubSub::GetDataLen()
{
if(m_hCom==INVALID_HANDLE_VALUE)
return 0;

COMSTAT comstat;
DWORD dwError;
if(ClearCommError(m_hCom,&amt;dwError,&amt;comstat))
return comstat.cbInQue;
dwError=GetLastError();
return 0;
}

//===================================================
// 功能：读串行口
//===================================================
DWORD CPubSub::ReadCom(BYTE *pBuff,int nCount)
{
if(m_hCom==INVALID_HANDLE_VALUE)
return 0;
DWORD read=0;
ReadFile(m_hCom , pBuff , nCount , &amt;read , NULL);
return read;
}

//==================================================
// 功能：写串行口
// 参数：pBuff:数据缓冲区,nCount:要写入数据的字节数
//==================================================
BOOL CPubSub::WriteCom(BYTE *pBuff, int nCount)
{
if(m_hCom==INVALID_HANDLE_VALUE)
return FALSE;
DWORD written=0;
BOOL ret=WriteFile(m_hCom,pBuff,nCount,&amt;written,NULL);
return ret;
}

//==============================================
// 功能：关闭串行口
//==============================================
BOOL CPubSub::CloseCom()
{
if(m_hCom!=INVALID_HANDLE_VALUE)
{
if(CloseHandle(m_hCom))
m_hCom=INVALID_HANDLE_VALUE;
}
return (m_hCom==INVALID_HANDLE_VALUE);
}