vrfWeatherStateProcessor.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/DtWeatherProcessObjectAgent.hpp>

#include <vrvCore/DtSimDataProcessorInterface.h>
#include <vrvVrl/DtWeatherStateListener.h>
#include <vrvVrl/DtVrlinkConnection.h>
#include <vrvVrl/DtEnvironmentalExistenceListener.h>
#include <vrvVrl/DtWeatherProcessor.h>
#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrvCore/DtSimEntryObjectAgent.hpp>
#include <vlutil/vlPerformanceStats.h>

namespace makVrv
{
   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtStateListenerInterface;
      class DtWeatherStateListener;
   }
}

namespace makVrf 
{
   class DtGlobalEnvironmentObjectAgent;

   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtVrfWeatherProcessor : public makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherProcessor
      {
      public:
         DtVrfWeatherProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim, int sessionId);

         virtual ~DtVrfWeatherProcessor();

         virtual void slot_environmentalDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEnvironmentalStateListenerInterface& listener);

      protected:
         int mySessionId;
      };

      class VRF_PROTOCOL_EXPORT DtVrfWeatherStateProcessor : public makVrv::DtSimDataProcessorInterface
      {
      public:

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

         virtual ~DtVrfWeatherStateProcessor();

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

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

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

         void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

         void environmentDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEnvironmentalStateListenerInterface& listener);

         void environmentToBeDeleted(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEnvironmentalStateListenerInterface& listener);

         virtual void createAndSendState(makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener& listener,
            DtWeatherProcessObjectAgent& objectDriver);

         virtual void setState(makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener& listener,
            DtVrlinkSimulatedWeatherState& state);

         virtual void slot_postUpdateCallback(
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEnvironmentalStateListenerInterface& listener);

         virtual void setUseGlobalTimeZone(bool);

      protected:

         static void postDrainInput(void* usr);

      protected:
         
         //A Listener and a driver which will be updated with it.
         class VrfWeatherObjectDataStateUpdater
         {
         public:
            VrfWeatherObjectDataStateUpdater(makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener& listener,
               DtWeatherProcessObjectAgent& driver,
               DtVrfWeatherStateProcessor& processor);

            VrfWeatherObjectDataStateUpdater(const VrfWeatherObjectDataStateUpdater& orig);

            VrfWeatherObjectDataStateUpdater& operator=(const VrfWeatherObjectDataStateUpdater& orig);

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

            void update(double timeT);

         public:

            makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener* myListener;
            DtWeatherProcessObjectAgent* myAgent;
            DtVrfWeatherStateProcessor* myProcessor;
         };
    
         typedef std::vector<makVrv::DtUniqueID> WeatherIdList;

         struct WeatherSimDataInstance
         {
            makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener* myListener;
            DtWeatherProcessObjectAgent* myAgent;
            makVrv::DtSimEntryUpdater::UpdateRate myRate;
            DtVrlinkSimulatedWeatherState myState;
         };

         typedef std::map<makVrv::DtUniqueID,WeatherSimDataInstance > WeatherAgentMap;

         typedef makVrv::DtBalancedUpdater<VrfWeatherObjectDataStateUpdater> WeatherUpdaterGroup;
         typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,WeatherUpdaterGroup>
            WeatherUpdateGroupMap;                  

      protected:

         makVrv::DtSignalConnectionManager myConnections;

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

         WeatherAgentMap myWeatherAgents;
         WeatherUpdateGroupMap myRefreshRateGroups;
         WeatherIdList myForceUpdateList;

         makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener* myGlobalEnvironment;
         DtGlobalEnvironmentObjectAgent* myGlobalEnvironmentObjectAgent;
      };

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

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

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

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