execObserverMgr.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2008 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: execObserverMgr.h,v $ $Revision: 1.3 $ $State: Exp $
*******************************************************************************/


#ifndef DtRtiexecObserverMgr_H_
#define DtRtiexecObserverMgr_H_

#include "rtiMsConfig.h"
#include "rtiMsg.h"
#include "rtiMsgCbMgr.h"
#include "exec.h"
#include <vlutil/vlSmartPointers.h>
#include <vlutil/vlTime.h>
#include <map>
#include <list>

class DtRtiExec;
class DtFedExec;
class DtFedExCbInfo;
class DtRtiexecObserver;
class DtFederate;
class DtSyncPt;
class DtTickCallbackInfo;
class DtTickWithExecCallbackInfo;

class DtMsgCbInfo {
public:
   DtMsgCbInfo( DtRtiMsgKind msgKind, DtRtiMsgCbMgr::DtCallbackFcn fcn,
      DtRtiexecObserver* observer, bool isMomCallback ) :
      myMsgKind( msgKind ), myFcn( fcn ), myObserver( observer ), 
      myIsMomCallback( isMomCallback ) {}
   ~DtMsgCbInfo() {}

   bool operator<(const DtMsgCbInfo& other) const
   {
      return ( myMsgKind < other.myMsgKind ||
         ( myMsgKind == other.myMsgKind && myFcn < other.myFcn ) ||
         ( myMsgKind == other.myMsgKind && myFcn == other.myFcn && myObserver < other.myObserver ) );
   }

   DtRtiMsgKind myMsgKind; 
   DtRtiMsgCbMgr::DtCallbackFcn myFcn;
   DtRtiexecObserver* myObserver;
   bool myIsMomCallback;
};

class DT_DLL_EXEC DtRtiexecObserverMgr
{

public:

   DtRtiexecObserverMgr();

   virtual ~DtRtiexecObserverMgr();

   virtual void setExec( DtBoost::shared_ptr<DtRtiExec> exec );

   virtual void addObserver( DtBoost::shared_ptr<DtRtiexecObserver> observer );

   virtual void removeObserver( DtBoost::shared_ptr<DtRtiexecObserver> observer );

   virtual void removeAllObservers();

   virtual void addRtiMsgCallback( DtRtiMsgKind msgKind, 
      DtRtiMsgCbMgr::DtCallbackFcn fcn, DtRtiexecObserver* observer,
      bool isMomCallback );

   virtual void removeRtiMsgCallback( DtRtiMsgKind msgKind, 
      DtRtiMsgCbMgr::DtCallbackFcn fcn, DtRtiexecObserver* observer,
      bool isMomCallback );

   virtual void addTickCallback( DtTickCbFn fcn, DtRtiexecObserver* observer, 
      DtTime interval );

   virtual void removeTickCallback( DtTickCbFn fcn, DtRtiexecObserver* observer );

   virtual void addTickCallback( DtTickWithExecCbFn fcn, DtRtiexecObserver* observer,
      DtTime interval );

   virtual void removeTickCallback( DtTickWithExecCbFn fcn, DtRtiexecObserver* observer );

   static void federationCreatedCallback( DtFedExec* exec, void* usr );
   void federationCreatedCallback( DtFedExec* exec );

   static void federationDestroyedCallback( DtFedExec* exec, void* usr );
   void federationDestroyedCallback( DtFedExec* exec );

   static void federateJoinedCallback( DtFederate* federate, void* usr );
   void federateJoinedCallback( DtFedExec* exec, DtFederate* federate );

   static void federateResignedCallback( DtFederate* federate, void* usr );
   void federateResignedCallback( DtFedExec* exec, DtFederate* federate );

   static void syncPtRegisteredCallback( DtSyncPt* pt, void* usr );
   void syncPtRegisteredCallback( DtFedExec* exec, DtSyncPt* pt );

   static void federationSynchronizedCallback( DtSyncPt* pt, void* usr );
   void federationSynchronizedCallback( DtFedExec* exec, DtSyncPt* pt );

   static void syncPtAchievedCallback( DtFederate* fed, DtSyncPt* pt, void* usr );
   void syncPtAchievedCallback( DtFedExec* exec, DtFederate* fed, DtSyncPt* pt );

   static void federateDisconnectedCallback( DtFederate* fed, void* usr );
   void federateDisconnectedCallback( DtFedExec* exec, DtFederate* fed );

   static void federateReconnectSucceededCallback( DtFederate* fed, void* usr );
   void federateReconnectSucceededCallback( DtFedExec* exec, DtFederate* fed);

   static void federateReconnectFailedCallback( DtFederate* fed, void* usr );
   void federateReconnectFailedCallback( DtFedExec* exec, DtFederate* fed);

   static void updateLogFileNameCallback( const DtFilename& logFile, void* usr );
   void updateLogFileNameCallback( const DtFilename& logFile );

   static void updateWebServerCallback( const DtInetAddr& webSpyIpAddr, int webSpyPort, void* usr );
   void updateWebServerCallback( const DtInetAddr& webSpyIpAddr, int webSpyPort );

   virtual unsigned long connectionId() const;

protected:
   
   DtRtiexecObserverMgr( const DtRtiexecObserverMgr& orig );

   DtRtiexecObserverMgr& operator=( const DtRtiexecObserverMgr& orig );

protected:

   typedef std::map<DtFedExec*, DtFedExCbInfo*> DtFedexToCbInfoMap;
   typedef std::set<DtMsgCbInfo> DtMsgCbSet;
   typedef std::set<DtTickCallbackInfo> DtTickCbSet;
   typedef std::set<DtTickWithExecCallbackInfo> DtTickWithExecCbSet;
   typedef std::list< DtBoost::shared_ptr<DtRtiexecObserver> > DtExecObsList;

   DtBoost::shared_ptr<DtRtiExec> myExec;

   DtExecObsList myObservers;

   DtMsgCbSet myMsgCbSet;

   DtTickCbSet myTickCbSet;

   DtTickWithExecCbSet myTickWithExecCbSet;

   DtFedexToCbInfoMap myFedexInfoMap;
};


#endif