vrfCloudLayerStateProcessor.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/DtCloudLayerProcessObjectAgent.hpp>

#include <vrvCore/DtSimDataProcessorInterface.h>
#include <vrvCore/DtShowHideContext.h>
#include <vrvVrl/DtCloudLayerStateListener.h>
#include <vrvVrl/DtVrlinkConnection.h>
#include <vrvVrl/DtCloudLayerElement.h>
#include <vrvVrl/DtEnvironmentalExistenceListener.h>
#include <vrvVrl/DtCloudLayerProcessor.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;
   }
}

namespace makVrf 
{
   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtVrfCloudLayerElement : public makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerElement
      {
      public:
         DtVrfCloudLayerElement(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn, makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerStateListener& listener);

         virtual ~DtVrfCloudLayerElement();

         virtual void setVisible(bool);
         virtual void show(int context);
         virtual void hide(int context);

         virtual bool isVisible() const;

      protected:
         virtual void sendAll();
         virtual void slot_cloudLayerUpdated();

         virtual void updateEnabledState();

      protected:
         std::set<int> myShowHideContexts;
         bool myVisible;
      };

      class VRF_PROTOCOL_EXPORT DtVrfCloudLayerProcessor : public makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerProcessor
      {
      public:
         DtVrfCloudLayerProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim, int sessionId);

         virtual ~DtVrfCloudLayerProcessor();

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

      protected:
         virtual void elementAttributeChangeRequested( 
            makVrv::DtUniqueID id, makVrv::DtUniqueID parentId, DtBoost::shared_ptr<const makVrv::DtElementAttribute> atr );
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerElement* createElement(makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerStateListener& listener);

      protected:
         int mySessionId;
      };

      class VRF_PROTOCOL_EXPORT DtVrfCloudLayerStateProcessor : public makVrv::DtSimDataProcessorInterface
      {
      public:

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

         virtual ~DtVrfCloudLayerStateProcessor();

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

         static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim,
            DtVrfCloudLayerStateProcessor* proc)
         {
            sim.registerInstance("DtVrfCloudLayerStateProcessor",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::DtCloudLayerStateListener& listener,
            DtCloudLayerProcessObjectAgent& objectDriver);

         virtual void setState(makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerStateListener& listener,
            DtVrlinkSimulatedCloudLayerState& state);

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

      protected:

         static void postDrainInput(void* usr);

      protected:
         
         //A Listener and a driver which will be updated with it.
         class VrfCloudLayerObjectDataStateUpdater
         {
         public:
            VrfCloudLayerObjectDataStateUpdater(makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerStateListener& listener,
               DtCloudLayerProcessObjectAgent& driver,
               DtVrfCloudLayerStateProcessor& processor);

            VrfCloudLayerObjectDataStateUpdater(const VrfCloudLayerObjectDataStateUpdater& orig);

            VrfCloudLayerObjectDataStateUpdater& operator=(const VrfCloudLayerObjectDataStateUpdater& orig);

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

            void update(double timeT);

         public:

            makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerStateListener* myListener;
            DtCloudLayerProcessObjectAgent* myAgent;
            DtVrfCloudLayerStateProcessor* myProcessor;
         };
    
         typedef std::vector<makVrv::DtUniqueID> CloudLayerIdList;

         struct CloudLayerSimDataInstance
         {
            makVrv::DT_PROTOCOL_NAMESPACE::DtCloudLayerStateListener* myListener;
            DtCloudLayerProcessObjectAgent* myAgent;
            makVrv::DtSimEntryUpdater::UpdateRate myRate;
            DtVrlinkSimulatedCloudLayerState myState;
         };

         typedef std::map<makVrv::DtUniqueID,CloudLayerSimDataInstance > CloudLayerAgentMap;

         typedef makVrv::DtBalancedUpdater<VrfCloudLayerObjectDataStateUpdater> CloudLayerUpdaterGroup;
         typedef std::map<makVrv::DtSimEntryUpdater::UpdateRate,CloudLayerUpdaterGroup>
            CloudLayerUpdateGroupMap;                  

      protected:

         makVrv::DtSignalConnectionManager myConnections;

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

         CloudLayerAgentMap myCloudLayerAgents;
         CloudLayerUpdateGroupMap myRefreshRateGroups;
         CloudLayerIdList myForceUpdateList;
      };

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

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

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

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