dynamicFeaturesManager.h

Go to the documentation of this file.

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


#pragma once

#include <vrfobjcore/vrfobjcoreDefines.h>
#include <vrfobjcore/vrfObjectPredicate.h>

#include <features/featureSet.h>
#include <features/feature.h>
#include <features/featureGeometry.h>
#include <features/featureSetUtils.h>

#include <vrfExtProtocol/objectType.h>

#include <vrfutil/callbackQueue.h>

#include <tbb/spin_mutex.h>
#include <tbb/spin_rw_mutex.h>

#include <boost/optional.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/signals2.hpp>

class DtSimManager;
class DtVrfObject;
class DtVrfObjectPredicateEvaluator;

namespace MAKVRinTerra
{
   class DtVrfObjectFeatureSet;
}

class DT_DLL_vrfobjcore DtDynamicFeaturesManager
{
public:
   friend class MAKVRinTerra::DtVrfObjectFeatureSet;

   typedef std::vector<DtObjectType> ObjectTypes;

   static DtDynamicFeaturesManager* create(DtSimManager*);

   explicit DtDynamicFeaturesManager(DtSimManager* mgr);

   virtual ~DtDynamicFeaturesManager();

   virtual MAKVRinTerra::DtFeatureSet* root();

   virtual void init();

   virtual void setObjectTypes(const ObjectTypes&);

   virtual void tick();

   virtual void objectAddedCallback(DtVrfObject*);
   virtual void objectDeletedCallback(DtVrfObject*);

protected:
   static void objectAddedCallbackFunc(DtVrfObject*, void*);
   static void objectDeletedCallbackFunc(DtVrfObject*, void*);

private:
   DtSimManager* mySimMgr;

   boost::shared_ptr<MAKVRinTerra::DtVrfObjectFeatureSet> myFeatureSet;
   ObjectTypes myObjectTypes;
};

namespace MAKVRinTerra
{
   class DT_DLL_vrfobjcore DtVrfObjectFeature
      : public DtFeature
      , public boost::enable_shared_from_this<DtVrfObjectFeature>
      , public DtObjectDebugger<DtVrfObjectFeature>
   {
   public:
      typedef boost::shared_ptr<DtVrfObjectFeature> Ptr;
      typedef boost::shared_ptr<const DtVrfObjectFeature> CPtr;

      DtVrfObjectFeature(DtVrfObject*);

      ~DtVrfObjectFeature();

      DtFeature* clone() const;

      DtFeatureGeometry geometry() const;

      void forEachAttribute(ForEachFunction f) const;

      unsigned numberOfAttributes(const Key::String &) const;

      bool hasAttribute(const Key & k) const;

      boost::optional<Attribute> attribute(const Key &) const;

      DetachCallback addDeleteCallback(const DeleteCallback&) const;
      bool isDeleted() const;

      virtual bool isChanged() const;

      virtual void removeFromVrf();

      DtObjectType objectType() const;
      std::string objectName() const;
      DtVector position() const;
      boost::optional<double> percentComplete() const;
      boost::optional<bool> isBreached() const;

   protected:
      typedef tbb::spin_rw_mutex Mutex;
      mutable Mutex myMutex;

      typedef boost::signals2::signal<void ()> DeleteSignal;
      mutable DeleteSignal myDeleteSignal;

      DtVrfObject* myObject;
      DtObjectType myObjectType;
      std::string myObjectTypeString;
      DtFeatureGeometry myGeometry;

      DtVector myLastPosition;

      typedef std::map<Key, Attribute> AttributeMap;
      AttributeMap myAttributes;

   private:
   };

   class DT_DLL_vrfobjcore DtVrfObjectFeatureSet
      : public DtFeatureSet::Source
      , public DtObjectDebugger<DtVrfObjectFeatureSet>
   {
   public:
      friend class ::DtDynamicFeaturesManager;

      typedef boost::shared_ptr<DtVrfObjectFeatureSet>       Ptr;
      typedef boost::shared_ptr<const DtVrfObjectFeatureSet> CPtr;

      class CallbackQueue
      {
      public:
         explicit CallbackQueue();

         void queueAdd(const DtVrfObjectFeature::Ptr&, DtVrfObjectFeatureSet&);
         void queueRemove(const DtVrfObjectFeature::Ptr&);
         void queueChange(
            const DtVrfObjectFeature::Ptr& from, const DtVrfObjectFeature::Ptr& to,
            DtVrfObjectFeatureSet&);

      private:
         DtCallbackQueue myQueue;
      };

      Ptr shared_from_this();

      std::string label() const;
      DtFeatureSet* filter(const DtQuery&, const boost::optional<DtFeatureGeometry>&, DtLoadType) const;
      DetachCallback addLoadedCallback(const LoadedCallback&) const;

      FeaturePtr addFeaturePtr(Feature* feature);

      void add(DtVrfObject*, const DtDynamicFeaturesManager::ObjectTypes&);
      void remove(DtVrfObject*);
      void changed(DtVrfObject*);

      void tick();

   protected:
      static void verticesChangedCallback(DtVrfObject*, void*);

      explicit DtVrfObjectFeatureSet(DtSimManager*);
      explicit DtVrfObjectFeatureSet(const DtVrfObjectFeatureSet& from);

      DtSimManager* mySimManager;

      typedef std::map<DtVrfObject*, DtVrfObjectFeature::Ptr> ObjectMap;
      ObjectMap myObjects;

      CallbackQueue myCallbackQueue;

      typedef boost::signals2::signal<void ()> LoadedSignal;
      mutable LoadedSignal myLoadedSignal;
   };
}

DT_DEFINE_OBJECT_DEBUGGER_NAME(MAKVRinTerra::DtVrfObjectFeature);
DT_DEFINE_OBJECT_DEBUGGER_NAME(MAKVRinTerra::DtVrfObjectFeatureSet);