vrfObjectDataStateProcessor.h

Go to the documentation of this file.

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


#pragma once

#include <vrfGuiNetworkCommon/vrfGuiNetworkCommonDefines.h>
#include <vrfGuiNetworkCommon/vrfDataProcessorInterface.inl>
#include <vrfGuiCore/DtVrfObjectDataStateObjectAgent.hpp>
#include <vrfStateData/rangeItemsStateComponent.h>
#include <vrfGuiCore/vrfObjectDataState.h>
#include <unordered_map>
#include <unordered_set>

namespace makVrf 
{
   class DtNetworkMessageInterfaceHandlerAgent;

   class DT_DLL_vrfGuiNetworkCommon DtVrfObjectDataStateProcessor : public DtVrfDataProcessor<DtVrfObjectDataStateObjectAgent>
   {
   public:
      static DtVrfObjectDataStateProcessor* findInstance(makVrv::DtBaseConnection& c);

      DtVrfObjectDataStateProcessor(DtStateDataManager*, makVrv::DtBaseConnection&, int sessionId, int messageVersion);

      virtual ~DtVrfObjectDataStateProcessor();

      virtual void createAndSendState(DtStateData* sd,
         makVrv::DtSimStateObjectAgent& objectDriver, bool force = false);

      virtual const makVrv::DtSimState& emptyState() const;

      virtual void setState(const DtStateData*, makVrv::DtSimState& state);

      static const char* ProcessorName() { return "DtVrfObjectDataStateProcessor"; };
      virtual const char* processorName() const { return ProcessorName(); };

      virtual void setLightweightMode(bool);
      bool lightweightMode() const
      {
         return myLightweightMode;
      }

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

   protected:

      virtual void addSimData(DtStateData* listener);
      virtual void removeData(Legion::UInt64 legionGlobalId);
      virtual void slot_postUpdateCallback(const DtStateData*);
      virtual void setupObjectStateData();
      virtual void addRangeRingItemToVisuals(const DtRangeItem& item);
      virtual bool rangeItemsFrom(const DtStateData* sd, const DtRangeItems& sourceItems, std::vector<DtRangeItem>& items);
      virtual bool shouldForceObjectUpdate(const DtFrameStateInterface*) const;
      virtual void slot_visualizerCreationDisabled(bool b, int type);
      virtual void addToState(const DtStateData* sd, makVrv::DtSimState& baseState);
      virtual void updateOnlyModifiedStatePropertiesSince(const DtRwProperties& source, DtRwProperties& target, double since);

   protected:
      typedef std::unordered_map<makVrv::DtUniqueID, DtVrfNetworkUpdateObjectDataState> Cache;
      Cache myCache;

      int mySessionId;
      int myMessageVersion;

      mutable std::set<std::string> myRangeLabels;
      DtNetworkMessageInterfaceHandlerAgent* myNetworkMessageInterfaceHandlerAgent;

      int myShowBoundingVolumeCount;
      bool myLightweightMode;
      mutable tbb::spin_mutex myForceUpdateDueToStatePropertyChangedMutex;
      mutable std::unordered_set<makVrv::DtUniqueID> myForceUpdateDueToStatePropertyChanged;
   };

   class DT_DLL_vrfGuiNetworkCommon DtVrfObjectDataStateProcessorCreator : public makVrv::DtVirtualBaseClass
   {
   public:
      DtVrfObjectDataStateProcessorCreator();

      static DtVrfObjectDataStateProcessorCreator& instance(makVrv::DtBaseConnection& conn);

      static void registerInstance(makVrv::DtBaseConnection& conn, DtVrfObjectDataStateProcessorCreator* instance);

      virtual DtVrfObjectDataStateProcessor* create(DtStateDataManager*, makVrv::DtBaseConnection&, int sessionId, int messageVersion);
   };
}