C / C++ / MFC

int CHPCtrl::Connect()
{


	struct sockaddr_in	rmtAddr;
	
//	Create data socket
	m_Socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

	if ( m_Socket == INVALID_SOCKET )
		return 1;

//	Set client properties
	rmtAddr.sin_family	= AF_INET;
	rmtAddr.sin_addr.s_addr = inet_addr( remoteIP );
	rmtAddr.sin_port	= htons( m_nDevicePort );

//	Connect to remote
	if ( connect( m_Socket, (struct sockaddr *)&rmtAddr, sizeof(rmtAddr) ) == SOCKET_ERROR )
		return 1;


//	Open rx monitor thread
	m_hRxMonitor = (HANDLE)_beginthreadex( 0, 0, RxMonitor, this, CREATE_SUSPENDED, 0 );

	if ( m_hRxMonitor )
	{
		
		m_bConnected = true;
		ResumeThread( m_hRxMonitor );

	} //__if ( m_pReadThread )__

	return 0;

}

UINT CHPCtrl::RxMonitor(void *pThis)
{


	CHPCtrl		*pCtrl = (CHPCtrl*)pThis;
	int		bytes_recevied = 0;
	
	fd_set		sckt;
	timeval		timeout;

//	Set two second timeout
	timeout.tv_sec	= 2;
	timeout.tv_usec = 0;

//	Monitor all rx traffic
	while ( pCtrl->m_bConnected )
	{

		FD_ZERO( &sckt );
		FD_SET( pCtrl->m_Socket, &sckt );

		int ret = select( 0, &sckt, 0, 0, &timeout );

		switch ( ret )
		{

			case  SOCKET_ERROR:
				//Handle error 
				break;

			case 0:	//Timeout
				//Handle time out
				break;

			default:
				pCtrl->ReadFromSocket( pCtrl->m_Socket );

		} //__switch ( ret )__

	} //__while ( m_bRunRx )__

//	Shutdown rx comm
	shutdown( pCtrl->m_Socket, SD_RECEIVE );

	return 0;

}

masnu wrote:

Please elaborate as to which part of the post wasn't in "international" English and I will be happy to clarify.