Line data    Source code

       1            0 : // Distributed under the MIT License.
       2              : // See LICENSE.txt for details.
       3              : 
       4              : #pragma once
       5              : 
       6              : #include <cstddef>
       7              : 
       8              : #include "DataStructures/DataBox/DataBox.hpp"
       9              : #include "DataStructures/TaggedTuple.hpp"
      10              : #include "Domain/Structure/ElementId.hpp"
      11              : #include "Parallel/AlgorithmExecution.hpp"
      12              : #include "Parallel/ArrayCollection/ReceiveDataForElement.hpp"
      13              : #include "Parallel/ArrayCollection/Tags/ElementCollection.hpp"
      14              : #include "Parallel/GlobalCache.hpp"
      15              : 
      16              : namespace Parallel::Actions {
      17              : /// \brief Starts the next phase on the nodegroup and calls
      18              : /// `ReceiveDataForElement` for each element on the node.
      19            1 : struct StartPhaseOnNodegroup {
      20              :   template <typename DbTagsList, typename... InboxTags, typename ArrayIndex,
      21              :             typename ActionList, typename ParallelComponent,
      22              :             typename Metavariables>
      23            0 :   static Parallel::iterable_action_return_t apply(
      24              :       db::DataBox<DbTagsList>& box,
      25              :       const tuples::TaggedTuple<InboxTags...>& /*inboxes*/,
      26              :       Parallel::GlobalCache<Metavariables>& cache,
      27              :       const ArrayIndex& /*array_index*/, const ActionList /*meta*/,
      28              :       const ParallelComponent* const /*meta*/) {
      29              :     const size_t my_node = Parallel::my_node<size_t>(cache);
      30              :     auto proxy_to_this_node =
      31              :         Parallel::get_parallel_component<ParallelComponent>(cache)[my_node];
      32              :     for (const auto& [element_id, element] :
      33              :          db::get<typename ParallelComponent::element_collection_tag>(box)) {
      34              :       Parallel::threaded_action<ReceiveDataForElement<true>>(proxy_to_this_node,
      35              :                                                              element_id);
      36              :     }
      37              :     return {Parallel::AlgorithmExecution::Halt, std::nullopt};
      38              :   }
      39              : };
      40              : }  // namespace Parallel::Actions