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 <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 DT_DLL_ASSISTANTAPP DtAssistantNetworkCompInfoMgr : public DtAssistantMgr
{
   Q_OBJECT

public:

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

   ~DtAssistantNetworkCompInfoMgr();

private:

   DtAssistantNetworkCompInfoMgr(DtAssistantNetworkCompInfoMgr const& );

   DtAssistantNetworkCompInfoMgr& operator= (DtAssistantNetworkCompInfoMgr 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;



   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 sendObserveForwarderMsg();

   void federateRemovalTimeChanged( float val );

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

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;

   std::set< DtRtiConnectionInfo > myRemotelyViewedConnectionsNeedingUpdate;

   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;

};


#endif