emitterSystemSimDataProcessor.h

Go to the documentation of this file.

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


#pragma once

#include <vrfVrlSharedSource/vrfProtocol.h>
#include <vrfGuiCore/vrlinkEmitterSystemState.h>
#include <vrvVrl/DtVrlinkConnection.h>
#include <vrvCore/DtSimEntryUpdater.h>
#include <vrvCore/DtSimDataProcessorInterface.h>

#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vl/globalObjectDesignator.h>
#include <vlutil/vlPerformanceStats.h>

class DtEmitterBeamRepository;

namespace makVrv
{
   class DtSimEntryObjectAgent;
   class DtEntityStateListener;
   class DtAggregateStateListener;

   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtVrlinkConnection;
      class DtVrlinkEmitterStateListener;
      class DtEmitterSystemExistenceListener;
      class DtEntityElementProcessor;
      class DtAggregateElementProcessor;
   }
}

namespace makVrf
{
   class DtVrlinkEmitterSystemStateObjectAgent;
   
   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtEmitterSystemSimDataProcessor : public makVrv::DtSimDataProcessorInterface
      {
      public:

         struct EmitterSystemSimDataInstance
         {
            std::vector<makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEmitterStateListener*> myListeners;
            DtVrlinkEmitterSystemStateObjectAgent* myAgent;
            makVrv::DtSimEntryUpdater::UpdateRate myRate;
            makVrv::DtUniqueID myEntityId;
         };

         DtEmitterSystemSimDataProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual ~DtEmitterSystemSimDataProcessor();

         static DtEmitterSystemSimDataProcessor* findInstance(
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim)
         {
            return dynamic_cast<DtEmitterSystemSimDataProcessor*>(
               sim.findInstance("DtEmitterSystemSimDataProcessor"));
         }

         static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,
            DtEmitterSystemSimDataProcessor* proc)
         {
            sim.registerInstance("DtEmitterSystemSimDataProcessor",proc);
         }
         
         void postDrainInput();

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

         virtual void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

         virtual void emitterSystemDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEmitterStateListener* listener);

         virtual void emitterSystemToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEmitterStateListener* listener);

         virtual void entityToBeDeleted(makVrv::DtEntityStateListener& listener);
         virtual void aggregateToBeDeleted(makVrv::DtAggregateStateListener& listener);

         virtual void createAndSendState(std::vector<makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEmitterStateListener*>& listeners,
            makVrv::DtUniqueID entityId, DtVrlinkEmitterSystemStateObjectAgent& objectAgent);
         virtual void setState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEmitterStateListener& listener,
            DtVrlinkEmitterSystemState& state);
         virtual void setState(DtVrlinkEmitterBeamState&, DtEmitterBeamRepository*);

         virtual makVrv::DtUniqueID mapHostIdToEntityUniqueId(const DtGlobalObjectDesignator& host,
            const DtGlobalObjectDesignator& systemId, makVrv::DtUniqueID systemUniqueId) const;

         virtual bool setupCallbackAgentFor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEmitterStateListener* listener);

         virtual void removeUpdaterAgent(makVrv::DtUniqueID id);

         boost::signals2::signal<void (makVrv::DtUniqueID, DtVrlinkEmitterSystemState)> signal_stateAdded;

      protected:

         static void postDrainInput(void* usr);

         virtual void slot_entityElementCreated();
         virtual void slot_aggregateElementCreated();

      protected:
         
         //A Listener and a driver which will be updated with it.
         class EmitterSystemStateUpdater
         {
         public:

            EmitterSystemStateUpdater(EmitterSystemSimDataInstance* emitterSystem, DtEmitterSystemSimDataProcessor& processor);

            EmitterSystemStateUpdater(const EmitterSystemStateUpdater& orig);

            EmitterSystemStateUpdater& operator=(const EmitterSystemStateUpdater& orig);

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

            void update(double timeT);

         protected:
            EmitterSystemSimDataInstance* myEmitterSystem;
            DtEmitterSystemSimDataProcessor* myProcessor;
         };
    
         typedef std::set<makVrv::DtUniqueID> EmitterSystemIdList;

         typedef std::map<makVrv::DtUniqueID,EmitterSystemSimDataInstance > EmitterSystemAgentMap;

         typedef makVrv::DtBalancedUpdater<EmitterSystemStateUpdater> EmitterSystemUpdaterGroup;
         typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,EmitterSystemUpdaterGroup>
            EmitterSystemUpdateGroupMap;                  

      protected:

         makVrv::DtSignalConnectionManager myConnections;

         makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& mySimulation;
         makVrv::DT_PROTOCOL_NAMESPACE::DtEmitterSystemExistenceListener& myListener;
         DtTimedSection myTimer;
         makVrv::DtSimEntryObjectAgent* mySimEntryAgent;

         EmitterSystemAgentMap myEmitterSystemAgents;
         EmitterSystemUpdateGroupMap myRefreshRateGroups;
         EmitterSystemIdList myForceUpdateList;
         
         typedef std::map<makVrv::DtUniqueID, DtVrlinkEmitterSystems> StateMapBySystem;
         StateMapBySystem myStateMapBySystem;

         typedef std::map<makVrv::DtUniqueID, DtVrlinkEmitterSystems> StateMapByEntity;
         StateMapByEntity myStateMapByEntity;
         makVrv::DT_PROTOCOL_NAMESPACE::DtEntityElementProcessor* myEntityElementProcessor;
         makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateElementProcessor* myAggregateElementProcessor;

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

      class VRF_PROTOCOL_EXPORT DtEmitterSystemSimDataProcessorCreator : public makVrv::DtVirtualBaseClass
      {
      public:
         DtEmitterSystemSimDataProcessorCreator();

         static DtEmitterSystemSimDataProcessorCreator& instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn);

         static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn, 
            DtEmitterSystemSimDataProcessorCreator* instance);

         virtual DtEmitterSystemSimDataProcessor* create(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn);
      };
   }
}