socketrx.cpp

telnet客户端

// SocketRx.cpp: implementation of the CSocketRx class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "Telnet.h"
#include "ProtocolRx.h"
#include "SocketRx.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
CSocketRx::CSocketRx()
{

}

CSocketRx::CSocketRx(SOCKET hSocket,HANDLE &hThread)
{
DWORD dwRet;

	m_nExit = 0;
	m_hThread = NULL;
	m_hSocket = hSocket;

	m_hThread = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE) RdTh,(LPVOID)this,0,&dwRet);
	if ( m_hThread == NULL ) return;
	hThread = m_hThread;
}

CSocketRx::~CSocketRx()
{
	m_nExit = 1;
}
DWORD CSocketRx::RdTh(CSocketRx *pSocketRx)
{
char pBuf[256];
char* scan;
int nRet;

  while(1)
  {
	if ( pSocketRx->m_nExit == 1 ) { ExitThread(0); return 0; }
    nRet = recv(pSocketRx->m_hSocket,pBuf,sizeof(pBuf),0);
	if ( nRet == SOCKET_ERROR ) { TRACE( "\nRaed Fail.........!\n" ); pSocketRx->m_nExit = 1; continue;}
	if ( nRet == 0) Sleep(10);
	scan = pBuf;
	while(nRet--)
	{
		pSocketRx->m_Protocol.TelentProtcol(pSocketRx->m_hSocket,*scan++);
		TRACE("%c ",*scan);
	}

  }
  return 0;
}