componentMgr.h

Go to the documentation of this file.

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

#ifndef componentMgr_H_
#define componentMgr_H_


#include "rtiMsConfig.h"
#include "assistantMgr.h"
#include "assistantConnectionInfo.h"
#include "connectionAndConfiguration.h"
#include "assistantConnectionConfigurationInfo.h"
#include "assistantConnMsg.h"
#include <rtiVersion.h>
#include <vlutil/vlTime.h>

class DtAssistantLrcCompInfoMsg;
class DtAssistantRtiexecCompInfoMsg;
class DtAssistantRtiForwarderCompInfoMsg;
class DtAssistantExecStateMsg;
class DtAssistantComponentInfo;
class DtAssistantSignalRouter;

typedef std::map< int, std::shared_ptr<DtAssistantComponentInfo> > DtIdToComponentInfoMap;

class DT_DLL_ASSISTANTAPP DtAssistantComponentMgr : public DtAssistantMgr
{
   Q_OBJECT

public:

   DtAssistantComponentMgr( std::shared_ptr<DtRtiAssistantServer> server,
      std::shared_ptr<DtRtiAssistantPeer> peer,
      DtAssistantSignalRouter& signalRouter );

   virtual ~DtAssistantComponentMgr();

private:

   DtAssistantComponentMgr(DtAssistantComponentMgr const& );

   DtAssistantComponentMgr& operator= (DtAssistantComponentMgr const& );

public:


   virtual const DtAssistantComponentInfo* componentInfo( int compId ) const;

   virtual const DtIdToComponentInfoMap& components() const;

   virtual const DtIdToComponentInfoMap& rtiexecComponents() const;

   virtual const DtIdToComponentInfoMap& lrcComponents() const;

   virtual const DtIdToComponentInfoMap& forwarderComponents() const;

   virtual const DtIdToComponentInfoMap& sharedMemComponents() const;

   virtual MAKRti::DtString printLocalComponentList() const;

   virtual MAKRti::DtString printFederationList(const DtAssistantExecStateMsg& msg);

   virtual MAKRti::DtString printRtiExecComponentsList(std::map<int, MAKRti::DtString>& data) const;

   virtual MAKRti::DtString printForwarderComponentsList(const std::map<int, MAKRti::DtString>& data) const;

public slots:

   virtual void updateComponent( int compId, const DtAssistantComponentInfo& comp );

protected:


   static void processConnMsg(const DtAssistantConnMsg& msg, void* usr);

   virtual void processConnMsg(const DtAssistantConnMsg& msg);

   virtual void processNewConnMsg(const DtAssistantConnMsg& msg);

   virtual void processCloseConnMsg(const DtAssistantConnMsg& msg);

   static void processLrcCompInfoMsg(const DtAssistantLrcCompInfoMsg& msg, void* usr);

   virtual void processLrcCompInfoMsg(const DtAssistantLrcCompInfoMsg& msg);

   static void processRtiexecCompInfoMsg(const DtAssistantRtiexecCompInfoMsg& msg, void* usr);

   virtual void processRtiexecCompInfoMsg(const DtAssistantRtiexecCompInfoMsg& msg);

   static void processRtiForwarderCompInfoMsg(const DtAssistantRtiForwarderCompInfoMsg& msg, void* usr);

   virtual void processRtiForwarderCompInfoMsg(const DtAssistantRtiForwarderCompInfoMsg& msg);


   static void processSocketRemoval(int compId, const MAKRti::DtString& reason, void* usr);

   virtual void processSocketRemoval(int compId, const MAKRti::DtString& reason);

signals:


   void lrcComponentAdded( const DtAssistantComponentInfo* );
   void rtiexecComponentAdded( const DtAssistantComponentInfo* );
   void forwarderComponentAdded( const DtAssistantComponentInfo* );
   void sharedMemComponentAdded( const DtAssistantComponentInfo* );


   void lrcComponentRemoved( const DtAssistantComponentInfo* );
   void rtiexecComponentRemoved( const DtAssistantComponentInfo* );
   void forwarderComponentRemoved( const DtAssistantComponentInfo* );
   void sharedMemComponentRemoved( const DtAssistantComponentInfo* );


   void lrcComponentRemovedUnexpectedly( const DtAssistantComponentInfo* );
   void rtiexecComponentRemovedUnexpectedly( const DtAssistantComponentInfo* );
   void forwarderComponentRemovedUnexpectedly( const DtAssistantComponentInfo* );
   void sharedMemComponentRemovedUnexpectedly( const DtAssistantComponentInfo* );


   void lrcComponentRenamed( const DtAssistantComponentInfo* );
   void rtiexecComponentRenamed( const DtAssistantComponentInfo* );
   void forwarderComponentRenamed( const DtAssistantComponentInfo* );
   void sharedMemComponentRenamed( const DtAssistantComponentInfo* );


   void lrcComponentConnected( const DtAssistantComponentInfo* );
   void rtiexecComponentConnected( const DtAssistantComponentInfo* );
   void forwarderComponentConnected( const DtAssistantComponentInfo* );


   void lrcComponentDisconnected( const DtAssistantComponentInfo* );
   void rtiexecComponentDisconnected( const DtAssistantComponentInfo* );
   void forwarderComponentDisconnected( const DtAssistantComponentInfo* );


   void lrcComponentUpdated( const DtAssistantComponentInfo* );
   void rtiexecComponentUpdated( const DtAssistantComponentInfo* );
   void forwarderComponentUpdated( const DtAssistantComponentInfo* );
   void sharedMemComponentUpdated( const DtAssistantComponentInfo* );

   void recoverConnection(const DtRtiConnectionInfo& connInfo, DtRtiConnectionInfo& recoveredConn);

   void localFederateJoined( const DtAssistantComponentInfo*,
      const MAKRti::DtString& federateType,
      const MAKRti::DtString& federateName,
      unsigned federateHandle,
      const MAKRti::DtString& federationName,
      unsigned federationHandle,
      DtHlaVersionId hlaVersion );

   void localFederateResigned( const DtAssistantComponentInfo* );

   void forwarderHasRtiexec( const DtAssistantComponentInfo* );

   void forwarderHasNoRtiexec( const DtAssistantComponentInfo* );
protected:


   DtIdToComponentInfoMap myComponentsById;

   DtIdToComponentInfoMap myRtiExecComponentsById;

   DtIdToComponentInfoMap myLrcComponentsById;

   DtIdToComponentInfoMap myForwarderComponentsById;

   DtIdToComponentInfoMap mySharedMemComponentsById;

   DtClock myClock;
};

#endif