fomViewMgr.h

Go to the documentation of this file.

#ifndef fomViewMgr_h__
#define fomViewMgr_h__
/*********************************************************************
** Copyright (c) 2012 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/

#include "rtiMsConfig.h"
#include "assistantMgr.h"
#include "assistantSignalRouter.h"
#include "rtiVersion.h"
#include <vlutil/vlFilename.h>
#include "assistantConnectionInfo.h"
#include "assistantNetStatsFomTreeUpdateMsg.h"
#include "assistantNetStatsEnums.h"

class DtFomStatisticsDialog;
class DtAssistantFederateInfo;
class DtAssistantForwarderInfo;
class DtAssistantNetStatsObservationMgr;
class DtAssistantNetStatsObserveReqMsg;
class DtAssistantNetStatsObserveRspMsg;
class DtAssistantComponentInfo;
class DtFomTreeData;
class DtAssistantNetStatsFomUpdateMsg;
class DtAssistantNetStatsAttrParamStringUpdateMsg;
class DtAssistantNetStatsFomAttrParamUpdateMsg;
class DtAssistantNetStatsInitStateRequestMsg;

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

typedef std::pair<DtRtiConnectionInfo, DtFederationNameFederateHandlePair> DtConnectionInfoFederationNameFederateHandleTriple;

typedef std::map< DtAssistantInfoCompIdPair, DtFomTreeData > DtFomTreeDataByCompIdMap;
typedef std::map< DtAssistantInfoCompIdPair, bool > DtInitStatusByCompIdMap;
typedef std::map< DtAssistantInfoCompIdPair, std::set<DtAssistantInfo> > DtAssistantInfoSetByCompIdMap;


class DT_DLL_ASSISTANTAPP DtAssistantFomViewMgr : public DtAssistantMgr
{
   Q_OBJECT

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

   ~DtAssistantFomViewMgr();

   virtual void startShutdown();

public slots:

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

      void fomStatDlgClosing(const DtAssistantInfo& astnt, int compId, 
         const MAKRti::DtString& federationName, int federateHandle, const DtRtiConnectionInfo& connInfo );
      
      void sendFomObservationRequest(const DtRtiConnectionInfo& connInfo,
         const MAKRti::DtString& federationName, unsigned federateHdl,
         const DtAssistantInfo& astnt, unsigned compId, bool observe=true);

      void sendFomInitStateRequest( const DtAssistantInfo& astnt, unsigned compId );

      void processFederateRemoval(const DtAssistantComponentInfo* comp);
      void processFederateRemoval(const DtRtiConnectionInfo& connInfo, const MAKRti::DtString& federationName, unsigned federateHandle);
      void processLocalRtiComponentConnected( const DtAssistantComponentInfo* compInfo);
      void processLocalRtiComponentDisconnected( const DtAssistantComponentInfo* compInfo);

      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 requestFederateLoc(const DtRtiConnectionInfo& connInfo, 
         const MAKRti::DtString& federationName, unsigned int federateHdl);


protected slots:

   virtual void handleObsRspFomStatDlgUpdate(const DtAssistantInfo& observer, int compId, bool response);

   virtual void handleNetStatsInitStateReq(const DtAssistantInfo& astnt, int compId);

   virtual void clearInitMaps(const DtAssistantInfo& astnt, int compId);

protected:

   static void processPeerNetStatsObserveReqMsg( const DtAssistantNetStatsObserveReqMsg& msg, void* usr );
   virtual void processPeerNetStatsObserveReqMsg( const DtAssistantNetStatsObserveReqMsg& msg);
   

   static void processPeerNetStatsObserveRspMsg( const DtAssistantNetStatsObserveRspMsg& msg, void* usr );
   virtual void processPeerNetStatsObserveRspMsg( const DtAssistantNetStatsObserveRspMsg& msg );

   static void processServerNetStatsFomTreeUpdateMsg( 
      const DtAssistantNetStatsFomTreeUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsFomTreeUpdateMsg( const DtAssistantNetStatsFomTreeUpdateMsg& msg );

   static void processServerNetStatsFomUpdateMsg( 
      const DtAssistantNetStatsFomUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsFomUpdateMsg( 
      const DtAssistantNetStatsFomUpdateMsg& msg);

   static void processServerNetStatsAttrParamStringUpdateMsg( const DtAssistantNetStatsAttrParamStringUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsAttrParamStringUpdateMsg( const DtAssistantNetStatsAttrParamStringUpdateMsg& msg );
   
   static void processServerNetStatsFomAttrParamUpdateMsg( const DtAssistantNetStatsFomAttrParamUpdateMsg& msg, void* usr );
   virtual void processServerNetStatsFomAttrParamUpdateMsg( const DtAssistantNetStatsFomAttrParamUpdateMsg& msg );

   static void processPeerNetStatsFomAttrParamUpdateMsg( const DtAssistantNetStatsFomAttrParamUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsFomAttrParamUpdateMsg( const DtAssistantNetStatsFomAttrParamUpdateMsg& msg );

   static void processPeerNetStatsFomTreeUpdateMsg( const DtAssistantNetStatsFomTreeUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsFomTreeUpdateMsg( const DtAssistantNetStatsFomTreeUpdateMsg& msg );

   static void processPeerNetStatsAttrParamStringUpdateMsg( const DtAssistantNetStatsAttrParamStringUpdateMsg& msg, void* usr );
   virtual void processPeerNetStatsAttrParamStringUpdateMsg( const DtAssistantNetStatsAttrParamStringUpdateMsg& msg );

   static void processPeerNetStatsInitStateRequestMsg( const DtAssistantNetStatsInitStateRequestMsg& msg, void* usr );
   virtual void processPeerNetStatsInitStateRequestMsg( const DtAssistantNetStatsInitStateRequestMsg& msg );

   void handleNetStatsFomAttrParamUpdateMsg( const DtAssistantNetStatsFomAttrParamUpdateMsg& msg,
      bool isServer, const DtAssistantInfo & astntInfo );
   void handleFomTreeDataForFomStatDlg(DtFomTreeData & objectFomTreeData,
      DtFomTreeData & interactionFomTreeData, const DtAssistantInfoCompIdPair& astntInfoCompIdPair);

   void handleAttributeNamesForFomStatDlg(DtFomTreeData& objectFomTreeData, const DtAssistantInfoCompIdPair& astntInfoCompIdPair);

   void handleParameterNamesForFomStatDlg(DtFomTreeData& objectFomTreeData,
      const DtAssistantInfoCompIdPair& astntInfoCompidPair);

   void handleStateUpdateForFomStateDlg(DtAssistantHandleType type, const DtFomTreeData& objectFomTreeData,
      const DtAssistantInfoCompIdPair& astntInfoCompidPair);

   void cleanLocalMaps(const DtAssistantInfo& astntInfo, unsigned int compId);
   void cleanRemoteMaps(unsigned int compId);
   int myViewedCompId;

   DtAssistantInfo myViewedFederateOwner;


   unsigned myViewedFederateHandle;
   MAKRti::DtString myViewedFederateName;
   MAKRti::DtString myViewedFederateType;
   MAKRti::DtFilename myViewedFederateProcess;
   MAKRti::DtString myViewedFederationName;
   DtRtiConnectionInfo myViewedConnection;

   MAKRti::DtFilename myConfigDir;
   DtAssistantSignalRouter& mySignalRouter;

   std::map<DtAssistantInfoCompIdPair, DtFomStatisticsDialog*> myFomViewDlgByCompIdMap;
   std::map<DtConnectionInfoFederationNameFederateHandleTriple, DtFomStatisticsDialog*> myFomViewDlgByFedNameHandlePairMap;

   std::map<DtConnectionInfoFederationNameFederateHandleTriple, bool> isPendingForLocationMap;

   std::set<DtAssistantInfoCompIdPair> myObservationsSet;
   std::map<DtAssistantInfoCompIdPair, bool> myPendingForObsRspMap;

   unsigned int myLrcNetStatsUpdateInterval;

   const bool myShouldHandleTransport;
   const bool myShouldHandleOrder;

   DtAssistantNetStatsObservationMgr * myAstntNetStatsObsMgr;

   DtFomTreeDataByCompIdMap myObjectFomTreeMap;
   DtFomTreeDataByCompIdMap myInteractionFomTreeMap;
   DtInitStatusByCompIdMap myInitFomNameMap;
   DtInitStatusByCompIdMap myInitFomAttributeMap;
   DtInitStatusByCompIdMap myInitFomParameterMap;
   DtInitStatusByCompIdMap myInitFomAttributeStateMap;
   DtInitStatusByCompIdMap myInitFomParameterStateMap;
   DtAssistantInfoSetByCompIdMap myRemoteAstntNeedsObjIntNamesMap;
   DtAssistantInfoSetByCompIdMap myRemoteAstntNeedsAttrNamesMap;
   DtAssistantInfoSetByCompIdMap myRemoteAstntNeedsParamNamesMap;
   DtAssistantInfoSetByCompIdMap myRemoteAstntNeedsAttrInitStateMap;
   DtAssistantInfoSetByCompIdMap myRemoteAstntNeedsParamInitStateMap;

   DtAssistantInfo myAssistantInfo;

   DtFederateIdentifierType myFederateIdType;

private:

   DtAssistantFomViewMgr(const DtAssistantFomViewMgr &);  

   DtAssistantFomViewMgr &operator=(const DtAssistantFomViewMgr &);
};








#endif // fomViewMgr_h__