connect.h

泵站系统屏与屏之间的通信

#ifndef		CONNECT_H
#define		CONNECT_H

#include		"SubData.h"

#define  		MBTCP_Client_Num  		6
#define  		IEC_Client_Num  		10
#define 		ListenPort_Num			4			//2403,2404,4661,4662

#define 		SELECT_S				0
#define 		SELECT_US				200000

#define 		TIMEOUT_TIMES		200		//检测网络是否正常

typedef  int 	SOCKET;
typedef  unsigned char   BYTE;
typedef struct 
{
	SOCKET 			Socket_fd;
	int 					inUse;
	int 					NeedCheck;
	int 					DebugFlag;
	unsigned short 		lport;
	int					send_wait_count;
	unsigned long 		timeout_T1;
	unsigned long 		timeout_T2;
	unsigned long 		timeout_T3;
	unsigned long 		timeout_SConfirm;
	unsigned long 		timeout_RecData;
	unsigned long 		timeout_NeedSConfirm;
	unsigned short 		count_I_Send;			//Sended I_Format Frame,need to be confimed
	unsigned short 		count_I_Recv;			//Received I_Format Frame,need to be confimed
	unsigned long 		IEC_Flag;
	unsigned long 		Conn_flag;
	unsigned int 			Conn_SendCount;		//Sended I_Fomrat Frame Conter(+2)
	unsigned int			Conn_RecvCount;		//Received I_Format Frame Counter(+2)
}CONNECTION;
CONNECTION A_ClientSocket[IEC_Client_Num],B_ClientSocket[IEC_Client_Num];
SOCKET A_ListenSocket[ListenPort_Num],B_ListenSocket[ListenPort_Num];
int A_Flag,B_Flag;
int CurDebugPort;

int MBTCP_AFlag, MBTCP_BFlag ;
SOCKET MBTCP_ListenSocket[2];
CONNECTION MBTCP_A_ClientSocket[MBTCP_Client_Num];
CONNECTION MBTCP_B_ClientSocket[MBTCP_Client_Num];

int max( int a, int b);

void TcpInit(void);
void NetInit(int NetGroup);
void *ProcessCallCommand(void * tmp);
void *A_NetRecv(void * tmp);
void *B_NetRecv(void * tmp);	
void *NetSend(void * tmp);
void add_socket(fd_set *sockset,SOCKET *ListenSockfd,CONNECTION *ClientSockfd);
int GetFreeConnect(int NetGroup);
int GetIP(int index,unsigned long int *pIp);
int CONN_SendBuff(SOCKET Socketfd, unsigned char *sendbuf, int nLen);
void CheckNetConnected(int NetGroup);
int CONN_Need_RT(int NetGroup,int index,unsigned char *pucData);
void Conn_Clear(int NetGroup,int nIndex);
int CONN_IsEngStation(int NetGroup,int index);
int CONN_COMMU_Enable();
int CONN_Validate(int ndx);
void OnCommOK(int iPort,int ucIndex);
void OnCommError(int iPort,int ucIndex);
void CONN_PackCount(int NetGroup,int iConect,unsigned char *pucData);
int CONN_Send104Data(int NetGroup,int iConnect,unsigned char *pData,int SendLen);
void CONN_Broad104Data(unsigned char *puc104,int len);
void CONN_SendToOpe(unsigned char *puc104,int len);
void CONN_SendToEng(unsigned char *pucTCP,int len);
void CONN_SendSConfirm(int iConnect);
void CONN_SendDataUp(int iPort,int NetGroup,int index,unsigned char *pucIEC104,unsigned char *pucIEC103);
int RecvDataFromNet(SOCKET Client_Fd,unsigned char *NetRecvBuff);

void ProcessParameters(int NetGroup, int iConnect, unsigned char *pData);
void GetParameters(int NetGroup, int iConnect,unsigned char *nType);
void Get_COM_Parameter(int NetGroup, int iConnect);
void Get_Dev_Parameter(int NetGroup, int iConnect,unsigned char iPort);
void UpDateTransTable(unsigned char *pData,unsigned char nType);
void SetParameters(unsigned char *pData,unsigned char nType);
void Set_COM_Parameter(unsigned char *pData,unsigned char nLen);
void Set_Dev_Parameter(unsigned char *pData,unsigned char nLen);

void ProcessDebugParameters(int NetGroup, int iConnect, unsigned char *pData);
void PrintDebugInfo(int iPort,unsigned char MsgType,unsigned char *pData,int nLen);

#endif