execObserver.h

Go to the documentation of this file.

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


#ifndef DtRtiexecObserver_H_
#define DtRtiexecObserver_H_

#include "rtiMsConfig.h"
#include "rtiMsg.h"
#include "rtiMsgCbMgr.h"
#include "execObserverMgr.h"

class DtFedExec;
class DtFederate;
namespace MAKRti
{
   class DtInetAddr;
}
class DtSyncPt;

class DT_DLL_EXEC DtRtiexecObserver
{

public:

   DtRtiexecObserver();

   virtual ~DtRtiexecObserver();

   virtual void setMgr( DtRtiexecObserverMgr* mgr );

   virtual void removeMgr();

   virtual void startObservation() {};


   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* fed, DtSyncPt* pt ) {}

   virtual void processFederateDisconnectedEvent( DtFedExec* exec, DtFederate* fed ) {}

   virtual void processFederateReconnectSucceededEvent( DtFedExec* exec, DtFederate* fed ) {}

   virtual void processFederateReconnectFailedEvent( DtFedExec* exec, DtFederate* fed ) {}

   virtual void processLogFileUpdatedEvent( const MAKRti::DtFilename& logFile ) {}
      
   virtual void addRtiMsgCallback( DtRtiMsgKind msgKind, 
      DtRtiMsgCbMgr::DtCallbackFcn fcn, bool isMomCallback = false );

   virtual void removeRtiMsgCallback( DtRtiMsgKind msgKind,
      DtRtiMsgCbMgr::DtCallbackFcn fcn, bool isMomCallback = false );

   virtual void addTickCallback( DtTickCbFn fcn, DtTime interval );

   virtual void removeTickCallback( DtTickCbFn fcn );

   virtual void addTickCallback( DtTickWithExecCbFn fcn, DtTime interval );

   virtual void removeTickCallback( DtTickWithExecCbFn fcn );

   virtual unsigned long connectionId() const;

protected:

   virtual void addCallbacks() = 0;

   virtual void removeCallbacks() = 0;

private:
   
   DtRtiexecObserver( const DtRtiexecObserver& orig );

   DtRtiexecObserver& operator=( const DtRtiexecObserver& orig );

protected:

   DtRtiexecObserverMgr* myMgr;

};


inline unsigned long DtRtiexecObserver::connectionId() const
{
   if( myMgr )
   {
      return myMgr->connectionId();
   }
   else
   {
      return 0;
   }
}


#endif