forwarderObserver.h

Go to the documentation of this file.

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


#ifndef DtRtiForwarderObserver_H_
#define DtRtiForwarderObserver_H_

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

namespace MAKRti
{
   class DtInetAddr;
}


class DT_DLL_FORWARDER DtRtiForwarderObserver
{

public:

   DtRtiForwarderObserver();

   virtual ~DtRtiForwarderObserver();

   virtual void setMgr( DtRtiForwarderObserverMgr* mgr );

   virtual void initMgr();

   virtual void removeMgr();


   
   virtual int clientToForwarderConnectionEstablished( 
      const MAKRti::DtString& connName, const MAKRti::DtString& connType,
      unsigned int connID, const DtInetAddrAndPort& connAddr ) = 0;

   virtual int clientToForwarderConnectionLost( 
      const MAKRti::DtString& connName, unsigned int connID, 
      const DtInetAddrAndPort& connAddr ) = 0;


   virtual void clientToForwarderFederateJoined( 
      const MAKRti::DtString& connName, const MAKRti::DtString& connType,
      const MAKRti::DtString& federationName,
      unsigned int connID, unsigned int fedHandle,
      const DtInetAddrAndPort& connAddr, const MAKRti::DtString& connHost,
      unsigned int processId, const MAKRti::DtString& processName,
      const MAKRti::DtString& commandArgs, DtHlaVersionId hlaVersion ) = 0;

   virtual void clientToForwarderFederateLost( 
      const MAKRti::DtString& connName, const MAKRti::DtString& connType,
      unsigned int connID, unsigned int fedHandle,
      const DtInetAddrAndPort& connAddr ) = 0;

   virtual int forwarderToForwarderExecConnected(
      const MAKRti::DtString& connName, unsigned int connID,
      const DtInetAddrAndPort& connAddr,
      const MAKRti::DtString& connHost, bool fullyCompliant ) = 0;

   virtual int forwarderToForwarderExecLost(
      const MAKRti::DtString& connName, unsigned int connID,
      const DtInetAddrAndPort& connAddr ) = 0;

   virtual int clientToForwarderExecConnected(
      const MAKRti::DtString& connName, unsigned int connID, 
      const DtInetAddrAndPort& connAddr, const MAKRti::DtString& connHost,
      bool fullyCompliant ) = 0;

   virtual int clientToForwarderExecLost(
      const MAKRti::DtString& connName, unsigned int connID, 
      const DtInetAddrAndPort& connAddr ) = 0;

   virtual void forwarderToForwarderConnectionEstablished( 
      const MAKRti::DtString& connName, unsigned int connID, 
      const DtInetAddrAndPort& connAddr ) = 0;

   virtual void forwarderToForwarderConnectionLost( 
      const MAKRti::DtString& connName, unsigned int connID, 
      const DtInetAddrAndPort& connAddr ) = 0;

   virtual void waitingForFowrarderConnections(
      const DtForwarderPort::DtConnAndNameMap& allNeededFws,
      const DtForwarderPort::DtConnAndNameMap& stillNeededFws ) = 0;

   virtual void notWaitingForFowrarderConnections() = 0;

     
   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, MAKRti::DtTime interval );

   virtual void removeTickCallback( DtTickCbFn fcn );

   virtual int clientToForwarderSocketQueueUpdate( unsigned int connId, int connQueueStatus ) = 0;

   
   virtual unsigned long connectionId() const;

protected:

   virtual void addCallbacks() = 0;

   virtual void removeCallbacks() = 0;

private:
   
   DtRtiForwarderObserver( const DtRtiForwarderObserver& orig );

   DtRtiForwarderObserver& operator=( const DtRtiForwarderObserver& orig );

protected:

   DtRtiForwarderObserverMgr* myMgr;

};


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


#endif