worker.cpp

pocket pc 2003系统下的数据通讯和文件传输

#include "stdafx.h"
#include "Worker.h"

//=============================================================================================
Worker::Worker(int port, int max)
		: m_nCurrThreads (0), m_nMaxThreads (0) , m_nRequests(0) ,
		  CWizRawSocketListener (port)
{
	MaxClient = max;
}


BOOL Worker::TreatData(int index, HANDLE hShutDownEvent, HANDLE hDataTakenEvent)
{
	BOOL ret=TRUE;

	if(++m_nCurrThreads > m_nMaxThreads)
		m_nMaxThreads = m_nCurrThreads;
	
	if(clientSide[index])
		connected[index]=1;
	else
		connected[index]=0;

	if (!CWizRawSocketListener::TreatData (index, hShutDownEvent, hDataTakenEvent))
	{
		--m_nCurrThreads;
		++m_nRequests;
		ret=FALSE;
	}

	if(clientSide[index])
		connected[index]=1;
	else
		connected[index]=0;

	return ret;
}