laserDesignatorSimDataProcessor.h

Go to the documentation of this file.

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


#pragma once

#include <vrfVrlSharedSource/vrfProtocol.h>

#include <vrfGuiCore/laserDesignatorState.h>
#include <vl/globalObjectDesignator.h>
#include <vrvCore/DtSimEntryUpdater.h>
#include <vrvCore/DtSimDataProcessorInterface.h>
#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vlutil/vlPerformanceStats.h>
#include <vrvVrl/DtLaserDesignatorExistenceListener.h>

namespace makVrv
{
   class DtSimEntryObjectAgent;

   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtVrlinkConnection;
      class DtVrlinkEntityStateListener;
      class DtVrlinkAggregateStateListener;
   }
}

namespace makVrf
{
   class DtLaserDesignatorStateObjectAgent;
   
   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtLaserDesignatorSimDataProcessor : public makVrv::DtSimDataProcessorInterface
      {
      public:
         static DtLaserDesignatorSimDataProcessor* findInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,DtLaserDesignatorSimDataProcessor*);

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

         virtual ~DtLaserDesignatorSimDataProcessor();
         
         virtual void postDrainInput();

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

         virtual void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

         virtual void laserDesignatorDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkLaserDesignatorStateListener* listener);

         virtual void laserDesignatorToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkLaserDesignatorStateListener* listener);

         virtual void entityToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener);
         virtual void entityDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener);

         virtual void aggregateToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
         virtual void aggregateDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);

         virtual bool createAndSendState(makVrv::DtElementID entity,
            DtLaserDesignatorStateObjectAgent& objectDriver, DtLaserDesignatorState* state = 0);
         virtual void setState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkLaserDesignatorStateListener& listener,
            DtLaserDesignatorState& state);

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

      protected:

         static void postDrainInput(void* usr);

         virtual makVrv::DtUniqueID entityIdForLaser(const DtGlobalObjectDesignator&) const;
         virtual std::string entityTypeForLaser(const DtGlobalObjectDesignator&) const;

         virtual void slot_postUpdateCallback(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkLaserDesignatorStateListener&);

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

            LaserDesignatorStateUpdater(makVrv::DtElementID,
               DtLaserDesignatorStateObjectAgent& driver, DtLaserDesignatorSimDataProcessor& processor);

            LaserDesignatorStateUpdater(const LaserDesignatorStateUpdater& orig);

            LaserDesignatorStateUpdater& operator=(const LaserDesignatorStateUpdater& orig);

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

            void update(double timeT);

         protected:

            makVrv::DtElementID myEntity;
            DtLaserDesignatorStateObjectAgent* myObjectAgent;
            DtLaserDesignatorSimDataProcessor* myProcessor;
         };
    
         typedef std::set<makVrv::DtUniqueID> LaserDesignatorIdList;

         struct LaserDesignatorSimDataInstance
         {
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkLaserDesignatorStateListener* myListener;

            DtLaserDesignatorStateObjectAgent* myAgent;
            makVrv::DtUniqueID myHostId;
            makVrv::DtSimEntryUpdater::UpdateRate myRate;
         };

         typedef std::map<makVrv::DtUniqueID, LaserDesignatorSimDataInstance > LaserDesignatorAgentMap;

         typedef makVrv::DtBalancedUpdater<LaserDesignatorStateUpdater> LaserDesignatorUpdaterGroup;
         typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,LaserDesignatorUpdaterGroup>
            LaserDesignatorUpdateGroupMap;                  

      protected:
         makVrv::DtSignalConnectionManager myConnections;

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

         LaserDesignatorAgentMap myLaserDesignatorAgents;
         LaserDesignatorUpdateGroupMap myRefreshRateGroups;
         LaserDesignatorIdList myForceUpdateList;

         typedef std::map<makVrv::DtUniqueID, DtLaserDesignatorState> LaserDesignatorStates;
         LaserDesignatorStates myLaserDesignatorStates;

         typedef std::map<DtGlobalObjectDesignator, makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkLaserDesignatorStateListener*> AwaitingMap;
         AwaitingMap myAwaitingEntityDiscovery;
      };

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

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

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

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