channel.cpp~

一个通信类源码

#include <iostream>

#include "channel.h"

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

	if (channel == NULL)
		return;	

	if (len <= 0)
		return;
	
            *(rcvData+len) = '\0';
	//cout << rcvData << endl;
            printf("%s" , rcvData);

            if (channel->m_port1.Send(rcvData, len) < 0)			
	{
	  //error(1, errno, "send failed");
	}	
}

void OnReceive1(void* userData, BYTE* rcvData, int len)
{
	CChannel* channel = (CChannel*)userData;
	
	if (channel == NULL)
		return;	
	
	if (len <= 0)
		return;
	
	*(rcvData+len) = '\0';
	printf("%s" , rcvData);

	if (channel->m_port.Send(rcvData, len) < 0)			
	{
		//error(1, errno, "send failed");
	}	
}


/******************************************************************************/
/* 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);
	}*/

	 m_sp.com   = 1;
             m_sp.baudrate = 9600;
             m_sp.databits = 8;
             m_sp.stopbits = 1;
             m_sp.parity = 'n';

	if (0 != (ret = m_port.Open(&m_sp, OnReceive, this)))
	{
		return MAKEWORD(ret, 3);
	}
	
	ETHERPORT ethport;

	ethport.port = m_sp.com + 8000;
	if (0 != (ret = m_port1.Open(&ethport, OnReceive1, this)))
	{
		return MAKEWORD(ret, 4);
	}
	
	return 0;
}