federationsViewMgr.h

Go to the documentation of this file.

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

#ifndef federationsViewMgr_H_
#define federationsViewMgr_H_


#include "rtiMsConfig.h"
#include "assistantMgr.h"
#include "assistantInfo.h"
#include "assistantConnectionInfo.h"
#include "forwarderInfo.h"
#include <QtGui/QWidget>
#include <vlutil/vlSmartPointers.h>

class DtRtiAssistantServer;
class DtRtiAssistantPeer;
class DtFederationsViewDialog;
class DtForwarderConnStatusDialog;
class DtRtiConnectionInfo;
class DtAssistantInfo;
class DtAssistantTimeStateMsg;
class DtAssistantSyncPtUpdateMsg;
class DtAssistantTestMgrStatusMsg;
class DtAssistantCommandMsg;
class DtAssistantDeleteFederateMsg;
class DtAssistantDeleteFederationMsg;
class DtAssistantComponentMgr;
class DtAssistantForwarderStateMsg;
class DtAssistantStateObserveMsg;
class DtRtiConnectionAndConfiguration;
class DtAssistantConnectionInfoMgr;
class DtAssistantExecObserveRspMsg;
class DtAssistantNotifyMsg;
class DtAssistantLogMsg;
class DtAssistantAwaitingForwardersMsg;
class DtAssistantSignalRouter;
class DtAssistantFederationsInfoMgr;
class DtAssistantNetworkCompInfoMgr;
class QSignalMapper;
class DtFederationsViewDialog;
class DtAssistantRidParamsMsg;
class DtSyncPtDialog;
class DtRIDParameters;
class DtWidgetDialog;
class DtRidWidget;

class DT_DLL_ASSISTANTAPP DtAssistantFederationsViewMgr : public DtAssistantMgr
{
   Q_OBJECT

public:

   DtAssistantFederationsViewMgr(DtBoost::shared_ptr<DtRtiAssistantServer> server, 
      DtBoost::shared_ptr<DtRtiAssistantPeer> peer, 
      DtAssistantSignalRouter& signalRouter,
      DtBoost::shared_ptr<DtAssistantComponentMgr> compMgr, 
      DtBoost::shared_ptr<DtAssistantConnectionInfoMgr> connInfoMgr, 
      DtBoost::shared_ptr<DtAssistantFederationsInfoMgr> fedInfoMgr, 
      DtBoost::shared_ptr<DtAssistantNetworkCompInfoMgr> netCompInfoMgr,
      const MAKRti::DtFilename& configDir);

   ~DtAssistantFederationsViewMgr();

private:

   DtAssistantFederationsViewMgr(DtAssistantFederationsViewMgr const& );
   DtAssistantFederationsViewMgr& operator= (DtAssistantFederationsViewMgr const& );

public:

   virtual void tick();

   virtual void startShutdown();

   virtual bool dialogsVisible() const;

   void saveGuiState();



   static void processExecObserveRspMsg( const DtAssistantExecObserveRspMsg& msg, void* usr );

   virtual void processExecObserveRspMsg( const DtAssistantExecObserveRspMsg& msg );

   static void processRtiexecNotifyMsg( const DtAssistantNotifyMsg& msg, void* usr );

   virtual void processRtiexecNotifyMsg( const DtAssistantNotifyMsg& msg );

   static void processAwaitingForwardersMsg( const DtAssistantAwaitingForwardersMsg& msg, void* usr );

   virtual void processAwaitingForwardersMsg( const DtAssistantAwaitingForwardersMsg& msg );

   // Ported from federationsViewMgr
   static void processRidParamMsg( const DtAssistantRidParamsMsg& msg, void* usr );

   virtual void processRidParamMsg( const DtAssistantRidParamsMsg& msg );


protected:

   virtual void processConnectionRemoval( const DtRtiConnectionInfoDataPair& conn );

   void logConnectionInfo(std::ofstream& fileStrm);

   void logFederationInfo(std::ofstream& fileStrm);

   void logFomInfo(std::ofstream& fileStrm, const std::list<MAKRti::DtString>* foms);

   void logFederateInfo(std::ofstream& fileStrm, const DtFederateInfoByHandleMap* federates,
      const DtAssistantForwarderInfo* fwInfo);

   struct DtCompRidParamDispStruct
   {
      DtRIDParameters* ridParams;
      DtWidgetDialog* ridDialog;
      DtRidWidget* ridWidget;
      MAKRti::DtString federation;
      unsigned federateHdl;
   };

   void showRidDialog(const QString& name, const DtAssistantInfo& assistant, 
      int compId);

   void createRidDialog(const QString& name, DtCompRidParamDispStruct& dispInfo);
   
   void updateRidParams(const DtAssistantInfo& assistant, int compId,
      const MAKRti::DtString& params, const MAKRti::DtString& filename,
      const MAKRti::DtString& federation, unsigned federateHdl);

   virtual void updatePeerForwarders(
      const DtAssistantForwarderInfo::DtPeerForwarderByIdMap* newFwds,
      const DtAssistantForwarderInfo::DtPeerForwarderByIdMap* oldFwds);

   virtual void updateRtiexecCompInfo(
      const DtAssistantNetworkCompInfo* newInfo,
      const DtAssistantNetworkCompInfo* oldInfo);

   virtual void updateFederateCompInfo(
      const DtAssistantForwarderInfo::DtCompByFederationAndHandleMap* newInfo,
      const DtAssistantForwarderInfo::DtCompByFederationAndHandleMap* oldInfo,
      const DtFederationStateByNameMap* federationMap);

   virtual void updateUnclassifiedComps(
      const DtAssistantNetworkCompInfoList* newInfo,
      const DtAssistantNetworkCompInfoList* oldInfo);

public slots:

   void showFederationsView();

   virtual void sendLogRequest();

   void shutdownRtiexec();

   void shutdownRtiForwarder();

   void processForwarderAdded( const DtRtiConnectionInfo& conn );

   void processForwarderConnUpdated( const DtRtiConnectionInfo& conn );

   void processForwarderUpdated( const DtRtiConnectionInfo& conn );

   void processForwarderRemoved( const DtRtiConnectionInfo& conn );

   void processDoNotWaitForForwarders(QWidget* dlg);

   void processShutDownWaitingForwarder(QWidget* dlg);

   // Ported from federationsViewMgr

   void changeViewedConnection( const DtRtiConnectionInfo& conn =
      DtRtiConnectionInfo::invalidConn() );

   void resignFederate( int, const QString& );

   void destroyFederation( const QString& );

   void sendNetworkTestingEnableMsg( const QString& fedexName );

   void sendNetworkTestingDisableMsg( const QString& fedexName );

   void showLatencyTestDialog( const QString& fedexName, int fedHandle );

   void processFederationUpdate(const DtRtiConnectionInfo& conn, 
      const MAKRti::DtString& federationName);

   void processFederationRemoved(const DtRtiConnectionInfo& conn, 
      const MAKRti::DtString& federationName);

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

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

   void removeLoadingIndication(const DtRtiConnectionInfo& conn);

   void saveToLog();

   void processConnectionsUpdate( const DtRtiConnectionAndConfiguration& conns );

   void processConnectionsRemoval( const DtRtiConnectionAndConfiguration& conns );

   void showFederationsViewPreferences();

   void processFederateSelection(const MAKRti::DtString& federation,
      int federate);

   void processRtiexecSelection();

   void processForwarderSelection(const MAKRti::DtString& fwName);

   void processPeerForwarderSelection(const MAKRti::DtString& fwName);

   void processFederationSelection(const MAKRti::DtString& federation);

   void processLightweightNodeSelection();

   void showSyncPtDialog(const MAKRti::DtString& federation);

   void showFederateStatsDialog(const MAKRti::DtString& federation, int federateHandle);

   void showFomDialog(const MAKRti::DtString& federation, int federateHandle);

   void showRtiexecRidParams();

   void showForwarderRidParams();

   void showFederateRidParams(const MAKRti::DtString& federation, int federateHandle);

   void destroyRidParamDialog(QWidget* widget);
   
   void sendPendingRidRequest(const DtRtiConnectionInfo& connInfo,
      const MAKRti::DtString& federationName, unsigned federateHdl,
      const DtAssistantInfo& astnt, unsigned compId);

   void showRtiexecLog();

   void showForwarderLog();

   void showFederateLog(const MAKRti::DtString& federation, int federateHandle);

   void removeDefunctFederateFromMap(const MAKRti::DtString& federation, int federateHandle);

signals:

   void aboutDialogRequested();

   void showPopup(const MAKRti::DtString&, const MAKRti::DtString&,
      const MAKRti::DtString&);

   // ported from federationsViewMgr
   void federateRemovalTimeChanged( float period );

   void showConfigDialog( DtPreferencesPage pageId );

   void showLrcLatencyTestDialog( int id );

   void showRtiexecLatencyTestDialog(
      const DtRtiConnectionInfoDataPair& connInfo, 
      unsigned int federationHdl, const MAKRti::DtString& federationName,
      unsigned int federateHdl);

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

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

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

   void showLogFileDialog( int compId );
   
   void queryFederateInfo(const DtRtiConnectionInfo&,
      const MAKRti::DtString&, unsigned, const DtAssistantFederateInfo**);

protected:

   typedef std::map< DtRtiConnectionInfo, DtAssistantInfoSet > DtConnectionToObserversMap;

   DtBoost::shared_ptr<DtAssistantComponentMgr> myCompMgr;

   DtBoost::shared_ptr<DtAssistantConnectionInfoMgr> myConnInfoMgr;

   DtBoost::shared_ptr<DtAssistantFederationsInfoMgr> myFedInfoMgr;

   DtBoost::shared_ptr<DtAssistantNetworkCompInfoMgr> myNetCompInfoMgr;

   DtRtiConnectionInfo myViewedConnection;

   DtAssistantForwarderInfo myCurrentForwarderInfo;

   std::set<std::pair<MAKRti::DtString, unsigned> > myLightweightFederates;

   DtFederationsViewDialog* myFederationsViewDialog;

   MAKRti::DtClock myClock;

   bool myReceivedRemoteForwarderInfo;

   MAKRti::DtTime myRemoteForwarderInfoTimeout;

   typedef std::map< DtRtiConnectionInfo, DtForwarderConnStatusDialog* > DtConnectionToFwStatusDialogMap;
   DtConnectionToFwStatusDialogMap myFwStatusDlgMap;

   QSignalMapper* myFwStatusAcceptSigMapper;

   QSignalMapper* myFwStatusRejectSigMapper;

   std::map<MAKRti::DtString, DtSyncPtDialog*> mySyncPtDialogs;

   QSignalMapper* myRidDialogSignalMapper;

   typedef std::pair<DtAssistantInfo, int> DtUniqueCompId;

   typedef std::map<DtUniqueCompId, DtCompRidParamDispStruct> DtRidParmDlgByComp;

   DtRidParmDlgByComp myRidParamDialogs;

   std::list<DtCompRidParamDispStruct> myPendingFederateRidDialogs;

   static const int theUpdatePeriod;

   static const unsigned theMaxLogLoadSize;

   QString mySavedFile;

};

#endif