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

#include <vlutil/vlPerformanceStats.h>

class DtAggregateStateRepository;
class DtVrfRemoteController;

namespace makVrv
{
   class DtSimEntryObjectAgent;

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

namespace makVrf
{
   class DtAggregateStateObjectAgent;
   
   namespace VRF_PROTOCOL_NAMESPACE
   {

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

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

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

         virtual ~DtAggregateSimDataProcessor();
         
         void postDrainInput();

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

         void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

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

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

         virtual void createAndSendState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
            DtAggregateStateObjectAgent& objectDriver, bool forceUpdate = false);
         virtual bool setState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
            DtVrlinkNetworkUpdateSimulatedAggregateState& state, const DtRwProperties& stateProperties,
            bool forceStatePropertyUpdate = false);

      protected:

         static void postDrainInput(void* usr);

         virtual void slot_postUpdateCallback(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener&);
         virtual void slot_damageStateSet(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener*);

         virtual void slot_modelSetChanged();

         virtual bool updateState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener, bool forceUpdate = false);
         virtual bool updateExtendedState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);

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

            AggregateStateUpdater(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
               DtAggregateStateObjectAgent& driver, DtAggregateSimDataProcessor& processor);

            AggregateStateUpdater(const AggregateStateUpdater& orig);

            AggregateStateUpdater& operator=(const AggregateStateUpdater& orig);

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

            void update(double timeT);

         protected:

            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* myListener;
            DtAggregateStateObjectAgent* myObjectAgent;
            DtAggregateSimDataProcessor* myProcessor;
         };
    
         typedef std::set<makVrv::DtUniqueID> AggregateIdList;

         struct AggregateSimDataInstance
         {
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* myListener;
            DtAggregateStateObjectAgent* myAgent;
            makVrv::DtSimEntryUpdater::UpdateRate myRate;
         };

         typedef std::map<makVrv::DtUniqueID,AggregateSimDataInstance > AggregateAgentMap;

         typedef makVrv::DtBalancedUpdater<AggregateStateUpdater> AggregateUpdaterGroup;
         typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,AggregateUpdaterGroup>
            AggregateUpdateGroupMap;                  

      protected:
         makVrv::DtSignalConnectionManager myConnections;

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

         AggregateAgentMap myAggregateAgents;
         AggregateUpdateGroupMap myRefreshRateGroups;
         AggregateIdList myForceUpdateList;
         DtVrfRemoteController* myRemoteController;

         typedef boost::unordered_map<makVrv::DtUniqueID, DtVrlinkNetworkUpdateSimulatedAggregateState> AggregateStates;
         AggregateStates myAggregateStates;

         typedef std::map<std::string, std::pair<DtRwProperties*, int> > BaseStateMap;
         BaseStateMap myBaseStateMap;

         std::map<makVrv::DtUniqueID, DtString> myExtendedLabels;
         std::map<makVrv::DtUniqueID, bool> myNeedsForcedUpdate;

         std::string myLastMarkingText;
      };

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

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

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

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