Line data    Source code

       1            0 : // Distributed under the MIT License.
       2              : // See LICENSE.txt for details.
       3              : 
       4              : #pragma once
       5              : 
       6              : #include <deque>
       7              : #include <memory>
       8              : #include <utility>
       9              : 
      10              : #include "Domain/Structure/ElementId.hpp"
      11              : #include "Parallel/Callback.hpp"
      12              : #include "Parallel/GlobalCache.hpp"
      13              : #include "Parallel/Info.hpp"
      14              : #include "Parallel/Phase.hpp"
      15              : #include "ParallelAlgorithms/Amr/Actions/CollectDataFromChildren.hpp"
      16              : #include "Utilities/ErrorHandling/Error.hpp"
      17              : 
      18              : /// \cond
      19              : namespace db {
      20              : template <typename>
      21              : class DataBox;
      22              : }  // namespace db
      23              : /// \endcond
      24              : 
      25              : namespace amr::Actions {
      26              : /// \brief Creates a new element in an ArrayAlgorithm whose id is `parent_id`
      27              : ///
      28              : /// \details This action is meant to be initially invoked by
      29              : /// amr::Actions::AdjustDomain on the amr::Component.  This action inserts a
      30              : /// new element with id `parent_id` in the array referenced by
      31              : /// `element_proxy`.  A Parallel::SimpleActionCallback `callback` is passed to
      32              : /// the constructor of the new DistributedObject, which will invoke
      33              : /// amr::Actions::CollectDataFromChildren on the element with id `child_id`.
      34              : ///
      35              : /// This action does not modify anything in the DataBox
      36            1 : struct CreateParent {
      37              :   template <typename ParallelComponent, typename DbTagList,
      38              :             typename Metavariables, typename ElementProxy>
      39            0 :   static void apply(
      40              :       db::DataBox<DbTagList>& /*box*/,
      41              :       Parallel::GlobalCache<Metavariables>& cache, const int /*array_index*/,
      42              :       ElementProxy element_proxy,
      43              :       ElementId<Metavariables::volume_dim> parent_id,
      44              :       const ElementId<Metavariables::volume_dim>& child_id,
      45              :       std::deque<ElementId<Metavariables::volume_dim>> sibling_ids_to_collect,
      46              :       const std::unordered_map<Parallel::Phase, size_t> child_phase_bookmarks) {
      47              :     if (CHARM_VERSION_MAJOR < 8 and
      48              :         Parallel::number_of_procs<size_t>(cache) > 1) {
      49              :       ERROR_NO_TRACE(
      50              :           "Dynamically creating elements in parallel executables is broken "
      51              :           "until charm 8.");
      52              :     }
      53              :     auto child_proxy = element_proxy[child_id];
      54              :     element_proxy[parent_id].insert(
      55              :         cache.get_this_proxy(), Parallel::Phase::AdjustDomain,
      56              :         child_phase_bookmarks,
      57              :         std::make_unique<Parallel::SimpleActionCallback<
      58              :             CollectDataFromChildren, decltype(child_proxy),
      59              :             ElementId<Metavariables::volume_dim>,
      60              :             std::deque<ElementId<Metavariables::volume_dim>>>>(
      61              :             child_proxy, std::move(parent_id),
      62              :             std::move(sibling_ids_to_collect)));
      63              :   }
      64              : };
      65              : }  // namespace amr::Actions