spotReportDataProcessor.h

Go to the documentation of this file.

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



#pragma once

#include <vrfGuiCore/vrfGuiCore.h>

#include <vrvUtil/signalslib.h>
#include <vrvCore/DtUniqueID.h>
#include <vrvCore/DtSimDataProcessorInterface.h>
#include <vrvCore/DtSimEntryUpdater.h>
#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrfutil/rwUUID.h>

#include <boost/bind.hpp>

class DtSpotReport;

namespace makVrv
{
   class DtDe;
   class DtSimEntryObjectAgent;
   class DtSimObjectEntry;
}

namespace makVrf
{
   class DtSpotReportDataHandler;
   class DtSpotReportDataHandlerCreatorInterface;
   class DtVrfSimBackendManager;

   class DT_DLL_VRFGUICORE DtSpotReportDataProcessor : public makVrv::DtSimDataProcessorInterface
   {
   public:

      static DtSpotReportDataProcessor& instance(makVrv::DtDe& de);

      void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

   public:
      virtual void addSpotReportHandler(const std::string& s, DtSpotReportDataHandlerCreatorInterface*);

      virtual void removeSpotReportHandler(const std::string& s);

      virtual bool addOrUpdateSpotReport(const std::string& type, void* data, const DtUUID&);

      virtual void removeSpotReport(makVrv::DtUniqueID id);

      virtual void removeAllSpotReports();

      virtual void resetFlushDataTime();

      virtual std::set<makVrv::DtUniqueID> observing(makVrv::DtUniqueID) const;

      virtual void setSuspended(bool);
      bool suspended() const
      {
         return mySuspended;
      }

      virtual double simTime() const;

   protected:
      virtual DtSpotReportDataHandler* createSpotReportHandler(const std::string& s, makVrv::DtUniqueID) const;

      virtual bool createSpotReport(const std::string& type, void* data, const DtUUID&);

   protected:
      virtual void processForceUpdateList();

      virtual void slot_simObjectEntryAboutToBeRemoved(makVrv::DtSimObjectEntry& entry);

      virtual void tick();

      virtual void updateFlushTime();
      virtual void updatePendingReports();

   protected:
      DtSpotReportDataProcessor(makVrv::DtDe& sim);

      virtual ~DtSpotReportDataProcessor();

   protected:
      typedef std::set<makVrv::DtUniqueID> SpotReportIdList;
      typedef std::map<std::string, DtSpotReportDataHandlerCreatorInterface*> SpotReportHandlerCreators;
      typedef std::map<DtUUID, DtSpotReportDataHandler*> SpotReportHandlers;
      typedef std::map<makVrv::DtUniqueID, DtSpotReportDataHandler*> SpotReportHandlersById;

      makVrv::DtDe&  myDe;
      makVrv::DtSimEntryObjectAgent* mySimEntryAgent;
      makVrv::DtSignalConnectionManager myConnections;
      SpotReportIdList myForceUpdateList;
      SpotReportHandlerCreators   mySpotReportHandlerCreators;
      SpotReportHandlers   mySpotReportHandlers;
      SpotReportHandlersById mySpotReportHandlersById;

      SpotReportHandlersById myNeedsUpdateOnAdd;

      double myNextFlushDataTime;
      DtVrfSimBackendManager& myBackendManager;

      int myPauseFlushUpdate;
      bool mySuspended;

      struct PendingSpotReport
      {
         PendingSpotReport() : report(0) {};
         PendingSpotReport(const PendingSpotReport& orig)
            : type(orig.type), key(orig.key), report(orig.report)
         {
         }

         PendingSpotReport& operator=(const PendingSpotReport& orig)
         {
            type = orig.type;
            key = orig.key;
            report = orig.report;

            return *this;
         }

         virtual ~PendingSpotReport() {};
         std::string type;
         DtUUID key;
         DtSpotReport* report;
      };

      typedef std::vector<PendingSpotReport> PendingSpotReports;
      
      PendingSpotReports myPendingSpotReports;

      std::set<makVrv::DtUniqueID> myPendingReportsToFlushData;
   };
}