rtiExecConnectionState.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2006 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: rtiExecConnectionState.h,v $ $Revision: 1.6 $ $State: Exp $
*********************************************************************/

#ifndef DtRtiExecConnectionState22_H_
#define DtRtiExecConnectionState22_H_

#include <vlutil/vlList.h>
#include <vlutil/vlString.h>
#include <list>
#include "rtiMsConfig.h"
#include <assert.h>
#include <vlutil/vlPrint.h>
#include <vlutil/vlTime.h>

class DtTcpMsgSocket;

//Singleton Class.
//Container class for connection information/status about the rtiExec.  
class DT_DLL_FORWARDER DtRtiExecConnectionState
{
private:

   DtRtiExecConnectionState(const DtRtiExecConnectionState& orig);
   DtRtiExecConnectionState& operator=(const DtRtiExecConnectionState& orig);

public:


   enum rtiExecConnectionStateDefns
   {
      DtNotConnected,
      DtConnectedAndRunning,
      DtWaitingForReconnect,
      DtReconnectFailed
   };

   //Creation and destruction 
   DtRtiExecConnectionState(bool reconnectEnabled, MAKRti::DtTime rtiExecReconnectTimeout);      
   ~DtRtiExecConnectionState();   

   unsigned int rtiExecConnID() const;

   const DtTcpMsgSocket* rtiExecSock() const;

   bool rtiExecAvailable() const;

   bool rtiExecIsLocalConnection() const;

   bool noConnectionAvailable() const;

   bool isWaitingForReconnect() const;

   //rather than storing a DtRidParameters object in its entirety, we simply store the one 
   bool reconnectEnabled() const;

   bool hasTimeElapsed() const;

   void resetRtiExecConnID();

   MAKRti::DtString hostName() const;

   //State transition functions, filter will notify us of events and we'll respond appropriately.     

   bool rtiExecTimedOutReconnect();
   
   bool rtiExecDisconnected();

   bool rtiExecDisconnectMsgReceived();

   bool rtiExecConnected(unsigned int newConnectionID, 
                         const DtTcpMsgSocket* execSock,
                         const MAKRti::DtString& hostName );

   bool rtiExecReconnected(unsigned int newConnectionID, 
                           const DtTcpMsgSocket* execSock,
                           const MAKRti::DtString& hostName );

   bool testRtiExecConnectionStatus();

protected:

   //void setRtiExecConnID(unsigned int newConnectionID);

 

protected:
   bool                             myRtiExecAvailable;
   bool                             myRtiExecIsLocallyConnected;
   unsigned int                     myRtiExecConnID;
   const DtTcpMsgSocket*       myExecSock;
   rtiExecConnectionStateDefns      myRtiExecState;
   bool                             myReconnectEnabled;
   MAKRti::DtTime                   myRtiExecReconnectTimeout;
   MAKRti::DtClock                  myTimer;
   MAKRti::DtClock                  myPingTimer;
   MAKRti::DtString                 myExecHostname;
      
};



#endif //! DtRtiExecConnectionState22_H_