extendedStateDataProcessor.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2021 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/


#pragma once

#include <vrfGuiNetworkCommon/vrfGuiNetworkCommonDefines.h>

#include <vrfGuiCore/DtExtendedStateDataObjectAgent.hpp>

#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrvCore/DtSimEntryObjectAgent.hpp>
#include <vrvCore/DtSimDataProcessorInterface.h>
#include <vlutil/vlPerformanceStats.h>

#include <boost/signals2.hpp>

namespace makVrv
{
   class DtBaseConnection;
}

namespace makVrf 
{
   class DtStateData;
   class DtStateDataManager;
   struct DtSimpleTypedDictionary;

   class DT_DLL_vrfGuiNetworkCommon DtExtendedStateDataProcessor : public makVrv::DtSimDataProcessorInterface
   {
   public:

      static DtExtendedStateDataProcessor* findInstance(makVrv::DtBaseConnection& sim);

      static void registerInstance(makVrv::DtBaseConnection& sim,DtExtendedStateDataProcessor*);

      DtExtendedStateDataProcessor(DtStateDataManager*, makVrv::DtBaseConnection& sim);

      virtual ~DtExtendedStateDataProcessor();
         
      void postDrainInput();

      void setObjectUpdateRate(makVrv::DtUniqueID uniqueId, makVrv::DtSimEntryUpdater::UpdateRate rate);

      void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

      virtual void createAndSendState(makVrv::DtUniqueID id, makVrv::DtSimStateObjectAgent& objectDriver);

      virtual DtSimpleTypedDictionary& extendedStateFor(makVrv::DtUniqueID id, bool forceUpdate = true);

      virtual bool hasStateFor(makVrv::DtUniqueID) const;
      virtual DtExtendedStateData stateFor(makVrv::DtUniqueID id) const;

      boost::signals2::signal<void (makVrv::DtUniqueID, DtExtendedStateData&) > signal_stateUpdated;

   protected:

      virtual void tick();
      virtual void itemToBeDestroyed(const DtStateData*);
      
   protected:
         
      //A Listener and a driver which will be updated with it.
      class ExtendedStateDataUpdater
      {
      public:

         ExtendedStateDataUpdater(makVrv::DtUniqueID id, DtExtendedStateDataObjectAgent& driver,
            DtExtendedStateDataProcessor& processor);

         ExtendedStateDataUpdater(const ExtendedStateDataUpdater& orig);

         ExtendedStateDataUpdater& operator=(const ExtendedStateDataUpdater& orig);

         //Are the updaters equal
         bool operator==(const ExtendedStateDataUpdater& orig) const;

         void update(double timeT);

      protected:
         makVrv::DtUniqueID myId;
         DtExtendedStateDataObjectAgent* myObjectAgent;
         DtExtendedStateDataProcessor* myProcessor;
      };
    
      typedef std::vector<makVrv::DtUniqueID> ExtendedStateDataIdList;

      struct ExtendedStateDataInstance
      {  
         makVrv::DtUniqueID myId;
         DtExtendedStateDataObjectAgent* myAgent;
         makVrv::DtSimEntryUpdater::UpdateRate myRate;
         DtExtendedStateData myStateData;
      };

      typedef std::map<makVrv::DtUniqueID,ExtendedStateDataInstance > ExtendedStateDataAgentMap;

      typedef makVrv::DtBalancedUpdater<ExtendedStateDataUpdater> ExtededStateDataUpdaterGroup;
      typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,ExtededStateDataUpdaterGroup>
         ExtendedStateDataUpdateGroupMap;                  

   protected:

      makVrv::DtSignalConnectionManager myConnections;

      makVrv::DtBaseConnection& mySimulation;
      DtTimedSection myTimer;
      makVrv::DtSimEntryObjectAgent* mySimEntryAgent;

      ExtendedStateDataAgentMap myExtendedStateDataAgents;
      ExtendedStateDataUpdateGroupMap myRefreshRateGroups;
      ExtendedStateDataIdList myForceUpdateList;

      DtStateDataManager* myStateDataManager;
   };
}