Simple, Robust and Expandable Winsock Server for Multiple Clients with Easy to Add New Services

/*
In this module is the working thread functions VmThrdFnctn and also 
the CVMThrd class implementation.

Author Vadim Motorine  
email vad@friendly-ware.com
Copyright (C) 2006 Vadim Motorine 
*/

#include "StdAfx.h"
#include "VMThrd.h"
#include "TimeTskPsprt.h"
#include "winsock2.h"
#include "vmSafeWinSock.h"
#include <string>
#include "DoItVM.h"


CVMThrd::CVMThrd(CTskPsprt* tskPsprtPi)
:thrdHndl(0)
,tskPsprtP(tskPsprtPi)
,isOK(false)
{
	RnThrd();//starts the thread
}

CVMThrd::~CVMThrd(void)
{

}

/* The working thread function. It is responsible for the data exchange with the server*/
DWORD WINAPI VmThrdFnctn(void* tskPsprtP)
{
//The class to exchange  the information with the main appliacation thread
	CTskPsprt* tskPsprtT = reinterpret_cast<CTskPsprt*>(tskPsprtP);
	CSafeExtThrd sfExtTrd(tskPsprtT); //some common tasks on exit the thread are in the destructor.
	CDoItVM doit(tskPsprtT);//  the main class to develop the recieved data
//The read only part of task to the thread	(port, IP address etc.)
	STskOnly tskOnly;
//the event to start new task	
	HANDLE evntHndle = tskPsprtT->GetEvnrHdl();
	
	while(true){
//Resets the flag that the thread is alive and was not asked to stop the task;
//Reset should be at the beginning. The point is that before assigning new task the main program
//asks to stop previous task just for the case. Inside the task it also may do this.
		tskPsprtT->Reset();//isToStpp = false,  means that the task interruption was not requested

//getting the new task
		tskPsprtT->CopyTskOnly(&tskOnly);//synchronouse getting	the new task;
		ResetEvent(evntHndle);//will wait new task at the end
		doit.Prfrm(&tskOnly);//does all the job
//If to diconnect		
		if(tskOnly.tskID == CVMprotocolCr::BY_BY){
			return 0;			
		}
		WaitForSingleObject(evntHndle,INFINITE);//waits for the new task
	}
	
	
	return 0;
}

//Starts the thread
void CVMThrd::RnThrd()
{
	DWORD trdID;
	thrdHndl = chBEGINTHREADEX(NULL,0,VmThrdFnctn,tskPsprtP,NULL,&trdID);
	if(!thrdHndl){
		tskPsprtP->SetStopped();
		tskPsprtP->SetIsItCnnctd(false);
		AfxMessageBox("Cannot start the thread");
	}
	isOK = true;
}