/////////////////////////////////////////////////////////////////////////////
//
// FILE: ServerRS232Array.cpp : implementation file
//
// See _README.CPP
//
// Implementation of the CServerRS232Array class.
//    This class does almost nothing, because we only ever open 1 port.
//    If in future multiple ports are allowed, this class will need 
//    minimal changes.
//
/////////////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "mod_RSsim.h"
#include "ServerRS232Array.h"
#include "MOD_RSsimDlg.h"
#include "abcommsprocessor.h"

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

extern CMOD_simDlg * pGlobalDialog;

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

CServerRS232Array::CServerRS232Array(int size /*= 10*/)
{
   SetSize(size);
}

CServerRS232Array::~CServerRS232Array()
{
// free up all of the items pointed to before this object looses the pointers
CMOD232CommsProcessor * 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 = (CMOD232CommsProcessor *)GetAt(i);  // Make sure to delete all items this array holds 
      SetAt((DWORD)i, NULL);
      if (NULL != sockPtr)
      {
      LONG i=100;
         sockPtr->keepPolling = FALSE;
         OutputDebugString("Stop comms Processor!\n");
         // To-do!!! Must get beter clean-up in here, will 
         // have to wait for thread to finnish running before continuing
         while (i)
         {
            // process our message queue in the meantime while we wait for the thread to die
            pGlobalDialog->MyProcessingLoop(20);
            if (WAIT_OBJECT_0 ==WaitForSingleObject(sockPtr->m_threadDeadEvent, 50))
               break;
            i--;
         }
         // the thread will be dead by now, if it isn't well...
         delete sockPtr;
      }
      i++;
   }
}


// ------------------------- CloseAll -----------------------------------------
// close them all
void CServerRS232Array::CloseAll()
{
//CDDKSrvSocket * sockPtr, *sockPtr1;
CRS232Port *pPort,*pPort1;
LONG n=GetUpperBound(); 

   // go backwards through the list so that the objects
   // are destroyed in reverse order of creation.
   pPort1 = (CRS232Port *)GetAt(0);  // Make sure to delete all items this array holds 
   while (n>=0)
   {
      pPort = (CRS232Port *)GetAt(n);  // Make sure to delete all items this array holds 
      //Remove((HANDLE)n);               // remove from the list
      pPort->keepPolling = FALSE;
      if (NULL != pPort)
         pPort->ClosePort();
         //sockPtr->CloseSocket(TRUE, *sockPtr1->m_pSocket);
      n--;                             
   }
} // CloseAll

// ------------------------- AddServers ------------------------------------
// Start the only port server.
LONG CServerRS232Array::AddServers(DWORD protocolSel,
                                   LPCTSTR portNameShort, 
                                   DWORD  baud, 
                                   DWORD byteSize, 
                                   DWORD parity, 
                                   DWORD stopBits,
                                   DWORD rts,
                                   int responseDelay, 
                                   BOOL MOSCADchecks,
                                   BOOL modifyThenRespond,
                                   BOOL disableWrites,
                                   DWORD PDUSize,
								           BOOL  useBCC,
                                   DWORD source,
                                   DWORD dest,
                                   DWORD files,
                                   BOOL  run,
                                   BOOL JOYread,
                                   BOOL JOYwrite,
                                   DWORD masterIdleTime,
                                   DWORD timeoutValue
                                   )
{
CMOD232CommsProcessor *pServerMOD;
CAB232CommsProcessor *pServerAB;
   
   RemoveAll();
   SetSize(0, 1); //numServers);
   // 1st server is the creator 
   switch (protocolSel)
   {
   case PROTOCOL_SELMOD232 :
      pServerMOD = (CMOD232CommsProcessor *) new CMOD232CommsProcessor(portNameShort, 
                                                             baud, 
                                                             byteSize, 
                                                             parity, 
                                                             stopBits,
                                                             rts,
                                                             responseDelay,
                                                             MOSCADchecks, 
                                                             modifyThenRespond,
                                                             disableWrites);
      pServerMOD->SetPDUSize(PDUSize);
      //pServer1->m_responseDelay = responseDelay;
      pServerMOD->m_threadStartupEvent.SetEvent();// CEvent
      //pServer = pServer1;
   
      // add it to our array
      Add((CObject*)pServerMOD);
      break;
   case PROTOCOL_SELJOY232 :
      pServerAB = (CAB232CommsProcessor *) new CAB232CommsProcessor(portNameShort, 
                                                             baud, 
                                                             byteSize, 
                                                             parity, 
                                                             stopBits,
                                                             rts,
                                                             responseDelay,
                                                             MOSCADchecks, 
                                                             modifyThenRespond,
                                                             disableWrites,
															                useBCC,
                                                             masterIdleTime,
                                                             timeoutValue
                                                             );
      pServerAB->SetPDUSize(PDUSize);
      pServerAB->SetJoyParameters(source, dest, files, run, JOYread, JOYwrite);

      //pServer1->m_responseDelay = responseDelay;
      pServerAB->m_threadStartupEvent.SetEvent();// CEvent
      //pServer = pServer1;
   
      // add it to our array
      Add((CObject*)pServerAB);
      break;
   case PROTOCOL_SELAB232 :
      pServerAB = (CAB232CommsProcessor *) new CAB232CommsProcessor(portNameShort, 
                                                             baud, 
                                                             byteSize, 
                                                             parity, 
                                                             stopBits,
                                                             rts,
                                                             responseDelay,
                                                             MOSCADchecks, 
                                                             modifyThenRespond,
                                                             disableWrites,
                															 useBCC,
                                                             masterIdleTime,
                                                             timeoutValue
                                                             );
      pServerAB->SetPDUSize(PDUSize);
      //pServer1->m_responseDelay = responseDelay;
      pServerAB->m_threadStartupEvent.SetEvent();// CEvent
      //pServer = pServer1;
   
      // add it to our array
      Add((CObject*)pServerAB);
      break;
   }
   // do some idle processing to allow the window to repaint
   pGlobalDialog->MyProcessingLoop(20);
   return (1);
} // AddServers


// -------------------------------- NumberConnected ---------------------------
// return # of sockets that are still connected to something
LONG CServerRS232Array::NumberConnected()
{
CRS232Port *pPort;
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)
   {
      pPort = (CRS232Port *)GetAt(n);  // Make sure to delete all items this array holds 
      if (NULL != pPort)
         if (INVALID_HANDLE_VALUE != pPort->h232Port)
            ret++;
      n--;                             
   }
   return(ret);
} // NumberConnected