// ServerSocketArray.cpp: implementation of the CServerSocketArray class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "mod_rssim.h"
#include "ServerSocketArray.h"
#include "MOD_rssimDlg.h"

//#include "modcommsprocessor.h"

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

extern CMOD_simDlg * pGlobalDialog;

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CServerSocketArray::CServerSocketArray(int size /*= 10*/)
{
	SetSize(size);
	kill = FALSE;
	initiating = FALSE;
}

CServerSocketArray::~CServerSocketArray()
{
	// free up all of the items pointed to before this object looses the pointers
	CMODEthCommsProcessor * sockPtr;  
	LONG n=GetUpperBound(),i=0;
	
	// go backwards through the list so that the objects
	// are destroyed in reverse order of creation.
	while (i<=n)
	{
		sockPtr = (CMODEthCommsProcessor *)GetAt(i);  // Make sure to delete all items this array holds 
		SetAt((DWORD)i, NULL);
		if (NULL != sockPtr)
			delete sockPtr;
		i++;
	}
}


// ------------------------- CloseAll -----------------------------------------
// close them all
void CServerSocketArray::CloseAll()
{
	CDDKSrvSocket * sockPtr, *sockPtr1;
	LONG n=GetUpperBound(); 
	
	// go backwards through the list so that the objects
	// are destroyed in reverse order of creation.
	sockPtr1 = (CDDKSrvSocket *)GetAt(0);  // Make sure to delete all items this array holds 
	while (n>=0)
	{
		sockPtr = (CDDKSrvSocket *)GetAt(n);  // Make sure to delete all items this array holds 
		//Remove((HANDLE)n);               // remove from the list
		if ((NULL != sockPtr) && (NULL != sockPtr1->m_pSocket))
			sockPtr->CloseSocket(TRUE, *sockPtr1->m_pSocket);
		n--;                             
	}
} // CloseAll

// ------------------------- AddServers ------------------------------------
// Start all the servers you want
LONG CServerSocketArray::AddServers(int numServers, 
                                    int port, 
                                    int responseDelay, 
                                    BOOL linger,
                                    BOOL MOSCADchecks,
                                    BOOL modifyThenRespond,
                                    BOOL disableWrites,
                                    DWORD PDUSize)
{
	int index;
	CMODEthCommsProcessor *pServer1;
	CMODEthCommsProcessor *pServer;
	
	initiating = TRUE;   
	RemoveAll();
	SetSize(0,numServers);
	for (index = 0; index < numServers; index++)
	{
		if (kill)
			return(index);
		if (0==index)
		{ // 1st server is the creator of the listen socket
			pServer1 = (CMODEthCommsProcessor *) new CMODEthCommsProcessor(responseDelay,
				MOSCADchecks,
				modifyThenRespond,
				disableWrites,
				PDUSize,
				port);
			//pServer1->SetPDUSize(PDUSize);
			//pServer1->m_responseDelay = responseDelay;
			
			pServer1->m_linger = linger;
			pServer1->m_threadStartupEvent.SetEvent();// CEvent
			pServer = pServer1;
		}
		else
		{
			pServer = (CMODEthCommsProcessor *) new CMODEthCommsProcessor(responseDelay,
				MOSCADchecks,
				modifyThenRespond,
				disableWrites,
				PDUSize,
				&pServer1->m_socket);
			//pServer->m_responseDelay = responseDelay;
			pServer->m_linger = linger;
			pServer->m_threadStartupEvent.SetEvent();// CEvent
		}
		// add it to our array
		//SetAt(index, (CObject*)pServer);
		Add((CObject*)pServer);
		
		if (kill)
			return(index);
		// do some idle processing to allow the window to repaint
		pGlobalDialog->MyProcessingLoop(20);
	}
	initiating = FALSE;
	return (index);
} // AddServers


// -------------------------------- NumberConnected ---------------------------
// return # of sockets that are still connected to something
LONG CServerSocketArray::NumberConnected()
{
	CDDKSrvSocket * sockPtr;  
	LONG n=GetUpperBound(); 
	LONG ret = 0;
	
	// go backwards through the list so that the objects
	// are destroyed in reverse order of creation.
	while (n>=0)
	{
		sockPtr = (CDDKSrvSocket *)GetAt(n);  // Make sure to delete all items this array holds 
		if (NULL != sockPtr)
			if (sockPtr->accepted)
				ret++;
			n--;                             
	}
	return(ret);
} // NumberConnected

// -------------------------------- FirstConnected ---------------------------
// return # of sockets that are still connected to something
SOCKET CServerSocketArray::FirstConnected()
{
	CDDKSrvSocket * sockPtr;  
	LONG n=GetUpperBound(); 
	LONG ret = 0;
	
	// go backwards through the list so that the objects
	// are destroyed in reverse order of creation.
	while (n>=0)
	{
		sockPtr = (CDDKSrvSocket *)GetAt(n);  // Make sure to delete all items this array holds 
		if (NULL != sockPtr)
			if (sockPtr->accepted)
				return(sockPtr->AcceptedAsyncSocket);
			n--;                             
	}
	return(INVALID_SOCKET);
} // FirstConnected