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);

   protected:
      virtual void queueDataRemoval(Legion::UInt64 legionId);

   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;
   };
}