channel.cpp

一个通信类源码

#include <iostream>

#include "channel.h"
//#define  CBXDEBUG

void OnReceive_Com(void* userData, BYTE* rcvData, int len)
{
		
	CChannel* channel = (CChannel*)userData;

	if (channel == NULL)
	   return;	

	if (len <= 0)
	   return;
	   
#ifdef CBXDEBUG	
	printf("ComPort recved %d byte! \n", len );
		
        for(int i = 0; i < len; i++)
	{
	   printf( "%2x",rcvData[i] );
	}
	printf("\n");
#endif		
        
	if (channel->m_tcp_port.Send(rcvData, len) < 0)			
	{
	  printf("Tcp port send failed!");
	  return;
	}
	
#ifdef CBXDEBUG		
	printf("TcpPort resend %d byte! \n", len );
		
        for(int i = 0; i < len; i++)
	{
	   printf( "%2x",rcvData[i] );
	}
	printf("\n");
#endif		
}

void OnReceive_Tcp(void* userData, BYTE* rcvData, int len)
{
	CChannel* channel = (CChannel*)userData;
	
	if (channel == NULL)
		return;	
	
	if (len <= 0)
		return;
	
#ifdef CBXDEBUG				
	printf("TcpPort recved %d byte! \n", len );
		
        for(int i = 0; i < len; i++)
	{
	   printf( "%2x",rcvData[i] );
	}
	printf("\n");
#endif		
	
	if (channel->m_com_port.Send(rcvData, len) < 0)			
	{
	  printf("Com port send failed!");
	  return;
	}

#ifdef CBXDEBUG		
	printf("ComPort resend %d byte! \n", len );
		
        for(int i = 0; i < len; i++)
	{
	   printf( "%2x",rcvData[i] );
	}
	printf("\n");
#endif		
}
       

/******************************************************************************/
/* CChannel */

CChannel::CChannel()
{
	m_bConnected = FALSE;
}

CChannel::~CChannel()
{
}

int CChannel::Open(int argc, char** argv)
{
	int		chanTyp;			// channel type
	char		commPara [64];			// communication parameter	
	int		devNum;				// device sum on channel
	int		addrBuf [MAXDEVCNUM];		// device addresses
	int*		addr [MAXDEVCNUM];
	char		typBuf [MAXDEVCNUM] [32];	// device types	
	char*		type [MAXDEVCNUM];
	
	int		i, ret;		

	for (i = 0; i < MAXDEVCNUM; i++)
	{
		addr [i] = &addrBuf [i];
		type [i] = typBuf [i];
	}

	if (0 != (ret = GetConfigs(
		argc,
		argv,
		&chanTyp,
		commPara,
		&devNum,
		addr,
		type)))
	{		
		return MAKEWORD(ret, 1);
	}
	
	if (0 != (ret = ParseSerialCommParaStr(commPara, &m_sp)))	
	{
		return MAKEWORD(ret, 2);
	}

	if (0 != (ret = m_com_port.Open(&m_sp, OnReceive_Com, this, chanTyp)))
	{
		return MAKEWORD(ret, 3);
	}
	
	printf("ComPort opened success! \n");
	
	ETHERPORT ethport;
	ethport.port = m_sp.com + 8000;
	
	if (1 != (ret = m_tcp_port.Open(&ethport, OnReceive_Tcp, this)))
	{
		return MAKEWORD(ret, 4);
	}
	printf("tcp/ip port opened success!");
	return 0;
}