欢迎来到天天文库
浏览记录
ID:25881418
大小:75.13 KB
页数:36页
时间:2018-11-23
《远动设备及系统网络通信程序源代码》由会员上传分享,免费在线阅读,更多相关内容在教育资源-天天文库。
1、远动设备及系统网络通信程序V1.036//NETProtocol.cpp:implementationoftheCNETProtocolclass.#include"stdafx.h"#include"NETProtocol.h"#defineTIME_TEST1047//Construction/DestructionCNETProtocol::CNETProtocol(){m_nRecSerialNo=0;//接收序列号m_nSendSerialNo=0;//发送序列号m_nRecSerialNoBack=0;m_tLastQueryAllData=0;m_tLa
2、stSendS=0;m_tLastSendTest=0;//每个节点的初始化标志初始化成0x0memset(m_cInitFlag,0x0,sizeof(m_cInitFlag));//每个节点召测了全数据标志初始化成0x0memset(m_cAllDataFlag,0x0,sizeof(m_cAllDataFlag));//每个节点需要对时标志初始化成0x0//memset(m_cTimeFlag,0x0,sizeof(m_cTimeFlag));//最近一次收到报文的时间memset(m_timeLastRecData,0,sizeof(m_timeLastRec
3、Data));}CNETProtocol::~CNETProtocol(){}intCNETProtocol::SetInitParam(intPortIndex,FesInfoInterface*pFesInfoInterface,CFesRdbInterface*pFesRdbInterface){if(ParseProtocolBase::SetInitParam(PortIndex,pFesInfoInterface,pFesRdbInterface)<0){return-1;}return1;}/**功能:线程处理的主循环函数*说明:在这个循环中完成NET规
4、约的解码,向实时库保存采集的数据,*汇报工作状态,通道码发送等工作**在控制指令下发的时候,判断通道的值班状态*在TCPIP连接方式下:子站-server;主站-client;每个子站一个独立的IP,端口号:2404*所以,每个链路只能连接一个子站,不可能出现多个子站挂在一条链路上的情形*采集流程:对每个终端,首先:复位链路-〉召唤全数据,然后:等待子站上送变化数据,*变化数据突发传送,收到数据后(收到几帧后)要在控制域做出确认;*每隔多长时间再召测一次全数据*/intCNETProtocol::MainLoop(){intnRetCode=0;intnRecvLen
5、=0;intnRetParseRecData=0;远动设备及系统网络通信程序V1.036unsignedcharcResultCode;time_ttimeSend;//发送出指令后设置time_ttimeCurr;//当前时间DWORDdwCurrCount;//当前TickCountDWORDdwSendCount;//发送数据的TickCountunsignedcharStartFlag;//TDTJ_MESSAGE_STRUCTtj_mess;m_DnetObj.write_log(0,"NET规约进入主循环!");//第一部分:初始化time(&CPrt
6、clThreadManager::m_tThreadActive[m_IndexInFes]);//设置该通道对应线程的最后活动时间CPrtclThreadManager::m_ThreadExitFlag[m_IndexInFes]=0;//复位该通道对应线程的自动重新启动标志ReportCommState((unsignedchar)3);for(m_NodeIndex=0;m_NodeIndex7、me_ttBeginFreeTime=0;while(!CPrtclThreadManager::m_ThreadExitFlag[m_IndexInFes]){Sleep(100);nRetCode=m_pFesRdbObj->GetChannelStartFlag(m_PortNo,StartFlag);if(nRetCode==1){if(StartFlag==CHL_THREAD_FREE){m_DnetObj.write_log(0,"检测到通道标志为free,规约线程退出");CPrtclThreadManager::m_ThreadEx
7、me_ttBeginFreeTime=0;while(!CPrtclThreadManager::m_ThreadExitFlag[m_IndexInFes]){Sleep(100);nRetCode=m_pFesRdbObj->GetChannelStartFlag(m_PortNo,StartFlag);if(nRetCode==1){if(StartFlag==CHL_THREAD_FREE){m_DnetObj.write_log(0,"检测到通道标志为free,规约线程退出");CPrtclThreadManager::m_ThreadEx
此文档下载收益归作者所有