rtiExecWebManager.h

Go to the documentation of this file.

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

#ifndef DtRtiExecWebManager_H_
#define DtRtiExecWebManager_H_

#include "rtiMsConfig.h"
#include <wwwSpyAdapter.h>
#include <spyXmlDocument.h>
#include <syncPointXmlBlock.h>
#include <federationListXmlBlock.h>
#include <federationStateXmlBlock.h>
#include <federateStateXmlBlock.h>
#include <rtiMsg.h>
#include <vlThreadedObject.h>
#include <list>
#include <map>

class DtRtiexecObserverForWebService;
class DtWwwControlMsg;

class DT_DLL_EXEC DtRtiExecWebManager
{
public:

   DtRtiExecWebManager( DtRtiexecObserverForWebService& parent, 
      unsigned long connId );
   virtual ~DtRtiExecWebManager();

   virtual bool tickOnce();

   inline const DtString& toXml() const;

   virtual DtFederationStateXmlBlockSP addFederation( const DtString& federationName,
      unsigned long federationHandle, const DtString& fedFileName );
   virtual DtFederationStateXmlBlockSP removeFederation( unsigned long federationHandle );

   virtual DtFederateStateXmlBlockSP addFederate( unsigned long connId, unsigned long federationHandle,
      const DtString& federateName, unsigned long federateHandle, const DtString& host,
      const DtString& webServerHost, int webServerPort ); 
   virtual DtFederateStateXmlBlockSP removeFederate( unsigned long federationHandle,
      unsigned long federateHandle );
   
   virtual DtTimeStateXmlBlockSP setFederateTimeState( unsigned long federationHandle,
      unsigned long federateHandle, bool regulating, bool constrained, const DtString& lbts,
      const DtString& lookahead, const DtString& curTime );

   virtual DtSyncPointXmlBlockSP addSyncPoint( unsigned long federationHandle, const DtString& syncPointName );
   virtual DtSyncPointXmlBlockSP removeSyncPoint( unsigned long federationHandle, const DtString& syncPointName );

   virtual DtSyncPointFederateXmlBlockSP addFederateToSyncPoint( unsigned long federationHandle, const DtString& syncPointName, unsigned long federateHandle );
   
   virtual void syncPointAchieved( unsigned long federationHandle, const DtString& syncPointName, unsigned long federateHandle );

   virtual void processFederateStateUpdateMsg( unsigned long connId, unsigned long federationHandle,
      unsigned long federateHandle, unsigned long stateType, const DtRtiMsg& federateStateMsg );

   virtual void processWwwControlRspMsg( unsigned long connId, unsigned long federationHandle,
      unsigned long federateHandle, unsigned long commandId, const DtRtiMsg& commandMsg );

   virtual void processNetworkMapRspMsg( DtSpyXmlDocumentSP netMap );
   
   inline DtRtiexecObserverForWebService& parent();

   inline DtWwwSpyAdapter& webServer();

protected:

   typedef void ( DtRtiExecWebManager::*MessageHandlerFn)( const DtRtiMsg* );
   typedef std::list< MessageHandlerFn > MessageHandlerList;
   typedef std::map< DtRtiMsgKind, MessageHandlerList > MessageHandlersByKind;

   typedef std::map< unsigned long, DtFederateStateXmlBlockSP > HandleToFederateMap;
   typedef std::pair< DtFederationStateXmlBlockSP, HandleToFederateMap > FederationAndFederatesPair;
   typedef std::map< unsigned long, FederationAndFederatesPair > HandleToFederationMap;

   typedef std::map< DtString, DtSyncPointXmlBlockSP > NameToSyncPointMap;
   typedef std::map< unsigned long, NameToSyncPointMap> FederationHandleToSyncPointsMap;

protected:
   
   virtual void refreshFederationStatePage();

   void refreshNetworkMapPage();


   virtual void registerMsgHandler( DtRtiMsgKind kind, MessageHandlerFn func );
   virtual void unRegisterMsgHandler( DtRtiMsgKind kind, MessageHandlerFn func );

   virtual const MessageHandlerList& messageHandlersForKind( DtRtiMsgKind kind );
   

   virtual void controlMsgHandler( const DtRtiMsg* msg );

   virtual void stateReqHandler( const DtRtiMsg* msg );

   virtual void federateStateReqHandler( const DtRtiMsg* msg );



   virtual void issueStateRequest( const DtWwwControlMsg* cntlMsg );

   virtual void issueLrcLogRequest( const DtWwwControlMsg* cntlMsg );

   virtual void issueDestroyFederationCommand( const DtWwwControlMsg* cntlMsg );

   virtual void issueDeleteFederateCommand( const DtWwwControlMsg* cntlMsg );

   void issueChangeRidParamsCommand( const DtWwwControlMsg* cntlMsg );

   void issueUndiscoverObjectCommand( const DtWwwControlMsg* cntlMsg );
protected:

   DtRtiexecObserverForWebService& myParent;
   unsigned long myConnId;

   DtWwwSpyAdapterSP myWebAdapter;

   DtSpyXmlDocument myXmlStateRepository;
   DtFederationListXmlBlockSP myFederationList;

   DtSpyXmlDocumentSP myXmlNetworkMapStateRepository;


   HandleToFederationMap myFederations;
   FederationHandleToSyncPointsMap mySyncPoints;

   MessageHandlersByKind myMessageHandlers;   
   
};

const DtString& DtRtiExecWebManager::toXml() const
{
   return myXmlStateRepository.toString();
}


inline DtRtiexecObserverForWebService& DtRtiExecWebManager::parent()
{
   return myParent;
}

inline DtWwwSpyAdapter& DtRtiExecWebManager::webServer()
{
   return *myWebAdapter;
}


#endif //! DtRtiExecWebManager_H_