featureSet.h

Go to the documentation of this file.

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


#pragma once

#include <features/featuresDefines.h>

#include <memory>
#include <string>

#include <boost/function.hpp>
#include <boost/scoped_ptr.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/weak_ptr.hpp>

#include <boost/optional.hpp>
#include <boost/noncopyable.hpp>

#include <vrfutil/objectCounter.h>
#include <vrfutil/taggedException.h>

namespace MAKVRinTerra
{
   class DtFeature;
   class DtQuery;
   class DtFeatureGeometry;

   enum DtLoadType
   {
      LOAD,
      LOAD_ASYNC,
      DO_NOT_LOAD
   };

   template <
      typename FS,
      template <typename> class PtrTemplate = boost::scoped_ptr,
      typename InnerFS = FS>
   class DtFeatureSetWrapper;

   class DT_DLL_features DtFeatureSetLoadingException : public DtException
   {
   public:
      explicit DtFeatureSetLoadingException();
   };

   template <typename FS, typename InnerFS = FS>
   class DT_DLL_features DtFeatureSetList;

   template <size_t N, typename FS, typename InnerFS = FS>
   class DT_DLL_features DtFeatureSetArray;

   template <typename FS>
   class DT_DLL_features DtFilteredFeatureSet;

   template <typename FS>
   class DT_DLL_features DtEmptyFeatureSet;

   template <typename FS, typename F = typename FS::Feature>
   class DT_DLL_features DtSinkFeatureSet;

   template <typename FS>
   class DT_DLL_features DtSourceFeatureSet;

   template <typename F>
   class DT_DLL_features DtFeatureSetTemplate
      : private boost::noncopyable
      , public DtObjectDebugger< DtFeatureSetTemplate<F> >
   {
   public:
      typedef F Feature;

      typedef DtFeatureSetTemplate FeatureSet;

      typedef boost::function<void ()> DetachCallback;

      class DetachScopeGuard : boost::noncopyable
      {
         DetachCallback callback;

      public:
         explicit DetachScopeGuard(const DetachCallback& cb = DetachCallback()):
            callback(cb) {};
         ~DetachScopeGuard()
         {
            if (callback)
            {
               callback();
            }
         };
         
         void reset(const DetachCallback& cb = DetachCallback())
         {
            if (callback)
               callback();

            callback = cb;
         };
      };

      typedef boost::function<void (const Feature&)> ForEachFunction;

      typedef boost::function<void ()> LoadedCallback;

      typedef DtFeatureSetWrapper<FeatureSet, boost::scoped_ptr> ScopedWrapper;

      typedef DtFeatureSetWrapper<FeatureSet, boost::shared_ptr> SharedWrapper;


      typedef DtFeatureSetList<FeatureSet>      List;
      typedef DtFilteredFeatureSet<FeatureSet>  Filtered;
      typedef DtEmptyFeatureSet<FeatureSet>     Empty;
      typedef DtSinkFeatureSet<FeatureSet>      Sink;
      typedef DtSourceFeatureSet<FeatureSet>    Source;

      template <typename FS>
      static FeatureSet* Wrap(FS* fs)
      {
         std::auto_ptr<FS> set(fs);
         return Wrap(set);
      }

      static DtFeatureSetTemplate* Wrap(DtFeatureSetTemplate* fs)
      {
         return fs;
      }

      static DtFeatureSetTemplate* Wrap(std::auto_ptr<FeatureSet> fs)
      {
         return fs.release();
      }

      template <typename FS>
      static FeatureSet* Wrap(std::auto_ptr<FS> fs)
      {
         if (!fs.get() || fs->empty())
            return 0;

         return new DtFeatureSetWrapper<FeatureSet, boost::scoped_ptr, FS>(fs);
      }

      template <typename FS>
      static FeatureSet* Wrap(const boost::shared_ptr<FS>& fs)
      {
         if (!fs || fs->empty())
            return 0;

         return new DtFeatureSetWrapper<FeatureSet, boost::shared_ptr, FS>(fs);
      }

      template <typename FS>
      static FeatureSet* Wrap(const boost::weak_ptr<FS>& fs)
      {
         boost::shared_ptr<FS> ptr(fs.lock());
         if (!ptr || ptr->empty())
            return 0;

         return new DtFeatureSetWrapper<FeatureSet, boost::weak_ptr, FS>(fs);
      }

      virtual ~DtFeatureSetTemplate();

      virtual std::string label() const = 0;

      virtual void forEachFeatureParallel(const ForEachFunction& func) const = 0;

      void forEachFeature(const ForEachFunction& func) const;


      bool forEachFeatureParallelBlock(const ForEachFunction& func, double timeout = 60) const;
      bool forEachFeatureBlock(const ForEachFunction& func, double timeout = 60) const;

      virtual DetachCallback forEachFeatureAsync(const ForEachFunction& func) const = 0;


      virtual DtFeatureSetTemplate* filter(
         const DtQuery& query,
         const boost::optional<DtFeatureGeometry>& geometry,
         DtLoadType load) const;

      DtFeatureSetTemplate* filter(
         const DtQuery& query, DtLoadType load) const;

      DtFeatureSetTemplate* filter(
         const boost::optional<DtFeatureGeometry>& geometry, DtLoadType load) const;


      virtual bool load(
         const DtQuery& query,
         const boost::optional<DtFeatureGeometry>& geometry) const;

      bool load(const DtQuery& query) const;
      bool load(const boost::optional<DtFeatureGeometry>& geometry) const;

      virtual DtFeatureSetTemplate* clone() const = 0;

      virtual bool loaded(double timeout=0.0) const = 0;

      virtual DetachCallback addLoadedCallback(const LoadedCallback&) const = 0;

      virtual bool empty() const;

      virtual bool isIndexed() const;

      virtual unsigned numberOfFeatures() const;


      class Visitor
      {
      public:
         virtual ~Visitor();
         virtual void visit(FeatureSet&) = 0;
      };

      class ConstVisitor
      {
      public:
         virtual ~ConstVisitor();
         virtual void visit(const FeatureSet&) = 0;
      };


      virtual void accept(Visitor&);
      virtual void accept(ConstVisitor&) const;

   protected:
      class SynchronizedFunction;
      struct FeatureCounter;
   };

   template <typename F>
   inline DtFeatureSetTemplate<F>* new_clone(const DtFeatureSetTemplate<F>& from)
   {
      return from.clone();
   }


   template <typename FS>
   inline bool DtIsEmpty(const FS& fs)
   {
      return fs.empty();
   }

   template <typename FS>
   inline bool DtIsEmpty(FS* fs)
   {
      if (!fs)
         return true;

      return DtIsEmpty(*fs);
   }

   typedef DtFeatureSetTemplate<DtFeature> DtFeatureSet;
}

#define DT_INSTANTIATE_FEATURE_SETS(F)                                                             \
   template class MAKVRinTerra::DtFeatureSetTemplate<F>;                                           \
   template class MAKVRinTerra::DtFeatureSetList< MAKVRinTerra::DtFeatureSetTemplate<F> >;         \
   template class MAKVRinTerra::DtFeatureSetArray<4, MAKVRinTerra::DtFeatureSetTemplate<F> >;      \
   template class MAKVRinTerra::DtFilteredFeatureSet< MAKVRinTerra::DtFeatureSetTemplate<F> >;     \
   template class MAKVRinTerra::DtEmptyFeatureSet< MAKVRinTerra::DtFeatureSetTemplate<F> >;        \
   template class MAKVRinTerra::DtSinkFeatureSet< MAKVRinTerra::DtFeatureSetTemplate<F> >;         \
   template class MAKVRinTerra::DtSourceFeatureSet< MAKVRinTerra::DtFeatureSetTemplate<F> >;       \
   template class MAKVRinTerra::DtAsyncLoadingFeatureSet< MAKVRinTerra::DtFeatureSetTemplate<F> >; \
   template class MAKVRinTerra::DtPagingFeatureSet< MAKVRinTerra::DtFeatureSetTemplate<F> >;       \

DT_DEFINE_OBJECT_DEBUGGER_NAME_TEMPLATE(MAKVRinTerra::DtFeatureSetTemplate);
DT_DEFINE_OBJECT_DEBUGGER_NAME(MAKVRinTerra::DtFeatureSet);