federateViewMgr.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2012 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/

#ifndef federateViewMgr_H_
#define federateViewMgr_H_

#include "rtiMsConfig.h"
#include "assistantMgr.h"
#include "assistantSignalRouter.h"
#include "rtiVersion.h"
#include "compInfo.h"
#include "assistantConnectionInfo.h"

#include <vlutil/vlFilename.h>
#include "assistantNetStatsStringUpdateMsg.h"
#include "assistantNetStatsStringReqMsg.h"


class DtAssistantComponentInfo;
class DtFederateStatisticsDialog;
class DtAssistantFederateInfo;
class DtAssistantForwarderInfo;
class DtAssistantNetStatsObserveReqMsg;
class DtAssistantNetStatsObserveRspMsg;
class DtAssistantNetStatsMsgUpdateMsg;
class DtAssistantNetStatsRtiAmbUpdateMsg;
class DtAssistantNetStatsFedAmbUpdateMsg;
class DtAssistantNetStatsObservationMgr;
class DtAssistantNetStatsObjectsUpdateMsg;
class DtAssistantNetStatsInteractionsUpdateMsg;
class DtAssistantNetStatsStringUpdateMsg;

typedef std::map< unsigned int, MAKRti::DtString > DtNamesByHandleMap;
typedef std::map< unsigned int, DtNamesByHandleMap > DtNameByHandleMapByLrcCompIdMap;

typedef std::pair<DtAssistantInfo, unsigned int> DtAssistantInfoCompIdPair;
typedef std::pair<MAKRti::DtString, unsigned int> DtFederationNameFederateHandlePair;
typedef std::pair<DtRtiConnectionInfo, DtFederationNameFederateHandlePair> DtConnectionInfoFederationNameFederateHandleTriple;

#define DtAssistantInvalidCompId -1
class DT_DLL_ASSISTANTAPP DtAssistantFederateViewMgr : public DtAssistantMgr
{
  Q_OBJECT

public:
    DtAssistantFederateViewMgr(DtBoost::shared_ptr<DtRtiAssistantServer> server,
        DtBoost::shared_ptr<DtRtiAssistantPeer> peer,
        DtAssistantSignalRouter& signalRouter,
        const MAKRti::DtFilename& configDir);

    ~DtAssistantFederateViewMgr();

    virtual void startShutdown();

public slots:

   void showFederateStatsDialog( const DtRtiConnectionInfo& connInfo, 
      const MAKRti::DtString& federationName, unsigned int federateHandle );

   void processFederateRemoval( const DtAssistantComponentInfo* comp );

   void processFederateRemoval( const DtRtiConnectionInfo& conn, 
      const MAKRti::DtString& federationName, unsigned federateHandle );

   void sendFederateObservationRequest(const DtRtiConnectionInfo& connInfo,
      const MAKRti::DtString& federationName, unsigned federateHdl,
      const DtAssistantInfo& astnt, unsigned compId);

   void processLocalRtiComponentConnected( const DtAssistantComponentInfo* compInfo);
   void processLocalRtiComponentDisconnected( const DtAssistantComponentInfo* compInfo);

   void handleObsRspFederateStatDlgUpdate( const DtAssistantInfo& observer, int compId, bool response );
   
   void federateStatDlgClosing(const DtAssistantInfo& astnt, int compId,
      const MAKRti::DtString& federationName, int federateHandle, const DtRtiConnectionInfo& connInfo);

   void federateIdentifierUpdated( unsigned int );

   void lrcNetStatsUpdateIntervalUpdated( unsigned int );

signals:

   void queryFederateInfo(const DtRtiConnectionInfo& conn,
      const MAKRti::DtString& federationName,
      unsigned federateHandle, const DtAssistantFederateInfo** info);

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

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

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

   void requestFederateLoc(const DtRtiConnectionInfo& connInfo, 
      const MAKRti::DtString& federationName, unsigned int federateHdl);

protected:

   static void processNetStatsObserveReqMsg( const DtAssistantNetStatsObserveReqMsg& msg, void* usr );
   virtual void processNetStatsObserveReqMsg( const DtAssistantNetStatsObserveReqMsg& msg);
   static void processNetStatsObserveRspMsg( const DtAssistantNetStatsObserveRspMsg& msg, void* usr );
   virtual void processNetStatsObserveRspMsg( const DtAssistantNetStatsObserveRspMsg& msg);
   
   static void processServerNetStatsMsgUpdateMsg( const DtAssistantNetStatsMsgUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsMsgUpdateMsg( const DtAssistantNetStatsMsgUpdateMsg& msg);
   static void processServerNetStatsRtiAmbUpdateMsg( const DtAssistantNetStatsRtiAmbUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsRtiAmbUpdateMsg( const DtAssistantNetStatsRtiAmbUpdateMsg& msg);
   static void processServerNetStatsFedAmbUpdateMsg( const DtAssistantNetStatsFedAmbUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsFedAmbUpdateMsg( const DtAssistantNetStatsFedAmbUpdateMsg& msg);
   static void processServerNetStatsObjectsUpdateMsg( const DtAssistantNetStatsObjectsUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsObjectsUpdateMsg( const DtAssistantNetStatsObjectsUpdateMsg& msg );
   static void processServerNetStatsInteractionsUpdateMsg( const DtAssistantNetStatsInteractionsUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsInteractionsUpdateMsg( const DtAssistantNetStatsInteractionsUpdateMsg& msg );
   static void processServerNetStatsStringUpdateMsg( const DtAssistantNetStatsStringUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsStringUpdateMsg( const DtAssistantNetStatsStringUpdateMsg& msg );


   static void processPeerNetStatsMsgUpdateMsg( const DtAssistantNetStatsMsgUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsMsgUpdateMsg( const DtAssistantNetStatsMsgUpdateMsg& msg );
   static void processPeerNetStatsRtiAmbUpdateMsg( const DtAssistantNetStatsRtiAmbUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsRtiAmbUpdateMsg( const DtAssistantNetStatsRtiAmbUpdateMsg& msg );
   static void processPeerNetStatsFedAmbUpdateMsg( const DtAssistantNetStatsFedAmbUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsFedAmbUpdateMsg( const DtAssistantNetStatsFedAmbUpdateMsg& msg );
   static void processPeerNetStatsObjectsUpdateMsg( const DtAssistantNetStatsObjectsUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsObjectsUpdateMsg( const DtAssistantNetStatsObjectsUpdateMsg& msg );
   static void processPeerNetStatsInteractionsUpdateMsg( const DtAssistantNetStatsInteractionsUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsInteractionsUpdateMsg( const DtAssistantNetStatsInteractionsUpdateMsg& msg );
   static void processPeerNetStatsStringUpdateMsg( const DtAssistantNetStatsStringUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsStringUpdateMsg( const DtAssistantNetStatsStringUpdateMsg& msg );
   static void processPeerNetStatsStringReqMsg( const DtAssistantNetStatsStringReqMsg& msg, void* usr );
   virtual void processPeerNetStatsStringReqMsg( const DtAssistantNetStatsStringReqMsg& msg);

   virtual void handleNetStatsMsgUpdateDlgUpdate( const DtAssistantNetStatsMsgUpdateMsg& msg,
      const DtAssistantInfoCompIdPair& astntCompIdPair);
   virtual void handleNetStatsRtiAmbUpdateDlgUpdate( const DtAssistantNetStatsRtiAmbUpdateMsg& msg,
      const DtAssistantInfoCompIdPair& astntCompIdPair  );
   virtual void handleNetStatsFedAmbUpdateDlgUpdate( const DtAssistantNetStatsFedAmbUpdateMsg& msg,
      const DtAssistantInfoCompIdPair& astntCompIdPair );
   virtual void handleNetStatsObjectsUpdateDlgUpdate( const DtAssistantNetStatsObjectsUpdateMsg& msg,
      const DtAssistantInfoCompIdPair& astntCompIdPair, bool isLocal = true);
   virtual void handleNetStatsInteractionsUpdateDlgUpdate( const DtAssistantNetStatsInteractionsUpdateMsg& msg,
      const DtAssistantInfoCompIdPair& astntCompIdPair, bool isLocal = true);
   virtual void handleNetStatsStringUpdateDlgUpdate(const DtAssistantInfoCompIdPair& astntCompIdPair,
      DtAssistantHandleType handleType, const std::vector<DtU32>& instanceHandles, 
      const std::vector<MAKRti::DtString>& instanceNames);

   virtual void insertLocalObjectClassNames(unsigned int lrcCompId, const std::vector<DtU32>& objectClassHandles, 
      const std::vector<MAKRti::DtString>& objectClassNames);
   virtual void insertLocalInteractionClassNames(unsigned int lrcCompId, const std::vector<DtU32>& interactionClassHandles, 
      const std::vector<MAKRti::DtString>& interactionClassNames);
   virtual void insertLocalObjectInstanceNames(unsigned int lrcCompId, const std::vector<DtU32>& objectInstanceHandles, 
      const std::vector<MAKRti::DtString>& objectInteractionNames);
   virtual bool getObjectClassName(unsigned int lrcCompId, DtU32 objectClassHandle, MAKRti::DtString& objectClassName );
   virtual bool getInteractionClassName(unsigned int lrcCompId, DtU32 InteractionClassHandle, MAKRti::DtString& interactionClassName );
   virtual bool getObjectInstanceName(unsigned int lrcCompId, DtU32 objectInstanceHandle, MAKRti::DtString& objectInstanceName );
   virtual void requestNetStatsStringUpdate(const DtAssistantInfoCompIdPair& astntCompIdPair,
      DtAssistantHandleType handletype, const std::set<DtU32>& handles);
   virtual void getHandlesAndNames(DtAssistantHandleType handleType, unsigned int myObservedCompId, 
      const std::set<DtU32>& unknownNamesHandles, std::vector<DtU32>& instanceHandles, 
      std::vector<MAKRti::DtString>& instanceNames);

private:

    DtAssistantFederateViewMgr(const DtAssistantFederateViewMgr &);  

    DtAssistantFederateViewMgr &operator=(const DtAssistantFederateViewMgr &);
protected:

   std::set<int> myViewedCompIds;

   std::set<DtAssistantInfo> myViewedFederateOwners;

   MAKRti::DtFilename myConfigDir;

   DtAssistantSignalRouter& mySignalRouter;
   

   std::map<DtAssistantInfoCompIdPair, DtFederateStatisticsDialog*> myFederateStatsDlgByCompIdMap;
   std::map<DtConnectionInfoFederationNameFederateHandleTriple, DtFederateStatisticsDialog*> myFederateStatsDlgByFedNameHandlePairMap;

   std::map<DtConnectionInfoFederationNameFederateHandleTriple, bool> myIsPendingForLocationMap;

   std::set<DtAssistantInfoCompIdPair> myObservationsSet;

   std::map<DtAssistantInfoCompIdPair, bool> myPendingForObsRspMap;

   DtAssistantNetStatsObservationMgr * myAstntNetStatsObsMgr;

   DtNameByHandleMapByLrcCompIdMap myLocalObjectClassNames;
   DtNameByHandleMapByLrcCompIdMap myLocalInteractionClassNames;
   DtNameByHandleMapByLrcCompIdMap myLocalObjectInstanceNames;

   DtFederateIdentifierType myFederateIdType;

   DtAssistantInfo myAssistantInfo;

   unsigned int myLrcNetStatsUpdateInterval;
};
#endif