vrfAggregateObjectDataStateProcessor.h

Go to the documentation of this file.

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


#pragma once

#include <vrfVrlSharedSource/vrfProtocol.h>
#include <vrfGuiCore/DtVrfObjectDataStateObjectAgent.hpp>
#include <vrvVrl/DtAggregateExistenceListener.h>
#include <vrvVrl/DtVrlinkAggregateStateListener.h>
#include <vrvCore/DtSimDataProcessorInterface.h>

#include <vrvVrl/vrvVrl.h>
//#include <vrvCore/DtSimDataProcessor.h>

#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrvCore/DtSimEntryObjectAgent.hpp>
#include <vlutil/vlPerformanceStats.h>

class DtExtAggregateStateRepository;

namespace makVrv
{
   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtStateListenerInterface;
   }
}

namespace makVrf 
{
   class DtNetworkMessageInterfaceHandlerAgent;

   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtVrfAggregateObjectDataStateProcessor : public makVrv::DtSimDataProcessorInterface
      {
      public:

         static DtVrfAggregateObjectDataStateProcessor* findInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

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

         DtVrfAggregateObjectDataStateProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,
            int sessionId, int messageVersion);

         virtual ~DtVrfAggregateObjectDataStateProcessor();
         
         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,
            makVrv::DtSimStateObjectAgent& objectDriver);
         virtual void updateExtendedState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
         virtual void rangeItemsFrom(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
            std::vector<DtRangeItem>&);

         virtual void setupState(
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener, DtVrfNetworkUpdateObjectDataState&);

         virtual void addRangeRingItemToVisuals(const makVrf::DtRangeItem& item);

         boost::signals2::signal<void (makVrv::DtUniqueID, DtVrfNetworkUpdateObjectDataState&) > signal_stateUpdated;

         boost::signals2::signal<void (const DtExtAggregateStateRepository&, std::vector<makVrf::DtRangeItem>&) > signal_addAdditionalRangeRingItems;

      protected:

         static void postDrainInput(void* usr);

      protected:
         
         virtual void slot_modelSetChanged();

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

            VrfAggregateObjectDataStateUpdater(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener,
               DtVrfObjectDataStateObjectAgent& driver,
               DtVrfAggregateObjectDataStateProcessor& processor);

            VrfAggregateObjectDataStateUpdater(const VrfAggregateObjectDataStateUpdater& orig);

            VrfAggregateObjectDataStateUpdater& operator=(const VrfAggregateObjectDataStateUpdater& orig);

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

            void update(double timeT);

         protected:

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

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

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

         typedef makVrv::DtBalancedUpdater<VrfAggregateObjectDataStateUpdater> 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;
         
         int mySessionId;
         int myMessageVersion;

         mutable std::set<std::string> myRangeLabels;
         std::map<makVrv::DtUniqueID, DtString> myExtendedLabels;
         DtNetworkMessageInterfaceHandlerAgent* myNetworkMessageInterfaceHandlerAgent;

         typedef std::map<makVrv::DtUniqueID, DtVrfNetworkUpdateObjectDataState> StateMap;
         StateMap myStateMap;
      };

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

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

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

         virtual DtVrfAggregateObjectDataStateProcessor* create(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn, int sessionId, int messageVersion);
      };
   }
}