Line data    Source code

       1           0 : // Distributed under the MIT License.
       2             : // See LICENSE.txt for details.
       3             : 
       4             : #pragma once
       5             : 
       6             : #include "DataStructures/DataBox/DataBox.hpp"
       7             : #include "Domain/Structure/ElementId.hpp"
       8             : #include "Parallel/AlgorithmExecution.hpp"
       9             : #include "Parallel/ArrayCollection/ReceiveDataForElement.hpp"
      10             : #include "Parallel/ArrayCollection/Tags/ElementCollection.hpp"
      11             : #include "Parallel/GlobalCache.hpp"
      12             : 
      13             : namespace Parallel::Actions {
      14             : /*!
      15             :  * \brief Reduction target that is called after all nodes have successfully
      16             :  * initialized the nodegroup portion of the `DgElementCollection`. This spawns
      17             :  * the messages that initialize the `DgElementArrayMember`s
      18             :  */
      19           1 : struct SpawnInitializeElementsInCollection {
      20             :   template <typename ParallelComponent, typename DbTagsList,
      21             :             typename Metavariables, typename ArrayIndex,
      22             :             typename DataBox = db::DataBox<DbTagsList>>
      23           0 :   static void apply(db::DataBox<DbTagsList>& box,
      24             :                     Parallel::GlobalCache<Metavariables>& cache,
      25             :                     const ArrayIndex& /*array_index*/,
      26             :                     const double /*unused_but_we_needed_to_reduce_something*/) {
      27             :     auto my_proxy = Parallel::get_parallel_component<ParallelComponent>(
      28             :         cache)[Parallel::my_node<size_t>(cache)];
      29             :     db::mutate<typename ParallelComponent::element_collection_tag>(
      30             :         [&my_proxy](const auto element_collection_ptr) {
      31             :           for (auto& [element_id, element] : *element_collection_ptr) {
      32             :             Parallel::threaded_action<ReceiveDataForElement<true>>(my_proxy,
      33             :                                                                    element_id);
      34             :           }
      35             :         },
      36             :         make_not_null(&box));
      37             :   }
      38             : };
      39             : }  // namespace Parallel::Actions