datacollector.hh

Go to the documentation of this file.

#ifndef DUNE_FEM_DATACOLLECTOR_HH
#define DUNE_FEM_DATACOLLECTOR_HH
 
//-System includes
#include <cassert>
#include <cstdlib>
 
#include <vector>
#include <utility>
#include <iostream>
 
//-Dune includes
#include <dune/common/dynvector.hh>
#include <dune/common/version.hh>
 
//- local includes
#include <dune/fem/misc/gridobjectstreams.hh>
#include <dune/fem/operator/common/objpointer.hh>
 
namespace Dune
{
 
  namespace Fem
  {
 
    // external forward declerations
    // -----------------------------
 
    template<class>
    struct DiscreteFunctionTraits;
 
    template <class GridImp> class DofManager;
 
    template <class LocalOp, class ParamType> class LocalInlinePlus;
 
 
    // define read or write stream
    struct DataCollectorTraits
    {
      enum ReadWriteType { readData , writeData };
    };
 
    template <class A, class B >
    class CombinedLocalDataCollect
      : public LocalInlinePlus< CombinedLocalDataCollect< A, B >, typename A::Traits::ParamType >
    {
    protected:
      const A& a_;
      const B& b_;
    public:
      CombinedLocalDataCollect( const A& a, const B& b ) : a_( a ), b_( b ) {}
 
      template <class Arg>
      void apply(Arg & arg) const
      {
        a_.apply( arg );
        b_.apply( arg );
      }
 
      template <class Arg1, class Arg2>
      void apply(Arg1 & arg1, Arg2 & arg2) const
      {
        a_.apply( arg1, arg2 );
        b_.apply( arg1, arg2 );
      }
    };
 
    template <class ParamT>
    class LocalInterface : public ObjPointerStorage
    {
    public:
      typedef LocalInterface<ParamT> MyType;
      struct Traits
      {
        typedef ParamT ParamType;
      };
 
      template <class PT>
      struct ObjectStreamExtractor
      {
        typedef PT ObjectStreamType ;
      };
 
      template < class T1 , class T2 >
      struct ObjectStreamExtractor< std::pair< T1* , const T2* > >
      {
        typedef T1 ObjectStreamType ;
      };
 
      typedef typename ObjectStreamExtractor< ParamT > :: ObjectStreamType ObjectStreamType;
 
    protected:
      typedef ParamT ParamType;
      typedef void FuncType(MyType &, ParamType & p);
      typedef typename std::pair < MyType * ,  FuncType * > PairType;
      typedef typename std::vector < PairType > ListType;
 
      template <class OpType>
      struct AddToWrapper
      {
        static void applyWrapper(MyType & m, ParamType & p )
        {
          static_cast<OpType &> (m).apply(p);
        }
 
        static void addToList (ListType & vec , const OpType & op )
        {
          PairType p( const_cast<OpType *> (&op) , applyWrapper);
          vec.push_back(p);
        }
      };
 
      // copy list of op to this class
      static void copyList (ListType & vec, const MyType & op )
      {
        const ListType & ve = op.vec_;
        if(ve.size() > 0)
        {
          ListType tmp ( vec );
          vec.resize( vec.size() + ve.size() );
 
          // copy list to new vector
          for(unsigned int i=0; i<tmp.size(); i++)
            vec[i] = tmp[i];
          for(unsigned int i=tmp.size(); i<vec.size(); i++)
            vec[i] = ve[i-tmp.size()];
        }
      }
 
    public:
      LocalInterface () : vec_ (0) {}
 
      template <class OpType>
      LocalInterface (const OpType & op)
      {
        AddToWrapper<OpType>::addToList(vec_,op);
      }
 
      LocalInterface (const MyType & op)
      {
        copyList(vec_,op);
      }
 
      virtual ~LocalInterface() {};
 
      void apply ( ParamType & p ) const
      {
        const size_t size = vec_.size();
        for(size_t i=0; i<size; ++i)
        {
          assert( vec_[i].second );
          assert( vec_[i].first );
          // vec_[i].second contains the pointer to the function that makes the
          // correct cast to the real type of vec_[i].first
          (*vec_[i].second)( *(vec_[i].first) , p );
        }
      }
 
      template <class OpType>
      MyType & operator + (const OpType & op)
      {
        AddToWrapper<OpType>::addToList(vec_,op);
        return *this;
      }
 
      MyType & operator + (const MyType & op)
      {
        copyList(vec_,op);
        return *this;
      }
 
      template <class OpType>
      MyType & operator += (const OpType & op)
      {
        AddToWrapper<OpType>::addToList(vec_,op);
        return *this;
      }
 
      MyType & operator += (const MyType & op)
      {
        copyList(vec_,op);
        return *this;
      }
 
      template <class OpType>
      void remove(const OpType & op)
      {
        typedef typename ListType :: iterator iterator;
        iterator end = vec_.end();
        for(iterator it = vec_.begin(); it != end; ++it)
        {
          if( &op == (*it).first )
          {
            vec_.erase( it );
            return ;
          }
        }
      }
 
      template <class OpType>
      MyType & operator = (const OpType & op)
      {
        AddToWrapper<OpType>::addToList(vec_,op);
        return *this;
      }
 
      bool empty () const { return (vec_.size() == 0); }
 
    private:
      mutable ListType vec_;
    };
 
    template <class LocalOp, class ParamT>
    class LocalInlinePlus : public LocalInterface<ParamT>
    {
    public:
      struct Traits
      {
        typedef ParamT ParamType;
        typedef LocalInterface<ParamType> LocalInterfaceType;
      };
 
      template <class B>
      CombinedLocalDataCollect<LocalOp,B> & operator + (const B & b)
      {
        //std::cout << "operator + of LocalInlinePlus \n";
        typedef CombinedLocalDataCollect<LocalOp,B> CombinedType;
        CombinedType * combo = new CombinedType ( asImp() , b );
        this->saveObjPointer( combo );
        return *combo;
      }
      LocalOp & asImp() { return static_cast<LocalOp &> (*this); }
    };
 
    template <class GridType, class ObjectStreamImp = DummyObjectStream >
    class DataCollectorInterface
    {
    public:
      typedef ObjectStreamImp  ObjectStreamType;
 
 
      typedef typename GridType::template Codim<0>::Entity EntityType;
 
      typedef DataCollectorInterface<GridType, ObjectStreamImp> MyType;
      typedef std::pair < ObjectStreamType * , const EntityType * >  DataCollectorParamType;
 
    public:
      typedef LocalInterface<DataCollectorParamType> LocalInterfaceType;
 
      struct Traits
      {
        typedef LocalInterface<DataCollectorParamType> LocalInterfaceType;
      };
 
      DataCollectorInterface () : dc_ (0) {}
 
      virtual ~DataCollectorInterface() { clear(); }
 
      virtual void apply (ObjectStreamType &str, const EntityType & entity ) const
      {
        // if dc_ was set (otherwise we might be load balancing only the grid)
        if(dc_)
        {
          (*dc_).apply(str, entity );
        }
      };
 
      virtual const LocalInterfaceType & getLocalInterfaceOp () const
      {
        if(dc_)
          return dc_->getLocalInterfaceOp ();
        else
        {
          std::cerr << "No LocalInterfaceOperator \n";
          assert(false);
          return *(new LocalInterfaceType());
        }
      };
 
      virtual LocalInterfaceType & getLocalInterfaceOp ()
      {
        if(dc_)
          return dc_->getLocalInterfaceOp ();
        else
        {
          std::cerr << "No LocalInterfaceOperator \n";
          assert(false);
          return *(new LocalInterfaceType());
        }
      };
 
      template <class OpType>
      MyType & operator += (const OpType & dc)
      {
        if(dc_)
        {
          //std::cout << "Operator += with OpType \n";
          dc_ = dcConv_;
          MyType * tmp = const_cast<OpType &> (dc).convert();
          dc_ = &(*dc_).operator += (*tmp);
        }
        else
        {
          dc_     = const_cast<OpType *> (&dc);
          dcConv_ = const_cast<OpType &> (dc).convert();
        }
        return (*this);
      }
 
      virtual MyType & operator += (const MyType & dc)
      {
        if(dc_)
        {
          //std::cout << "Operator += with MyType \n";
          dc_ = dcConv_;
          dc_ = &(*dc_).operator += (dc);
        }
        else
        {
          dc_ = const_cast<MyType *> (&dc);
          dcConv_ = const_cast<MyType *> (&dc);
        }
        return (*this);
      }
 
      template <class OpType>
      MyType & operator = (const OpType & dc)
      {
        //std::cout << "Store operator \n";
        dc_     = const_cast<OpType *> (&dc);
        dcConv_ = const_cast<OpType &> (dc).convert();
        return (*this);
      }
 
      MyType & operator = (const MyType & dc)
      {
        //std::cout << "No need to do this, use += \n";
        dc_     = const_cast<MyType *> (dc.dc_);
        dcConv_ = const_cast<MyType *> (dc.dcConv_);
        return (*this);
      }
 
      virtual void clear()
      {
        dc_ = 0;
        dcConv_ = 0;
      }
    private:
      MyType *dc_;
      MyType *dcConv_;
    };
 
 
    template <class GridType>
    class DummyDataCollector
    {
      typedef DummyDataCollector<GridType> MyType;
    public:
 
      typedef std::pair < int * , int * > DataCollectorParamType;
      typedef LocalInterface<DataCollectorParamType> LocalInterfaceType;
      void apply (int , int ) const
      {
        std::cerr << "WARNING: apply: did nothing! \n";
      };
 
      template <class OpType>
      MyType & operator += (const OpType & dc)
      {
        return (*this);
      }
 
      template <class OpType>
      MyType & operator = (const OpType & dc)
      {
        return (*this);
      }
    };
 
 
    template <class GridType,
              class LocalDataCollectImp >
    class DataCollector
    : public DataCollectorInterface< GridType, typename LocalDataCollectImp :: ObjectStreamType >
    , public ObjPointerStorage
    {
    public:
      typedef typename LocalDataCollectImp :: ObjectStreamType ObjectStreamType;
      typedef typename GridType::template Codim<0>::Entity EntityType;
 
    protected:
      typedef DataCollectorInterface< GridType, ObjectStreamType > BaseType;
      typedef typename DataCollectorTraits :: ReadWriteType ReadWriteType;
 
      typedef DataCollector<EntityType,LocalDataCollectImp> MyType;
      typedef DofManager<GridType> DofManagerType;
 
      typedef typename std::pair < ObjectStreamType * , const EntityType * > ParamType;
      typedef LocalInterface<ParamType> LocalInterfaceType;
 
      friend class DataCollectorInterface<GridType, ObjectStreamType>;
      typedef DataCollectorInterface<GridType, ObjectStreamType> DataCollectorInterfaceType;
 
    public:
      DataCollector (GridType & grid,
                     DofManagerType & dm,
                     LocalDataCollectImp & ldc,
                     const ReadWriteType rwType,
                     int numChildren = 8)
        : grid_(grid) , dm_ ( dm ), ldc_ (ldc)
        , rwType_( rwType )
        , numChildren_(numChildren)
      {}
 
      virtual ~DataCollector () {}
 
      template <class LocalDataCollectType>
      DataCollector<GridType,
      CombinedLocalDataCollect <LocalDataCollectImp,LocalDataCollectType> > &
      operator + (const DataCollector<GridType,LocalDataCollectType> &op)
      {
        typedef DataCollector<GridType,LocalDataCollectType> CopyType;
        typedef CombinedLocalDataCollect <LocalDataCollectImp,LocalDataCollectType> COType;
 
        COType *newLDCOp = new COType ( ldc_  , const_cast<CopyType &> (op).getLocalOp() );
        typedef DataCollector <GridType, COType> OPType;
 
        OPType *dcOp = new OPType ( grid_ , dm_ , *newLDCOp, rwType_ );
 
        // memorize this new generated object because is represents this
        // operator and is deleted if this operator is deleted
        saveObjPointer( dcOp , newLDCOp );
 
        return *dcOp;
      }
 
      template <class LocalDataCollectType>
      DataCollector<GridType,LocalInterface<ParamType> > &
      operator += (const DataCollector<GridType,LocalDataCollectType> &op)
      {
        typedef LocalInterface<ParamType> COType;
 
        COType *newLDCOp = new COType ( ldc_ + op.getLocalOp() );
        typedef DataCollector <GridType, COType> OPType;
 
        OPType *dcOp = new OPType ( grid_ , dm_ , *newLDCOp, rwType_ );
 
        // memorize this new generated object because is represents this
        // operator and is deleted if this operator is deleted
        saveObjPointer( dcOp , newLDCOp );
 
        return *dcOp;
      }
 
      DataCollectorInterfaceType &
      operator += (const DataCollectorInterfaceType &op)
      {
        //std::cout << "operator += with Interface Type \n";
        typedef LocalInterface<ParamType> COType;
 
        COType *newLDCOp = new COType ( ldc_ + op.getLocalInterfaceOp() );
        typedef DataCollector<GridType, COType> OPType;
 
        OPType *dcOp = new OPType ( grid_ , dm_ , *newLDCOp, rwType_ );
 
        // memorize this new generated object because is represents this
        // operator and is deleted if this operator is deleted
        saveObjPointer( dcOp , newLDCOp );
 
        return *dcOp;
      }
 
      const LocalDataCollectImp & getLocalOp () const
      {
        return ldc_;
      }
 
      LocalDataCollectImp & getLocalOp ()
      {
        return ldc_;
      }
 
      const LocalInterfaceType & getLocalInterfaceOp () const
      {
        //std::cout << "getLocalInter \n";
        return ldc_;
      }
 
      LocalInterfaceType & getLocalInterfaceOp ()
      {
        //std::cout << "getLocalInter \n";
        return ldc_;
      }
 
      bool writeData() const  { return rwType_ == DataCollectorTraits :: writeData ; }
 
      void apply ( ObjectStreamType & str, const EntityType & entity ) const
      {
        ParamType p( &str , &entity );
        // apply local operators
        ldc_.apply( p );
      }
 
      void inlineData (ObjectStreamType & str, const EntityType & entity ) const
      {
        // read/write macro element
        inlineLocal(str, entity );
 
        // if given entity is not leaf then pack entire hierarchy
        if( ! entity.isLeaf() )
        {
          const int mxlvl = grid_.maxLevel();
 
          typedef typename EntityType::HierarchicIterator HierarchicIteratorType;
          const HierarchicIteratorType endit  = entity.hend( mxlvl );
          for(HierarchicIteratorType it = entity.hbegin( mxlvl );
              it != endit; ++it )
          {
            inlineLocal(str, *it);
          }
        }
      }
 
      void xtractData (ObjectStreamType & str, const EntityType & entity ) const
      {
        // read/write macro element
        xtractLocal(str, entity );
 
        // if given entity is not leaf then unpack entire hierarchy
        if( ! entity.isLeaf() )
        {
          const int mxlvl = grid_.maxLevel();
 
          typedef typename EntityType::HierarchicIterator HierarchicIteratorType;
          const HierarchicIteratorType endit  = entity.hend( mxlvl );
          for(HierarchicIteratorType it = entity.hbegin( mxlvl );
              it != endit; ++it )
          {
            xtractLocal(str, *it);
          }
        }
      }
 
    private:
      DataCollector<GridType,LocalInterface<ParamType> > * convert ()
      {
        typedef LocalInterface<ParamType> COType;
 
        COType *newLDCOp = new COType ( ldc_ );
        typedef DataCollector <GridType, COType> OPType;
 
        OPType *dcOp = new OPType ( grid_ , dm_ , *newLDCOp, rwType_ );
 
        // memorize this new generated object because is represents this
        // operator and is deleted if this operator is deleted
        saveObjPointer( dcOp , newLDCOp );
 
        return dcOp;
      }
 
      // write data of entity
      void inlineLocal(ObjectStreamType & str, const EntityType& entity ) const
      {
        assert( writeData() );
 
        ParamType p( &str , &entity );
        // apply local operators
        ldc_.apply( p );
      }
 
      // read data of entity
      void xtractLocal(ObjectStreamType & str, const EntityType& entity ) const
      {
        assert( ! writeData() );
 
        ParamType p( &str , &entity );
        // apply local operators
        ldc_.apply( p );
      }
 
      GridType &grid_;
 
      DofManagerType &dm_;
 
      LocalDataCollectImp &ldc_;
 
      const ReadWriteType rwType_;
 
      // number of childs one element can have
      const int numChildren_;
    };
 
 
    //***********************************************************************
    template< class DiscreteFunctionType >
    struct LocalDataInlinerTraits
    {
      typedef typename DiscreteFunctionType::DiscreteFunctionSpaceType
        DiscreteFunctionSpaceType;
      typedef typename DiscreteFunctionSpaceType::GridType        GridType;
      typedef typename DiscreteFunctionSpaceType::EntityType      EntityType;
      typedef typename GridType :: template Codim< 0 > :: Entity  GridEntityType;
 
      typedef DofManager < GridType > DofManagerType ;
      typedef typename DofManagerType :: InlineStreamType ObjectStreamType;
 
      typedef std::pair< ObjectStreamType *, const GridEntityType * > ParamType;
      typedef LocalInterface< ParamType > LocalInterfaceType;
    };
 
 
    template< class DiscreteFunctionType,
              class ContainsCheck >
    class LocalDataInliner
    : public LocalInlinePlus< LocalDataInliner< DiscreteFunctionType, ContainsCheck >,
                              typename LocalDataInlinerTraits< DiscreteFunctionType >::ParamType >
    {
    public:
      typedef LocalDataInlinerTraits< DiscreteFunctionType > Traits;
      typedef typename Traits::ObjectStreamType ObjectStreamType;
 
      typedef typename Traits::DofManagerType   DofManagerType;
 
      typedef typename Traits::EntityType       EntityType;
      typedef typename Traits::GridEntityType   GridEntityType;
      typedef typename Traits::ParamType        ParamType;
 
      typedef LocalInterface<ParamType> LocalInterfaceType;
 
      typedef typename DiscreteFunctionTraits< DiscreteFunctionType >::DofType DofType;
      // we cannot use ConstLocalFunction here, since DiscreteFunctionType could
      // be the FemPy::DiscreteFunctionList which only takes dofs vectors
      typedef Dune::DynamicVector< DofType > LocalDofVectorType;
 
      LocalDataInliner ( const DiscreteFunctionType & df,
                         const ContainsCheck& containsCheck )
        : df_ (df),
          dm_( DofManagerType::instance( df.gridPart().grid() ) ),
          containsCheck_( containsCheck ),
          ldv_()
      {}
 
      LocalDataInliner ( const LocalDataInliner & other  )
        : df_ (other.df_),
          dm_( other.dm_ ),
          containsCheck_( other.containsCheck_ ),
          ldv_()
      {}
 
      void apply ( ParamType & p ) const
      {
        assert( p.first && p.second );
        const EntityType& entity = df_.space().gridPart().convert( *p.second );
        inlineData( *p.first, entity, *p.second );
      }
 
      typename DataCollectorTraits :: ReadWriteType
      readWriteInfo() const { return DataCollectorTraits :: writeData ; }
    protected:
      void inlineData ( ObjectStreamType& str,
                        const EntityType& entity,
                        const GridEntityType& gridEntity ) const
      {
        if( ! containsCheck_.contains ( entity ) ) return ;
 
        assert( df_.space().indexSet().contains( entity ) );
 
        ldv_.resize( df_.space().basisFunctionSet( entity ).size() );
        df_.getLocalDofs( entity, ldv_ );
        for( const DofType &dof : ldv_ )
          str.write( dof );
      }
 
    protected:
      const DiscreteFunctionType & df_;
      DofManagerType& dm_ ;
      const ContainsCheck containsCheck_;
      mutable LocalDofVectorType ldv_;
    };
 
 
    template< class DiscreteFunctionType >
    struct LocalDataXtractorTraits
    {
      typedef typename DiscreteFunctionType::DiscreteFunctionSpaceType
        DiscreteFunctionSpaceType;
      typedef typename DiscreteFunctionSpaceType::GridType        GridType;
      typedef typename DiscreteFunctionSpaceType::EntityType      EntityType;
      typedef typename GridType :: template Codim< 0 > :: Entity  GridEntityType;
 
      typedef DofManager < GridType > DofManagerType ;
      typedef typename DofManagerType :: XtractStreamType ObjectStreamType;
 
      typedef std::pair< ObjectStreamType *, const GridEntityType * > ParamType;
      typedef LocalInterface< ParamType > LocalInterfaceType;
    };
 
 
    template< class DiscreteFunctionType,
              class ContainsCheck >
    class LocalDataXtractor
    : public LocalInlinePlus< LocalDataXtractor< DiscreteFunctionType, ContainsCheck >,
                              typename LocalDataXtractorTraits< DiscreteFunctionType >::ParamType >
    {
    public:
      typedef LocalDataXtractorTraits< DiscreteFunctionType > Traits;
      typedef typename Traits::ObjectStreamType ObjectStreamType;
 
      typedef typename Traits::DofManagerType   DofManagerType;
 
      typedef typename Traits::EntityType       EntityType;
      typedef typename Traits::GridEntityType   GridEntityType;
      typedef typename Traits::ParamType        ParamType;
 
      typedef typename Traits::LocalInterfaceType LocalInterfaceType;
 
      typedef typename DiscreteFunctionTraits< DiscreteFunctionType >::DofType DofType;
      // we cannot use ConstLocalFunction here, since DiscreteFunctionType could
      // be the FemPy::DiscreteFunctionList which only takes dofs vectors
      typedef Dune::DynamicVector< DofType >  LocalDofVectorType;
 
      LocalDataXtractor ( DiscreteFunctionType & df,
                          const ContainsCheck& containsCheck )
        : df_ (df),
          dm_( DofManagerType :: instance( df.gridPart().grid() ) ),
          containsCheck_( containsCheck ),
          ldv_()
        {}
 
      LocalDataXtractor ( const LocalDataXtractor & other )
        : df_( other.df_ ),
          dm_( other.dm_ ),
          containsCheck_( other.containsCheck_ ),
          ldv_()
      {}
 
      void apply ( ParamType & p ) const
      {
        assert( p.first && p.second );
        const EntityType& entity = df_.space().gridPart().convert( *p.second );
        xtractData( *p.first, entity, *p.second );
      }
 
      typename DataCollectorTraits :: ReadWriteType
      readWriteInfo() const { return DataCollectorTraits :: readData ; }
    protected:
      void xtractData (ObjectStreamType & str,
                       const EntityType& entity,
                       const GridEntityType& gridEntity ) const
      {
        if( ! containsCheck_.contains ( entity ) ) return ;
 
        // make sure entity is contained in set
        assert( df_.space().indexSet().contains( entity ) );
 
        ldv_.resize( df_.space().basisFunctionSet( entity ).size() );
        for( DofType &dof : ldv_ )
          str.read( dof );
        df_.setLocalDofs( entity, ldv_ );
      }
 
    protected:
      DiscreteFunctionType &df_;
      DofManagerType &dm_;
      const ContainsCheck containsCheck_;
      mutable LocalDofVectorType ldv_;
    };
 
  } // namespace Fem
 
} // namespace Dune
 
#endif // #ifndef DUNE_FEM_DATACOLLECTOR_HH