?? serialpro.cpp
字號:
//////////////////////////////////////////////////////////////////////
// SerialPro.cpp: implementation of the CSerialPro class.
//負責與串行編程器通訊，對編程器發令
//////////////////////////////////////////////////////////////////////
#include "stdafx.h"
#include "EPro.h"
#include "SerialPro.h"
#include "Pro.h"
#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
CSerialPro::CSerialPro()
{
m_bCanUse=FALSE;
m_bPort=FALSE;
m_bThread=FALSE;
m_hReadRsp=CreateEvent(NULL,FALSE,FALSE,NULL);
m_hWriteRsp=CreateEvent(NULL,FALSE,FALSE,NULL);
}
CSerialPro::~CSerialPro()
{
}
//發送18個字節，第1個字節表示操作類型，第2個字節表示器件的FID，
//后16個字節是與該操作相關的數據
BOOL CSerialPro::SendData()
{
if(!m_bPort)
{
m_pPro->Notify(PRO_INIT_SERIAL_NOT);
return FALSE;
}
if(m_bCanUse)
{
TRACE("[0]%2x [1]%2x [2]%2x [3]%2x [4]%2x [5]%2x [6]%2x [7]%2x\n",TxdBuf[0],TxdBuf[1],TxdBuf[2],TxdBuf[3],TxdBuf[4],TxdBuf[5],TxdBuf[6],TxdBuf[7]);
SendBlock(TxdBuf,18);
m_bCanUse=FALSE;
return TRUE;
}
else
{
m_pPro->Notify(PRO_INVALID);
return FALSE;
}
}
//接收完指定長度數據塊后的處理
void CSerialPro::OnReceived(BYTE *pBuf, UINT nLength)
{
static int n=0;
n++;
TRACE("%d-OnReceived %d BYTES\n",n,nLength);
TRACE("[0]%2x [1]%2x [2]%2x [3]%2x [4]%2x [5]%2x [6]%2x [7]%2x\n",pBuf[0],pBuf[1],pBuf[2],pBuf[3],pBuf[4],pBuf[5],pBuf[6],pBuf[7]);
if(nLength==18)
{
switch(pBuf[0])//是什么操作的回應
{
case 0://編程器就緒
m_bCanUse=TRUE;
m_pPro->Notify(PRO_AVAILABLE);
return;
case 1://編程器讀入特征字
m_bCanUse=TRUE;
m_pPro->SignByte[0]=pBuf[2];
m_pPro->SignByte[1]=pBuf[3];
m_pPro->SignByte[2]=pBuf[4];
m_pPro->CheckChip();//檢查是否可以找到與特征字匹配的器件
return;
case 2://編程器插除器件
m_bCanUse=TRUE;
m_pPro->Notify(PRO_ERASE);
return;
case 3:
//編程器等待寫器件的回應，建立寫ROM的線程
TRACE("m_bThread=%d\n",m_bThread);
if(m_bThread==FALSE?(AfxBeginThread(WriteRomThread,this)!=NULL):FALSE)
return;
case 4:
//編程器等待讀器件的回應，建立讀ROM的線程
TRACE("m_bThread=%d\n",m_bThread);
if(m_bThread==FALSE?(AfxBeginThread(ReadRomThread,this)!=NULL):FALSE)
return;
case 5://編程器寫鎖定位完成
m_bCanUse=TRUE;
m_pPro->Notify(PRO_LOCK_BIT);
return;
case 6://讀出器件的數據
if(m_bThread)
{
SetEvent(m_hReadRsp);//用事件通知讀線程
}
return;
case 0xff://編程器收到無效的命令
m_bCanUse=TRUE;
m_pPro->Notify(PRO_WORK_INVALID);
return;
default:
m_bCanUse=TRUE;
break;
}
}
else if(nLength==1 && m_bThread)//如果只接收到1個字節，是否給寫線程的
{
//為提高通訊效率，編程器寫完一塊數據后回應一個字節
//表示是否成功寫入
SetEvent(m_hWriteRsp);//用事件通知寫線程
}
else//通訊出錯了
{
m_pPro->Notify(PRO_RCV_ER);
m_bCanUse=FALSE;
}
}
BOOL CSerialPro::InitPort(CPro* pPro, UINT nPort, UINT nBaud)
{
m_pPro=pPro;
if(m_bPort)
{
StopMonitoring();//如果以前占用了串口，先關閉監聽串口
}
//初始化串口通訊
m_bPort=CSerialPort::InitPort((CWnd*)pPro->m_pDlg,nPort,nBaud,'N');
if(m_bPort)
{
SetExpRcv(18);//設置期望的數據塊長度
StartMonitoring();//監聽串口
m_pPro->Notify(PRO_INIT_SERIAL_SEC);
TRACE("CSerialPort::InitPort-PASS\n");
}
else
{
m_pPro->Notify(PRO_INIT_SERIAL_ER);
TRACE("CSerialPort::InitPort-ERROR\n");
}
return m_bPort;
}
void CSerialPro::DetectPro(BYTE FID)
{
TRACE("DetectPro(%d)\n",FID);
TxdBuf[0]=0;
TxdBuf[1]=FID;
m_bCanUse=TRUE;
SendData();
}
void CSerialPro::ReadSign(BYTE FID)
{
TRACE("ReadSign(%d)\n",FID);
TxdBuf[0]=1;
TxdBuf[1]=FID;
SendData();
}
void CSerialPro::Erase(BYTE FID)
{
TRACE("Erase(%d)\n",FID);
TxdBuf[0]=2;
TxdBuf[1]=FID;
SendData();
}
//發送開始寫器件的命令，讓編程器做好準備
void CSerialPro::BeginWrite(BYTE FID)
{
TRACE("BeginWrite(%d)\n",FID);
TxdBuf[0]=3;
TxdBuf[1]=FID;
SendData();
}
//發送開始讀器件的命令，讓編程器做好準備
void CSerialPro::BeginRead(BYTE FID)
{
TRACE("BeginWrite(%d)\n",FID);
TxdBuf[0]=4;
TxdBuf[1]=FID;
SendData();
}
void CSerialPro::LockBit(BYTE FID,int nBit)
{//寫鎖定位，nBit為鎖定位數
TRACE("LockBit(%d,%d)\n",FID,nBit);
TxdBuf[0]=5;
TxdBuf[1]=FID;
TxdBuf[2]=(BYTE)nBit;
SendData();
}
//寫器件的線程
UINT CSerialPro::WriteRomThread(LPVOID pParam)
{
TRACE("WriteRomThread(LPVOID pParam)\n");
CSerialPro* pSerialPro=(CSerialPro*)pParam;
pSerialPro->m_bThread=TRUE;
CPro* pPro=pSerialPro->m_pPro;
pPro->Notify(PRO_WRITE_BEGIN);
pPro->m_nAddr=0;
pPro->m_nDataLength=pPro->GetMinLength(pPro->m_pWriteBuf,0x10000);
//得到緩沖中最小數據塊長度，跳過寫0xff
if(pPro->m_nDataLength==0)//如果數據塊長度為0，直接退出
{
TRACE("WriteRomThread(...) Over\n");
pSerialPro->m_bThread=FALSE;
pSerialPro->TxdBuf[0]=0;//通知編程器寫結束
pSerialPro->SendBlock(pSerialPro->TxdBuf,18);
pPro->Notify(PRO_WRITE_OVER);
return 0;
}
pSerialPro->SetExpRcv(1);//設置只要接收一個字節
Sleep(5);
ResetEvent(pSerialPro->m_hWriteRsp);//事件復位
while(pPro->m_nAddr<pPro->m_nDataLength)
{//只要ROM地址指針小于數據塊長度，就繼續寫
TRACE("pPro->m_nAddr:%04x pPro->m_nDataLength:%04x\n",pPro->m_nAddr,pPro->m_nDataLength);
pSerialPro->TxdBuf[0]=0x07;//表示繼續寫
memcpy(&pSerialPro->TxdBuf[2],&pPro->m_pWriteBuf[pPro->m_nAddr],0x10);
//給發送緩沖填充要寫的數據
pSerialPro->SendBlock(pSerialPro->TxdBuf,18);//發送
TRACE("WaitForSingleObject(...)\n");
if(WaitForSingleObject(pSerialPro->m_hWriteRsp,1000)==WAIT_TIMEOUT)
{//等待編程器回應超時
TRACE("WaitForSingleObject(...) TimeOut\n");
pSerialPro->SetExpRcv(18);
pPro->Notify(PRO_RCV_ER);
pSerialPro->m_bThread=FALSE;
pSerialPro->m_bCanUse=TRUE;
return -1;
}
TRACE("WaitForSingleObject(...) OVER\n");
if(pSerialPro->RxdBuf[0]==0x01)
{//寫數據成功
pPro->m_nAddr+=0x10;
pPro->Notify(PRO_WRITE_BLOCK);
}
else if(pSerialPro->RxdBuf[0]==0xff)
{//寫數據失敗
TRACE("WriteRomThread(...) ERROR\n");
pSerialPro->SetExpRcv(18);
pSerialPro->TxdBuf[0]=0;
pSerialPro->SendBlock(pSerialPro->TxdBuf,18);
pPro->Notify(PRO_WRITE_ER);
pSerialPro->m_bThread=FALSE;
pSerialPro->m_bCanUse=TRUE;
return -1;
}
else//通訊出錯
{
TRACE("WriteRomThread(...) COM ER\n");
pSerialPro->SetExpRcv(18);
pPro->Notify(PRO_RCV_ER);
pSerialPro->m_bThread=FALSE;
pSerialPro->m_bCanUse=TRUE;
return -1;
}
}
pSerialPro->SetExpRcv(18);//還原
pSerialPro->TxdBuf[0]=0;//通知編程器寫結束
pSerialPro->SendBlock(pSerialPro->TxdBuf,18);
pPro->Notify(PRO_WRITE_OVER);
TRACE("WriteRomThread(...) SEC\n");
pSerialPro->m_bThread=FALSE;
pSerialPro->m_bCanUse=TRUE;
return 0;
}
//讀器件的線程
UINT CSerialPro::ReadRomThread(LPVOID pParam)
{
TRACE("ReadRomThread(LPVOID pParam)\n");
CSerialPro* pSerialPro=(CSerialPro*)pParam;
pSerialPro->m_bThread=TRUE;
CPro* pPro=pSerialPro->m_pPro;
pPro->Notify(PRO_READ_BEGIN);
BYTE RespByte=1;
BOOL bReWait=FALSE;
pPro->m_nAddr=0;
if(!pPro->m_bCheck)//如果不是效驗，則讀整個ROM
pPro->m_nDataLength=pPro->GetCurChip()->RomSize*1024;
if(pPro->m_nDataLength==0)
{
pPro->Notify(PRO_READ_OVER);
TRACE("ReadRomThread(...) Over\n");
pSerialPro->m_bThread=FALSE;
return 0;
}
ResetEvent(pSerialPro->m_hReadRsp);//事件復位
while(pPro->m_nAddr<pPro->m_nDataLength)
{
TRACE("pPro->m_nAddr:%04x pPro->m_nDataLength:%04x\n",pPro->m_nAddr,pPro->m_nDataLength);
pSerialPro->SendBlock(&RespByte,1);//發一個字節給編程器
TRACE("WaitForSingleObject(...)\n");
if(WaitForSingleObject(pSerialPro->m_hReadRsp,500)==WAIT_TIMEOUT)
{//等待回應超時
if(bReWait)//如果是重發都失敗
{
RespByte=0;
pSerialPro->SendBlock(&RespByte,1);
pPro->Notify(PRO_RCV_ER);
pSerialPro->m_bThread=FALSE;
pSerialPro->m_bCanUse=TRUE;
return -1;
}
else//嘗試要求重發
{
RespByte=0xff;
bReWait=TRUE;
continue;
}
}
bReWait=FALSE;
TRACE("WaitForSingleObject(...) OVER\n");
memcpy(&pPro->m_pReadBuf[pPro->m_nAddr],&pSerialPro->RxdBuf[2],0x10);
//收到數據后，填充到讀緩沖
pPro->m_nAddr+=0x10;
RespByte=0x01;//表示繼續讀
pPro->Notify(PRO_READ_BLOCK);
}
RespByte=0;//表示讀結束
pSerialPro->SendBlock(&RespByte,1);
pPro->Notify(PRO_READ_OVER);
pSerialPro->m_bThread=FALSE;
pSerialPro->m_bCanUse=TRUE;
TRACE("ReadRomThread(...) Over\n");
return 0;
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -