networkCompInfoMgr.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2011 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: networkCompInfoMgr.h,v $ $Revision: 1.16 $ $State: Exp $
*********************************************************************/

#ifndef networkCompInfoMgr_H_
#define networkCompInfoMgr_H_


#include <map>
#include <set>
#include <rtiMsConfig.h>
#include <vlutil/vlFilename.h>
#include <assistantConnectionInfo.h>
#include "assistantMgr.h"

class DtRtiAssistantServer;
class DtRtiAssistantPeer;
class DtAssistantMsg;
class DtAssistantSignalRouter;
class DtAssistantComponentMgr;
class DtAssistantConnectionInfoMgr;
class DtAssistantForwarderInfo;
class DtAssistantStateObserveMsg;
class DtAssistantForwarderStateMsg;
class DtAssistantCommandMsg;
class DtRtiConnectionAndConfiguration;
class DtAssistantNetworkCompInfo;

class DT_DLL_ASSISTANTAPP DtAssistantForwarderCompInfoMgr : public DtAssistantMgr
{
   Q_OBJECT

public:

   DtAssistantForwarderCompInfoMgr( DtBoost::shared_ptr<DtRtiAssistantServer> server,
      DtBoost::shared_ptr<DtRtiAssistantPeer> peer,
      DtAssistantSignalRouter& signalRouter,
      DtBoost::shared_ptr<DtAssistantComponentMgr> compMgr,
      DtBoost::shared_ptr<DtAssistantConnectionInfoMgr> connInfoMgr );

   ~DtAssistantForwarderCompInfoMgr();

private:

   DtAssistantForwarderCompInfoMgr(DtAssistantForwarderCompInfoMgr const& );

   DtAssistantForwarderCompInfoMgr& operator= (DtAssistantForwarderCompInfoMgr const& );

public:

   virtual void tick();

   virtual bool isLocalForwarder(const DtRtiConnectionInfo& conn) const;

   virtual bool isRemoteForwarder(const DtRtiConnectionInfo& conn) const;

   virtual void requestSingleUpdateFromConnectedForwarders(int id);

   virtual void viewNetworkComponentsForConnection(const DtRtiConnectionInfo& conn);

   virtual const DtAssistantForwarderInfo* forwarderInfo(const DtRtiConnectionInfo& conn) const;

   const std::set<const DtAssistantForwarderInfo*> peerForwarderInfos(const DtRtiConnectionInfo& conn) const;

   virtual std::pair<DtRtiConnectionInfo, bool> forwarderConnectionInfo(const DtAssistantNetworkCompInfo& conn) const;

   virtual bool isObservedPeerOfViewedConnection(const DtRtiConnectionInfo& conn) const;

   virtual void updateObservedPeers(const DtRtiConnectionInfo& conn, bool addOrRemove);

   virtual int getPeerForwarders(const DtRtiConnectionInfo& conn, std::set<DtRtiConnectionInfo>& peers) const;

   virtual bool isPeerForwarder(const DtRtiConnectionInfo& conn, const DtRtiConnectionInfo& peerConn) const;



   static void processForwarderObserveMsg( const DtAssistantStateObserveMsg& msg, void* usr );

   virtual void processForwarderObserveMsg( const DtAssistantStateObserveMsg& msg );

   static void processForwarderStateMsgForConnection( 
      const DtAssistantForwarderStateMsg& msg, void* usr );

   virtual void processForwarderStateMsgForConnection( 
      const DtAssistantForwarderStateMsg& msg );

   // Process state message, handle RTI command requests if any.
   virtual void handleRtiCommands( const DtAssistantForwarderStateMsg& msg );

   static void processAssistantCommandMsg(const DtAssistantCommandMsg& msg, void* usr);

   virtual void processAssistantCommandMsg(const DtAssistantCommandMsg& msg);

public slots:

   void processConnectionsUpdate( const DtRtiConnectionAndConfiguration& conns );

   void processConnectionsRemoval( const DtRtiConnectionAndConfiguration& conns );

   void sendAllForwarderInfo();

   void sendObserveForwarderMsgToPeer(bool shouldObserve = true);

   void sendObserveForwarderMsgForViewedPeers(bool shouldObserve = true);

   void federateRemovalTimeChanged( float val );

   void provideForwarderInfo(const DtRtiConnectionInfo& conn,
      const DtAssistantForwarderInfo** info);

   void providePeerForwarderInfo(const DtRtiConnectionInfo&,
      std::vector<DtAssistantForwarderInfo>*);

signals:

   void forwarderAdded(const DtRtiConnectionInfo& conn);

   void forwarderConnUpdated(const DtRtiConnectionInfo& conn);

   void forwarderUpdated(const DtRtiConnectionInfo& conn);

   void forwarderRemoved(const DtRtiConnectionInfo& conn);

protected:

   virtual void pruneTimedOutSingleUpdates();

protected:

   typedef std::map< DtRtiConnectionInfo, DtAssistantInfoSet > DtConnectionToObserversMap;
   typedef std::map< DtRtiConnectionInfo, DtAssistantForwarderInfo > DtForwarderStateByConnectionMap;

   DtBoost::shared_ptr<DtAssistantComponentMgr> myCompMgr;

   DtBoost::shared_ptr<DtAssistantConnectionInfoMgr> myConnInfoMgr;

   DtRtiConnectionInfo myViewedRtiForwarder;

   DtConnectionToObserversMap myRemotelyViewedRtiForwarders;

   DtForwarderStateByConnectionMap myRemoteForwarders;

   DtForwarderStateByConnectionMap myLocalForwarders;

   MAKRti::DtClock myClock;

   unsigned int myTimeStateUpdateInterval;

   float myDefunctRemovalTime; 

   std::map<std::pair<int, MAKRti::DtTime>, std::map<int, MAKRti::DtString> > myRequestedRtiForwarderUpdates;

   static const int theTimeToWaitForForwarderInfo;

   std::set<DtRtiConnectionInfo> myObservedPeerRtiForwarderSet;

};


#endif