execObserverForWebService.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2009 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: execObserverForWebService.h,v $ $Revision: 1.1 $ $State: Exp $
*******************************************************************************/


#ifndef execObserverForWebService_H_
#define execObserverForWebService_H_

#include "rtiMsConfig.h"
#include "execObserver.h"
#include "execCmdProc.h"
#include <RIDparams.h>
#include <memory>

class DtWwwStateRspMsg;
class DtWwwFederateStateRspMsg;
class DtWwwControlRspMsg;
class DtNetworkMapRspMsg;
class DtRtiExecWebManager;

class DT_DLL_EXEC DtRtiexecObserverForWebService : public DtRtiexecObserver
{
public:
   DtRtiexecObserverForWebService( const DtRIDParameters* params,
      DtBoost::shared_ptr<DtRtiexecCmdProc> cmdProc  );
   virtual ~DtRtiexecObserverForWebService();

   virtual void startObservation();



   static void tick( void* usr );
   virtual void tick();

   virtual void processFedExCreatedEvent( DtFedExec* exec );

   virtual void processFedExDestroyedEvent( DtFedExec* exec );

   virtual void processFederateJoinedEvent( DtFedExec* exec, DtFederate* federate );

   virtual void processFederateResignedEvent( DtFedExec* exec, DtFederate* federate );

   virtual void processSyncPtRegisteredEvent( DtFedExec* exec, DtSyncPt* pt );

   virtual void processFederationSynchronizedEvent( DtFedExec* exec, DtSyncPt* pt );

   virtual void processSyncPtAchievedEvent( DtFedExec* exec, DtFederate* federate, DtSyncPt* pt );

   static void processTimeStateEvent( const DtRtiExec& exec, void* usr );
   virtual void processTimeStateEvent( const DtRtiExec& exec );




   static void processStateRspMsg( const DtRtiMsg& msg, void* usr );
   virtual void processStateRspMsg( const DtWwwStateRspMsg& msg );

   static void processFederateStateRspMsg( const DtRtiMsg& msg, void* usr );
   virtual void processFederateStateRspMsg( const DtWwwFederateStateRspMsg& msg );

   static void processControlRspMsg( const DtRtiMsg& msg, void* usr );
   virtual void processControlRspMsg( const DtWwwControlRspMsg& msg );

   static void processNetworkMapRespMsg( const DtRtiMsg& msg, void* usr );
   virtual void processNetworkMapRespMsg( const DtNetworkMapRspMsg& msg );

   virtual void sendMsgToFederation( const DtString& federationName, std::auto_ptr<DtRtiMsg> msg );

   virtual void deleteFederate( const DtString& federationName, unsigned long federateHandle );

   virtual void destroyFederation( const DtString& federationName, unsigned long federationHandle );

   virtual void changeRidParam( const DtString&  federationName, unsigned long federateHandle,  
      const DtString& ridParameter,  const DtString& ridValue );

   inline void setConnectionId( unsigned long connectionId );
   
   inline const DtRIDParameters& params() const;

protected:

   virtual void addCallbacks();

   virtual void removeCallbacks();
     
protected:
   
   const DtRIDParameters* myParams;

   std::auto_ptr<DtRtiExecWebManager> myWebManager;

   DtBoost::shared_ptr<DtRtiexecCmdProc> myCmdProc;

   DtClock myClock;

   const DtTime myMinTimeBetweenUpdates;

   unsigned long myConnectionId;
};

void DtRtiexecObserverForWebService::setConnectionId( unsigned long connectionId )
{
   myConnectionId = connectionId;
}

const DtRIDParameters& DtRtiexecObserverForWebService::params() const
{
   return *myParams;
}

#endif   //! execObserverForWebService_H_