copy_attachment_handler.h

Go to the documentation of this file.

/*
 * Copyright (c) 2015:  G-CSC, Goethe University Frankfurt
 * Author: Markus Breit
 * 
 * This file is part of UG4.
 * 
 * UG4 is free software: you can redistribute it and/or modify it under the
 * terms of the GNU Lesser General Public License version 3 (as published by the
 * Free Software Foundation) with the following additional attribution
 * requirements (according to LGPL/GPL v3 §7):
 * 
 * (1) The following notice must be displayed in the Appropriate Legal Notices
 * of covered and combined works: "Based on UG4 (www.ug4.org/license)".
 * 
 * (2) The following notice must be displayed at a prominent place in the
 * terminal output of covered works: "Based on UG4 (www.ug4.org/license)".
 * 
 * (3) The following bibliography is recommended for citation and must be
 * preserved in all covered files:
 * "Reiter, S., Vogel, A., Heppner, I., Rupp, M., and Wittum, G. A massively
 *   parallel geometric multigrid solver on hierarchically distributed grids.
 *   Computing and visualization in science 16, 4 (2013), 151-164"
 * "Vogel, A., Reiter, S., Rupp, M., Nägel, A., and Wittum, G. UG4 -- a novel
 *   flexible software system for simulating pde based models on high performance
 *   computers. Computing and visualization in science 16, 4 (2013), 165-179"
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU Lesser General Public License for more details.
 */
 
#ifndef LIB_GRID__COPY_ATTACHMENT_HANDLER_H_
#define LIB_GRID__COPY_ATTACHMENT_HANDLER_H_
 
#include "common/util/smart_pointer.h"  // for SmartPtr
#include "lib_grid/grid/grid_observer.h"  // for GridObserver
#include "lib_grid/multi_grid.h"  // for MultiGrid
 
#ifdef UG_PARALLEL
    #include "lib_grid/parallelization/util/compol_copy_attachment.h" // ComPol_CopyAttachment
    #include "lib_grid/parallelization/distributed_grid.h"        // DistributedGridManager
#endif
 
namespace ug{
 
 
template <typename TElem, typename TAttachment>
class CopyAttachmentHandler : public GridObserver
{
  public:
    CopyAttachmentHandler()
    : m_bEnableVertComm(true) {}
    CopyAttachmentHandler() {…}
 
    virtual ~CopyAttachmentHandler()
    {
      if (m_spMG.valid())
        m_spMG->unregister_observer(this);
 
      m_aa.invalidate();
    };
    virtual ~CopyAttachmentHandler() {…}
 
    void set_attachment(const TAttachment& attch)
    {
      m_a = attch;
 
      // if we already have a grid, then this must be a reset
      if (m_spMG.valid())
      {
        m_aa.invalidate();
        m_aa.access(*m_spMG, m_a);
      }
    }
    void set_attachment(const TAttachment& attch) {…}
 
    void set_grid(SmartPtr<MultiGrid> mg)
    {
      // do nothing if given grid is already set
      if (m_spMG == mg) return;
 
      // if another grid is already given, unregister from old grid and invalidate accessor
      if (m_spMG.valid())
      {
        m_spMG->unregister_observer(this);
        m_aa.invalidate();
      }
 
      // set new grid
      m_spMG = mg;
      UG_COND_THROW(!m_spMG.valid(), "No valid multigrid given!");
 
      // register as appropriate observer
      register_as_observer<TElem, void>(m_spMG, this);
 
      // check that attachment is attached to grid
      UG_COND_THROW(!m_spMG->has_attachment<TElem>(m_a),
              "Given grid does not have given attachment attached to it.");
 
      // init accessor
      m_aa.access(*m_spMG, m_a);
 
      // copy to all levels that are already present
      propagate_to_levels();
    }
    void set_grid(SmartPtr<MultiGrid> mg) {…}
 
    void enable_vertical_communication(bool b)
    {
      m_bEnableVertComm = b;
    }
    void enable_vertical_communication(bool b) {…}
 
 
    // GridObserver implementations
    virtual void vertex_created
    (
      Grid* grid,
      Vertex* vrt,
      GridObject* pParent = NULL,
      bool replacesParent = false
    )
    {
      propagate<Vertex, void>(vrt, pParent, this);
    }
    virtual void vertex_created {…}
 
    virtual void edge_created
    (
      Grid* grid,
      Edge* e,
      GridObject* pParent = NULL,
      bool replacesParent = false
    )
    {
      propagate<Edge, void>(e, pParent, this);
    }
    virtual void edge_created {…}
 
    virtual void face_created
    (
      Grid* grid,
      Face* f,
      GridObject* pParent = NULL,
      bool replacesParent = false
    )
    {
      propagate<Face, void>(f, pParent, this);
    }
    virtual void face_created {…}
 
    virtual void volume_created
    (
      Grid* grid,
      Volume* vol,
      GridObject* pParent = NULL,
      bool replacesParent = false
    )
    {
      propagate<Volume, void>(vol, pParent, this);
    }
 
  protected:
 
    // this template will be used if created is called with anything BUT TElem (in that case: do nothing)
    template <typename TCreatedElem, typename Dummy>
    struct propagate
    {
      propagate(TCreatedElem* elem, GridObject* pParent, CopyAttachmentHandler<TElem, TAttachment>* cah) {};
    };
    struct propagate {…};
 
    // this template will be used if created is called with an elem of type TElem
    template <typename Dummy>
    struct propagate<TElem, Dummy>
    {
      propagate(TElem* elem, GridObject* pParent, CopyAttachmentHandler<TElem, TAttachment>* cah)
      {
        // check that parent is given
        if (!pParent) return;
 
        // if parent is of different elem type than child
        TElem* par = dynamic_cast<TElem*>(pParent);
        if (!par)
        {
          cah->copy_from_other_elem_type(pParent, elem);
          return;
        }
 
        // copy attachment value from parent to child
        cah->copy(par, elem);
      }
      propagate(TElem* elem, GridObject* pParent, CopyAttachmentHandler<TElem, TAttachment>* cah) {…}
    };
    struct propagate<TElem, Dummy> {…};
 
    friend struct propagate<TElem, void>;
 
    template <typename TObserverElem, typename Dummy>
    struct register_as_observer
    {
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<TObserverElem, TAttachment>* cah) {};
    };
    struct register_as_observer {…};
 
    template <typename Dummy>
    struct register_as_observer<Vertex, Dummy>
    {
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Vertex, TAttachment>* cah)
      {
        mg->register_observer(cah, OT_VERTEX_OBSERVER);
      }
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Vertex, TAttachment>* cah) {…}
    };
    struct register_as_observer<Vertex, Dummy> {…};
    template <typename Dummy>
    struct register_as_observer<Edge, Dummy>
    {
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Edge, TAttachment>* cah)
      {
        mg->register_observer(cah, OT_EDGE_OBSERVER);
      }
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Edge, TAttachment>* cah) {…}
    };
    struct register_as_observer<Edge, Dummy> {…};
    template <typename Dummy>
    struct register_as_observer<Face, Dummy>
    {
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Face, TAttachment>* cah)
      {
        mg->register_observer(this, OT_FACE_OBSERVER);
      }
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Face, TAttachment>* cah) {…}
    };
    struct register_as_observer<Face, Dummy> {…};
    template <typename Dummy>
    struct register_as_observer<Volume, Dummy>
    {
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Volume, TAttachment>* cah)
      {
        mg->register_observer(this, OT_VOLUME_OBSERVER);
      }
      register_as_observer(SmartPtr<MultiGrid> mg, CopyAttachmentHandler<Volume, TAttachment>* cah) {…}
    };
    struct register_as_observer<Volume, Dummy> {…};
 
 
    void propagate_to_levels()
    {
      // ensure a final vertical communication on the top level
      const size_t nProp = m_bEnableVertComm ? m_spMG->num_levels() + 1 : m_spMG->num_levels();
      for (size_t i = 1; i < nProp; ++i)
        propagate_to_level(i, m_bEnableVertComm);
    }
    void propagate_to_levels() {…}
 
    void propagate_to_level(size_t lvl, bool vertComm = true)
    {
#ifdef UG_PARALLEL
      // copy from vMasters to vSlaves
      if (pcl::NumProcs() > 1 && vertComm)
      {
        typedef typename GridLayoutMap::Types<TElem>::Layout layout_type;
        DistributedGridManager& dgm = *m_spMG->distributed_grid_manager();
        GridLayoutMap& glm = dgm.grid_layout_map();
        pcl::InterfaceCommunicator<layout_type> icom;
 
        ComPol_CopyAttachment<layout_type, TAttachment> compolCopy(*m_spMG, m_a);
        icom.exchange_data(glm, INT_V_MASTER, INT_V_SLAVE, compolCopy);
        icom.communicate();
      }
#endif
      // iterate over all TElems of level
      typedef typename geometry_traits<TElem>::const_iterator iter_type;
      iter_type iter = m_spMG->begin<TElem>(lvl);
      iter_type iter_end = m_spMG->end<TElem>(lvl);
      for (; iter != iter_end; ++iter)
      {
        TElem* child = *iter;
        GridObject* parent = m_spMG->get_parent(*iter);
 
        propagate<TElem, void>(child, parent, this);
      }
    }
    void propagate_to_level(size_t lvl, bool vertComm = true) {…}
 
    virtual void copy(TElem* parent, TElem* child)
    {
      m_aa[child] = m_aa[parent];
    }
    virtual void copy(TElem* parent, TElem* child) {…}
 
    virtual void copy_from_other_elem_type(GridObject* parent, TElem* child) {};
 
  protected:
    SmartPtr<MultiGrid> m_spMG;
 
    bool m_bEnableVertComm;
 
    TAttachment m_a;
 
    Grid::AttachmentAccessor<TElem, TAttachment> m_aa;
 
};
class CopyAttachmentHandler : public GridObserver {…};
 
} // end namespace ug
 
#endif // LIB_GRID__COPY_ATTACHMENT_HANDLER_H__