netStatsObservationMgr.h

Go to the documentation of this file.

#ifndef netStatsObservationMgr_h__
#define netStatsObservationMgr_h__

#include "rtiMsConfig.h"
#include "assistantMgr.h"
#include <vlutil/vlSmartPointers.h>
#include "map"
#include "list"
#include "set"
#include <QtCore/QObject>
#include "assistantMsg.h"
#include "assistantNetStatsEnums.h"

class DtRtiAssistantServer;
class DtRtiAssistantPeer;
class DtAssistantInfo;
class DtAssistantSignalRouter;
class DtAssistantNetStatsInitStateRequestMsg;

typedef std::map<int, unsigned int> DtIntervalMap;
typedef std::map<DtAssistantInfo, int> DtLrcCompIdByAssistantInfoMap;   
typedef std::map<int, std::set<DtAssistantInfo> > DtAssistantInfoByLrcCompIdMap;
typedef std::map<int, bool> DtLrcNetStatsEnabledMap;

class DT_DLL_ASSISTANTAPP DtAssistantNetStatsObservationMgr : public DtAssistantMgr
{
   Q_OBJECT

public:
   DtAssistantNetStatsObservationMgr(DtBoost::shared_ptr<DtRtiAssistantServer> server,
      DtBoost::shared_ptr<DtRtiAssistantPeer> peer, DtAssistantSignalRouter& signalRouter,
      DtAssistantObservationType observationType);

   ~DtAssistantNetStatsObservationMgr();

signals:
   void sendLocalNetStatsObserveRsp(const DtAssistantInfo& observer, int compId, bool response);
   void processPeerNetStatsInitStateReq(const DtAssistantInfo& observer, int compId);
   void lrcNoLongerObserved(const DtAssistantInfo& observer, int compId);

public:
   void processObserveRequest(const DtAssistantInfo& observer, int compId, 
      bool observe, unsigned int interval, bool isLocalAssistant = false);
   static void processNetStatsInitStateRequestMsg(
      const DtAssistantNetStatsInitStateRequestMsg& msg, void* usr );
   void processNetStatsInitStateRequestMsg(
      const DtAssistantNetStatsInitStateRequestMsg& msg);
   const DtAssistantInfoByLrcCompIdMap& getObservingAssistantsMap() const;   
   void setLrcNetStatsEnabled(int lrcCompId, bool enabled);
   void removeLrcNetStatsEnabled( int lrcCompId );
   void forwardNetStatsUpdateToRemoteAstnt(const DtAssistantMsg & msg );
   void federateDisconnected( int lrcCompId );
   void sendNetStatsInitStateReq(const DtAssistantInfo& observer, int compId);
protected:
   void addObserver(const DtAssistantInfo& observer, int compId, unsigned int interval);
   void removeObserver(const DtAssistantInfo& observer, int compId);
   void sendNetStatsObserveRsp(const DtAssistantInfo& observer, int compId, bool response);

   bool isLrcNetStatsEnabled(int lrcCompId);
   bool updateIntervalMap(int compId, unsigned int interval);
   void removeLrcFromIntervalMap(int compId);
   bool addToMaps( const DtAssistantInfo& observer, int compId);
   bool removeFromMaps( const DtAssistantInfo& observer, int compId);
   void sanitizeMaps( int lrcCompId );
   void removeAllObservers();
   void messageCallbacks();
protected:

   DtAssistantObservationType myObservationType;
   // LRC compId for key, interval for value
   DtIntervalMap myObservedIntervalsByLrcCompId;
   DtLrcCompIdByAssistantInfoMap myObservedLrcCompIdByAssistantCompId;
   DtAssistantInfoByLrcCompIdMap myObservingAssistantsByLrcCompId;
   DtLrcNetStatsEnabledMap myLrcNetStatsEnabled;
//    DtBoost::shared_ptr<DtRtiAssistantServer> myServer;
//    DtBoost::shared_ptr<DtRtiAssistantPeer> myPeer;

};

#endif // netStatsObservationMgr_h__