orbatSimDataProcessor.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/orbatState.h>
#include <vrvCore/DtSimEntryUpdater.h>
#include <vrvCore/DtSimDataProcessorInterface.h>
#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>

#include <vlutil/vlPerformanceStats.h>

class DtVrfRemoteController;
class DtRwOrbatData;

namespace makVrv
{
   class DtSimEntryObjectAgent;
   class DtEntityStateListener;

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

namespace makVrf
{
   class DtOrbatStateObjectAgent;
   
   namespace VRF_PROTOCOL_NAMESPACE
   {
      class DtOrbatStateListenerInterface;

      class VRF_PROTOCOL_EXPORT DtOrbatSimDataProcessor : public makVrv::DtSimDataProcessorInterface
      {
      public:
         static DtOrbatSimDataProcessor* findInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

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

         DtOrbatSimDataProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,
            DtVrfRemoteController* remote);

         virtual ~DtOrbatSimDataProcessor();
         
         virtual void postDrainInput();

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

         virtual void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

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

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

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

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

         virtual void addOrbatListener(DtOrbatStateListenerInterface& listener);

         virtual void removeOrbatListener(DtOrbatStateListenerInterface& listener);

         virtual void createAndSendState(DtOrbatStateListenerInterface& listener,
            DtOrbatStateObjectAgent& objectDriver);
         virtual bool setState(DtOrbatStateListenerInterface& listener, DtOrbatState& state);

      protected:

         static void postDrainInput(void* usr);

         virtual void slot_postAggregateUpdateCallback(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener&);
         virtual void slot_postEntityUpdateCallback(makVrv::DtEntityStateListener&);

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

            OrbatStateUpdater(DtOrbatStateListenerInterface& listener,
               DtOrbatStateObjectAgent& driver, DtOrbatSimDataProcessor& processor);

            OrbatStateUpdater(const OrbatStateUpdater& orig);

            OrbatStateUpdater& operator=(const OrbatStateUpdater& orig);

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

            void update(double timeT);

         protected:

            DtOrbatStateListenerInterface* myListener;
            DtOrbatStateObjectAgent* myObjectAgent;
            DtOrbatSimDataProcessor* myProcessor;
         };
    
         typedef std::set<makVrv::DtUniqueID> OrbatIdList;

         struct OrbatSimDataInstance
         {
            DtOrbatStateListenerInterface* myListener;
            DtOrbatStateObjectAgent* myAgent;
            makVrv::DtSimEntryUpdater::UpdateRate myRate;
         };

         typedef std::map<makVrv::DtUniqueID,OrbatSimDataInstance > OrbatAgentMap;

         typedef makVrv::DtBalancedUpdater<OrbatStateUpdater> OrbatUpdaterGroup;
         typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,OrbatUpdaterGroup>
            OrbatUpdateGroupMap;                  

      protected:
         makVrv::DtSignalConnectionManager myConnections;

         makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& mySimulation;
         makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateExistenceListener& myAggregateListener;
         makVrv::DT_PROTOCOL_NAMESPACE::DtEntityExistenceListener& myEntityListener;
         DtTimedSection myTimer;
         makVrv::DtSimEntryObjectAgent* mySimEntryAgent;

         OrbatAgentMap myOrbatAgents;
         OrbatUpdateGroupMap myRefreshRateGroups;
         OrbatIdList myForceUpdateList;
         DtVrfRemoteController* myRemoteController;
      };

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

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

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

         virtual DtOrbatSimDataProcessor* create(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn, DtVrfRemoteController* remote);
      };
   }
}