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 DtAssistantPreferencesInfoMgr;
class DtAssistantLrcCompInfoMsg;
class DtAssistantRtiexecCompInfoMsg;
class DtAssistantShmExecCompInfoMsg;
class DtAssistantWwwCompInfoMsg;
class DtAssistantRtiForwarderCompInfoMsg;
class DtAssistantExecStateMsg;
class DtAssistantForwarderStateMsg;
class DtAssistantSignalTickedMsg;
class DtAssistantComponentInfo;

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

class DT_DLL_ASSISTANTAPP DtAssistantComponentMgr : public DtAssistantMgr
{
   Q_OBJECT

public:

   DtAssistantComponentMgr( DtBoost::shared_ptr<DtRtiAssistantServer> server,
      DtBoost::shared_ptr<DtRtiAssistantPeer> peer,
      DtBoost::shared_ptr<DtAssistantPreferencesInfoMgr> prefMgr );

   virtual ~DtAssistantComponentMgr();

private:

   DtAssistantComponentMgr(DtAssistantComponentMgr const& );

   DtAssistantComponentMgr& operator= (DtAssistantComponentMgr const& );

public:


   virtual const DtAssistantComponentInfo* componentInfo( int compId ) const;

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

   virtual const DtIdToComponentInfoMap& components() const;

   virtual const DtIdToComponentInfoMap& rtiexecComponents() const;

   virtual const DtIdToComponentInfoMap& lrcComponents() const;

   virtual const DtIdToComponentInfoMap& forwarderComponents() const;

   virtual const DtIdToComponentInfoMap& webServerComponents() 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;

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 processWwwCompInfoMsg(const DtAssistantWwwCompInfoMsg& msg, void* usr);

   virtual void processWwwCompInfoMsg(const DtAssistantWwwCompInfoMsg& msg);


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

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

signals:


   void lrcComponentAdded( int compId );
   void rtiexecComponentAdded( int compId );
   void forwarderComponentAdded( int compId );
   void webServerComponentAdded( int compId );
   void sharedMemComponentAdded( int compId );


   void lrcComponentRemoved( int compId );
   void rtiexecComponentRemoved( int compId );
   void forwarderComponentRemoved( int compId );
   void webServerComponentRemoved( int compId );
   void sharedMemComponentRemoved( int compId );


   void lrcComponentRemovedUnexpectedly( int compId );
   void rtiexecComponentRemovedUnexpectedly( int compId );
   void forwarderComponentRemovedUnexpectedly( int compId );
   void webServerComponentRemovedUnexpectedly( int compId );
   void sharedMemComponentRemovedUnexpectedly( int compId );


   void lrcComponentRenamed( int compId );
   void rtiexecComponentRenamed( int compId );
   void forwarderComponentRenamed( int compId );
   void webServerComponentRenamed( int compId );
   void sharedMemComponentRenamed( int compId );


   void lrcComponentConnected( int compId );
   void rtiexecComponentConnected( int compId );
   void forwarderComponentConnected( int compId );


   void lrcComponentDisconnected( int compId );
   void rtiexecComponentDisconnected( int compId );
   void forwarderComponentDisconnected( int compId );


   void lrcComponentUpdated( int compId );
   void rtiexecComponentUpdated( int compId );
   void forwarderComponentUpdated( int compId );
   void webServerComponentUpdated( int compId );
   void sharedMemComponentUpdated( int compId );

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

   void localFederateResigned( int compId );

   void forwarderHasRtiexec( int compId );

   void forwarderHasNoRtiexec( int compId );

protected:

   DtBoost::shared_ptr<DtAssistantPreferencesInfoMgr> myPrefMgr;


   DtIdToComponentInfoMap myComponentsById;

   DtIdToComponentInfoMap myRtiExecComponentsById;

   DtIdToComponentInfoMap myLrcComponentsById;

   DtIdToComponentInfoMap myForwarderComponentsById;

   DtIdToComponentInfoMap myWebComponentsById;

   DtIdToComponentInfoMap mySharedMemComponentsById;

   DtClock myClock;
};

#endif