simDataProcessorManager.h

Go to the documentation of this file.

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

#pragma once

#include <vrfGuiNetworkCommon/vrfGuiNetworkCommonDefines.h>
#include <vrvUtil/DtLockedBufferedQueue.h>
#include <vrvUtil/DtVirtualBaseClass.h>
#include <vrfGuiNetworkCommon/vrfDataProcessorInterface.h>
#include <vrvUtil/DtSignalConnectionManager.h>

#include <string>

namespace makVrf
{
   class DtStateComponent;
   class DtStateDataManager;
   class DtSimDataProcessorManager;

   typedef DtSimDataProcessorManager* (*DtSimDataProcessorManagerCreatorFcn)(DtStateDataManager* instance, makVrv::DtBaseConnection& sim);
   class DT_DLL_vrfGuiNetworkCommon DtSimDataProcessorManager : public makVrv::DtVirtualBaseClass
   {
   public:

      DtSimDataProcessorManager(DtStateDataManager* instance, makVrv::DtBaseConnection& sim);

      virtual ~DtSimDataProcessorManager();

      virtual void queueFunction(const boost::function<void ()>& function);

      virtual void addDataProcessor(DtVrfSimDataProcessorInterface*);

      virtual void runFunctionQueue();

      virtual DtVrfSimDataProcessorInterface* dataProcessor(const char*);

      static DtSimDataProcessorManager& instance(makVrv::DtBaseConnection& conn);
      static void registerInstance(makVrv::DtBaseConnection& sim, DtSimDataProcessorManager* instance);

      static DtSimDataProcessorManager* create(DtStateDataManager* instance, makVrv::DtBaseConnection& sim);
      static DtSimDataProcessorManagerCreatorFcn setCreator(DtSimDataProcessorManagerCreatorFcn);

      virtual void addVantageToLegionIdMapping(makVrv::DtUniqueID, Legion::UInt64);
      virtual bool removeLegionToVantageIdMapping(Legion::UInt64);

      virtual Legion::UInt64 vantageToLegionId(makVrv::DtUniqueID) const;
      virtual makVrv::DtUniqueID legionToVantageId(Legion::UInt64) const;

   protected:
      typedef makVrv::DtLockedBufferedQueue<boost::function<void ()> > FunctionCallQueue;
      typedef std::vector<boost::function<void ()> > FunctionCallList;

      FunctionCallQueue myThreadFunctions;

      makVrv::DtBaseConnection& mySimulation;

      typedef std::map<std::string, DtVrfSimDataProcessorInterface*> RegisteredInterfaces;
      RegisteredInterfaces myRegisteredInterfaces;

      DtStateDataManager* myStateDataManager;
      makVrv::DtSignalConnectionManager myConnections;

      static DtSimDataProcessorManagerCreatorFcn theSimDataProcessorManagerCreatorFcn;
      typedef std::unordered_map<makVrv::DtUniqueID, Legion::UInt64> VantageToLegionIdMap;
      typedef std::unordered_map<Legion::UInt64, std::pair<makVrv::DtUniqueID, int>> LegionToVantageIdMap;

      VantageToLegionIdMap myVantageToLegionIdMap;
      LegionToVantageIdMap myLegionToVantageIdMap;
   };
}