From: grahambenharper Date: Tue, 28 Jan 2020 19:50:52 +0000 (-0700) Subject: Remove fully_distributed_tria_util files X-Git-Tag: v9.2.0-rc1~600^2 X-Git-Url: https://gitweb.dealii.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=d1cf14a81116a0bc41c38dbd6992a76fbc6c45ac;p=dealii.git Remove fully_distributed_tria_util files --- diff --git a/source/distributed/fully_distributed_tria_util.cc b/source/distributed/fully_distributed_tria_util.cc deleted file mode 100644 index 675cc73ae2..0000000000 --- a/source/distributed/fully_distributed_tria_util.cc +++ /dev/null @@ -1,676 +0,0 @@ -// --------------------------------------------------------------------- -// -// Copyright (C) 2019 by the deal.II authors -// -// This file is part of the deal.II library. -// -// The deal.II library is free software; you can use it, redistribute -// it, and/or modify it under the terms of the GNU Lesser General -// Public License as published by the Free Software Foundation; either -// version 2.1 of the License, or (at your option) any later version. -// The full text of the license can be found in the file LICENSE.md at -// the top level directory of deal.II. -// -// --------------------------------------------------------------------- - -#include -#include - -#include -#include -#include - -#include -#include - -#include - -DEAL_II_NAMESPACE_OPEN - -namespace parallel -{ - namespace fullydistributed - { - namespace Utilities - { - namespace - { - /** - * Set the user_flag of a cell and of all its parent cells. - */ - template - void - set_user_flag_reverse(TriaIterator> cell) - { - cell->set_user_flag(); - if (cell->level() != 0) - set_user_flag_reverse(cell->parent()); - } - - - /** - * Convert the binary representation of a CellId to coarse-cell id as - * if the finest level were the coarsest level ("level coarse-grid id"). - */ - template - types::coarse_cell_id - convert_cell_id_binary_type_to_level_coarse_cell_id( - const typename CellId::binary_type &binary_representation) - { - // exploiting the structure of CellId::binary_type - // see also the documentation of CellId - - // actual coarse-grid id - const unsigned int coarse_cell_id = binary_representation[0]; - const unsigned int n_child_indices = binary_representation[1] >> 2; - - const unsigned int children_per_value = - sizeof(CellId::binary_type::value_type) * 8 / dim; - unsigned int child_level = 0; - unsigned int binary_entry = 2; - - // path to the get to the cell - std::vector cell_indices; - while (child_level < n_child_indices) - { - Assert(binary_entry < binary_representation.size(), - ExcInternalError()); - - for (unsigned int j = 0; j < children_per_value; ++j) - { - unsigned int cell_index = - (((binary_representation[binary_entry] >> (j * dim))) & - (GeometryInfo::max_children_per_cell - 1)); - cell_indices.push_back(cell_index); - ++child_level; - if (child_level == n_child_indices) - break; - } - ++binary_entry; - } - - // compute new coarse-grid id: c_{i+1} = c_{i}*2^dim + q; - types::coarse_cell_id level_coarse_cell_id = coarse_cell_id; - for (auto i : cell_indices) - level_coarse_cell_id = - level_coarse_cell_id * GeometryInfo::max_children_per_cell + - i; - - return level_coarse_cell_id; - } - } // namespace - - - template - ConstructionData - create_construction_data_from_triangulation( - const dealii::Triangulation &tria, - const MPI_Comm comm, - const bool construct_multilevel_hierarchy, - const unsigned int my_rank_in) - { - if (auto tria_pdt = dynamic_cast< - const parallel::distributed::Triangulation *>( - &tria)) - AssertThrow(comm == tria_pdt->get_communicator(), - ExcMessage("MPI communicators do not match.")); - - // First, figure out for what rank we are supposed to build the - // ConstructionData object - unsigned int my_rank = my_rank_in; - AssertThrow(my_rank == numbers::invalid_unsigned_int || - my_rank < dealii::Utilities::MPI::n_mpi_processes(comm), - ExcMessage( - "Rank has to be smaller than available processes.")); - - if (auto tria_pdt = dynamic_cast< - const parallel::distributed::Triangulation *>( - &tria)) - { - AssertThrow( - my_rank == numbers::invalid_unsigned_int || - my_rank == dealii::Utilities::MPI::this_mpi_process(comm), - ExcMessage( - "If parallel::distributed::Triangulation as source triangulation, my_rank has to equal global rank.")); - - my_rank = dealii::Utilities::MPI::this_mpi_process(comm); - } - else if (auto tria_serial = - dynamic_cast *>( - &tria)) - { - if (my_rank == numbers::invalid_unsigned_int) - my_rank = dealii::Utilities::MPI::this_mpi_process(comm); - } - else - { - AssertThrow(false, - ExcMessage( - "This type of triangulation is not supported!")); - } - - ConstructionData construction_data; - - // store the communicator - construction_data.comm = comm; - - - std::map> - coinciding_vertex_groups; - std::map vertex_to_coinciding_vertex_group; - - GridTools::collect_coinciding_vertices( - tria, coinciding_vertex_groups, vertex_to_coinciding_vertex_group); - - // helper function, which collects all vertices belonging to a cell - // (also taking into account periodicity) - auto add_vertices_of_cell_to_vertices_owned_by_locally_owned_cells = - [coinciding_vertex_groups, vertex_to_coinciding_vertex_group]( - TriaIterator> &cell, - std::vector &vertices_owned_by_locally_owned_cells) { - // add local vertices - for (unsigned int v = 0; v < GeometryInfo::vertices_per_cell; - ++v) - { - vertices_owned_by_locally_owned_cells[cell->vertex_index(v)] = - true; - const auto coinciding_vertex_group = - vertex_to_coinciding_vertex_group.find(cell->vertex_index(v)); - if (coinciding_vertex_group != - vertex_to_coinciding_vertex_group.end()) - for (const auto &co_vertex : coinciding_vertex_groups.at( - coinciding_vertex_group->second)) - vertices_owned_by_locally_owned_cells[co_vertex] = true; - } - }; - - // check if multilevel hierarchy should be constructed - if (construct_multilevel_hierarchy == false) - { - AssertThrow( - tria.has_hanging_nodes() == false, - ExcMessage( - "Hanging nodes are only supported if multilevel hierarchy is constructed!")); - - construction_data.settings = - fullydistributed::Settings::default_setting; - - // 1) collect vertices of active locally owned cells - std::vector vertices_owned_by_locally_owned_cells( - tria.n_vertices()); - for (auto cell : tria.cell_iterators()) - if (cell->is_active() && cell->subdomain_id() == my_rank) - add_vertices_of_cell_to_vertices_owned_by_locally_owned_cells( - cell, vertices_owned_by_locally_owned_cells); - - // helper function to determine if cell is locally relevant - // (i.e. a cell which is connected to a vertex via a locally owned - // active cell) - auto is_locally_relevant = - [&](TriaIterator> &cell) { - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - if (vertices_owned_by_locally_owned_cells[cell->vertex_index( - v)]) - return true; - return false; - }; - - // 2) process all local and ghost cells: set up needed data - // structures and collect all locally relevant vertices - // for second sweep - std::map vertices_locally_relevant; - construction_data.cell_infos.resize(1); - - for (auto cell : tria.cell_iterators()) - if (cell->is_active() && is_locally_relevant(cell)) - { - // to be filled - CellData cell_info; - - // a) extract cell definition (with old numbering of - // vertices) - dealii::CellData cell_data; - cell_data.material_id = cell->material_id(); - cell_data.manifold_id = cell->manifold_id(); - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - cell_data.vertices[v] = cell->vertex_index(v); - construction_data.coarse_cells.push_back(cell_data); - - // b) save indices of each vertex of this cell - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - vertices_locally_relevant[cell->vertex_index(v)] = - numbers::invalid_unsigned_int; - - // c) save boundary_ids of each face of this cell - for (unsigned int f = 0; - f < GeometryInfo::faces_per_cell; - ++f) - { - types::boundary_id boundary_ind = - cell->face(f)->boundary_id(); - if (boundary_ind != numbers::internal_face_boundary_id) - cell_info.boundary_ids.emplace_back(f, boundary_ind); - } - - // d) compute a new coarse-cell id (by ignoring all parent - // level) - types::coarse_cell_id new_coarse_cell_id = - convert_cell_id_binary_type_to_level_coarse_cell_id( - cell->id().template to_binary()); - - // store the coarse cell id - cell_info.id = CellId(new_coarse_cell_id, 0, nullptr) - .template to_binary(); - - // save coarse_cell_index -> coarse_cell_id mapping - construction_data.coarse_cell_index_to_coarse_cell_id - .push_back(new_coarse_cell_id); - - // e) store manifold id of cell - cell_info.manifold_id = cell->manifold_id(); - - // ... of lines - if (dim >= 2) - for (unsigned int line = 0; - line < GeometryInfo::lines_per_cell; - ++line) - cell_info.manifold_line_ids[line] = - cell->line(line)->manifold_id(); - - // ... of quads - if (dim == 3) - for (unsigned int quad = 0; - quad < GeometryInfo::quads_per_cell; - ++quad) - cell_info.manifold_quad_ids[quad] = - cell->quad(quad)->manifold_id(); - - // f) store subdomain_id - cell_info.subdomain_id = cell->subdomain_id(); - - // g) store invalid level_subdomain_id (since multilevel - // hierarchy is not constructed) - cell_info.level_subdomain_id = numbers::invalid_subdomain_id; - - construction_data.cell_infos[0].emplace_back(cell_info); - } - - // 3) enumerate locally relevant vertices - unsigned int vertex_counter = 0; - for (auto &vertex : vertices_locally_relevant) - { - construction_data.coarse_cell_vertices.push_back( - tria.get_vertices()[vertex.first]); - vertex.second = vertex_counter++; - } - - // 4) correct vertices of cells (make them local) - for (auto &cell : construction_data.coarse_cells) - for (unsigned int v = 0; v < GeometryInfo::vertices_per_cell; - ++v) - cell.vertices[v] = vertices_locally_relevant[cell.vertices[v]]; - } - else - { - construction_data.settings = - fullydistributed::Settings::construct_multigrid_hierarchy; - - // 1) collect locally relevant cells (set user_flag) - std::vector old_user_flags; - tria.save_user_flags(old_user_flags); - - // 1a) clear user_flags - const_cast &>(tria) - .clear_user_flags(); - - // 1b) loop over levels (from fine to coarse) and mark on each level - // the locally relevant cells - for (unsigned int level = - tria.get_triangulation().n_global_levels() - 1; - level != numbers::invalid_unsigned_int; - level--) - { - // collect vertices connected to a (on any level) locally owned - // cell - std::vector - vertices_owned_by_locally_owned_cells_on_level( - tria.n_vertices()); - for (auto cell : tria.cell_iterators_on_level(level)) - if (cell->level_subdomain_id() == my_rank || - (cell->is_active() && cell->subdomain_id() == my_rank)) - add_vertices_of_cell_to_vertices_owned_by_locally_owned_cells( - cell, vertices_owned_by_locally_owned_cells_on_level); - - for (auto cell : tria.active_cell_iterators()) - if (cell->subdomain_id() == my_rank) - add_vertices_of_cell_to_vertices_owned_by_locally_owned_cells( - cell, vertices_owned_by_locally_owned_cells_on_level); - - // helper function to determine if cell is locally relevant - // (i.e. a cell which is connected to a vertex via a locally - // owned cell) - auto is_locally_relevant_on_level = - [&](TriaIterator> &cell) { - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - if (vertices_owned_by_locally_owned_cells_on_level - [cell->vertex_index(v)]) - return true; - return false; - }; - - // mark all locally relevant cells - for (auto cell : tria.cell_iterators_on_level(level)) - if (is_locally_relevant_on_level(cell)) - set_user_flag_reverse(cell); - } - - // 2) set_up coarse-grid triangulation - { - std::map vertices_locally_relevant; - - // a) loop over all cells - for (auto cell : tria.cell_iterators_on_level(0)) - { - if (!cell->user_flag_set()) - continue; - - // extract cell definition (with old numbering of vertices) - dealii::CellData cell_data; - cell_data.material_id = cell->material_id(); - cell_data.manifold_id = cell->manifold_id(); - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - cell_data.vertices[v] = cell->vertex_index(v); - construction_data.coarse_cells.push_back(cell_data); - - // save indices of each vertex of this cell - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - vertices_locally_relevant[cell->vertex_index(v)] = - numbers::invalid_unsigned_int; - - // save translation for corase grid: lid -> gid - construction_data.coarse_cell_index_to_coarse_cell_id - .push_back(cell->id().get_coarse_cell_id()); - } - - // b) enumerate locally relevant vertices - unsigned int vertex_counter = 0; - for (auto &vertex : vertices_locally_relevant) - { - construction_data.coarse_cell_vertices.push_back( - tria.get_vertices()[vertex.first]); - vertex.second = vertex_counter++; - } - - // c) correct vertices of cells (make them local) - for (auto &cell : construction_data.coarse_cells) - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - cell.vertices[v] = - vertices_locally_relevant[cell.vertices[v]]; - } - - - // 3) collect info of each cell - construction_data.cell_infos.resize( - tria.get_triangulation().n_global_levels()); - - // collect local vertices on active level - std::vector vertices_owned_by_locally_owned_active_cells( - tria.n_vertices()); - for (auto cell : tria.active_cell_iterators()) - if (cell->subdomain_id() == my_rank) - add_vertices_of_cell_to_vertices_owned_by_locally_owned_cells( - cell, vertices_owned_by_locally_owned_active_cells); - - // helper function to determine if cell is locally relevant - // on active level - auto is_locally_relevant_on_active_level = - [&](TriaIterator> &cell) { - if (cell->is_active()) - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - if (vertices_owned_by_locally_owned_active_cells - [cell->vertex_index(v)]) - return true; - return false; - }; - - for (unsigned int level = 0; - level < tria.get_triangulation().n_global_levels(); - ++level) - { - // collect local vertices on level - std::vector - vertices_owned_by_locally_owned_cells_on_level( - tria.n_vertices()); - for (auto cell : tria.cell_iterators_on_level(level)) - if (cell->level_subdomain_id() == my_rank || - (cell->is_active() && cell->subdomain_id() == my_rank)) - add_vertices_of_cell_to_vertices_owned_by_locally_owned_cells( - cell, vertices_owned_by_locally_owned_cells_on_level); - - // helper function to determine if cell is locally relevant - // on level - auto is_locally_relevant_on_level = - [&](TriaIterator> &cell) { - for (unsigned int v = 0; - v < GeometryInfo::vertices_per_cell; - ++v) - if (vertices_owned_by_locally_owned_cells_on_level - [cell->vertex_index(v)]) - return true; - return false; - }; - - auto &level_cell_infos = construction_data.cell_infos[level]; - for (auto cell : tria.cell_iterators_on_level(level)) - { - // check if cell is locally relevant - if (!(cell->user_flag_set())) - continue; - - CellData cell_info; - - // save coarse-cell id - cell_info.id = cell->id().template to_binary(); - - // save boundary_ids of each face of this cell - for (unsigned int f = 0; - f < GeometryInfo::faces_per_cell; - ++f) - { - types::boundary_id boundary_ind = - cell->face(f)->boundary_id(); - if (boundary_ind != numbers::internal_face_boundary_id) - cell_info.boundary_ids.emplace_back(f, boundary_ind); - } - - // save manifold id - { - // ... of cell - cell_info.manifold_id = cell->manifold_id(); - - // ... of lines - if (dim >= 2) - for (unsigned int line = 0; - line < GeometryInfo::lines_per_cell; - ++line) - cell_info.manifold_line_ids[line] = - cell->line(line)->manifold_id(); - - // ... of quads - if (dim == 3) - for (unsigned int quad = 0; - quad < GeometryInfo::quads_per_cell; - ++quad) - cell_info.manifold_quad_ids[quad] = - cell->quad(quad)->manifold_id(); - } - - // subdomain and level subdomain id - cell_info.subdomain_id = numbers::artificial_subdomain_id; - cell_info.level_subdomain_id = - numbers::artificial_subdomain_id; - - if (is_locally_relevant_on_active_level(cell)) - { - cell_info.level_subdomain_id = - cell->level_subdomain_id(); - cell_info.subdomain_id = cell->subdomain_id(); - } - else if (is_locally_relevant_on_level(cell)) - { - cell_info.level_subdomain_id = - cell->level_subdomain_id(); - } - // else: cell is locally relevant but an artificial cell - - level_cell_infos.emplace_back(cell_info); - } - } - - const_cast &>(tria) - .load_user_flags(old_user_flags); - } - - return construction_data; - } - - - - template - ConstructionData - create_construction_data_from_triangulation_in_groups( - std::function &)> - serial_grid_generator, - std::function &, - const MPI_Comm, - const unsigned int)> serial_grid_partitioner, - const MPI_Comm comm, - const int group_size, - const bool construct_multilevel_hierarchy) - { -#ifndef DEAL_II_WITH_MPI - (void)serial_grid_generator; - (void)serial_grid_partitioner; - (void)comm; - (void)group_size; - (void)construct_multilevel_hierarchy; - - return ConstructionData(); -#else - const unsigned int my_rank = - dealii::Utilities::MPI::this_mpi_process(comm); - const unsigned int group_root = (my_rank / group_size) * group_size; - - const int mpi_tag = - dealii::Utilities::MPI::internal::Tags::fully_distributed_create; - - // check if process is root of the group - if (my_rank == group_root) - { - // Step 1: create serial triangulation - dealii::Triangulation tria( - construct_multilevel_hierarchy ? - dealii::Triangulation::none : - dealii::Triangulation:: - limit_level_difference_at_vertices); - serial_grid_generator(tria); - - // Step 2: partition active cells and ... - serial_grid_partitioner(tria, comm, group_size); - - // ... cells on the levels if multigrid is required - if (construct_multilevel_hierarchy) - GridTools::partition_multigrid_levels(tria); - - const unsigned int end_group = - std::min(group_root + group_size, - dealii::Utilities::MPI::n_mpi_processes(comm)); - - // 3) create ConstructionData for the other processes in group - for (unsigned int other_rank = group_root + 1; - other_rank < end_group; - other_rank++) - { - // 3a) create construction data for other ranks - const auto construction_data = - create_construction_data_from_triangulation( - tria, comm, construct_multilevel_hierarchy, other_rank); - // 3b) pack - std::vector buffer; - dealii::Utilities::pack(construction_data, buffer, false); - - // 3c) send ConstructionData - const auto ierr = MPI_Send(buffer.data(), - buffer.size(), - MPI_CHAR, - other_rank, - mpi_tag, - comm); - AssertThrowMPI(ierr); - } - - // 4) create ConstructionData for this process (root of group) - return create_construction_data_from_triangulation( - tria, comm, construct_multilevel_hierarchy, my_rank); - } - else - { - // 3a) recv packed ConstructionData from group-root process - // (counter-part of 3c of root process) - MPI_Status status; - auto ierr = MPI_Probe(group_root, mpi_tag, comm, &status); - AssertThrowMPI(ierr); - - int len; - MPI_Get_count(&status, MPI_CHAR, &len); - - std::vector buf(len); - ierr = MPI_Recv(buf.data(), - len, - MPI_CHAR, - status.MPI_SOURCE, - status.MPI_TAG, - comm, - &status); - AssertThrowMPI(ierr); - - // 3b) unpack ConstructionData (counter-part of 3b of root process) - auto construction_data = dealii::Utilities::template unpack< - ConstructionData>(buf, false); - - // WARNING: serialization cannot handle the MPI communicator - // which is the reason why we have to set it here explicitly - construction_data.comm = comm; - - return construction_data; - } -#endif - } - - } // namespace Utilities - } // namespace fullydistributed -} // namespace parallel - - - -/*-------------- Explicit Instantiations -------------------------------*/ -#include "fully_distributed_tria_util.inst" - - -DEAL_II_NAMESPACE_CLOSE diff --git a/source/distributed/fully_distributed_tria_util.inst.in b/source/distributed/fully_distributed_tria_util.inst.in deleted file mode 100644 index 6962da1d47..0000000000 --- a/source/distributed/fully_distributed_tria_util.inst.in +++ /dev/null @@ -1,51 +0,0 @@ -// --------------------------------------------------------------------- -// -// Copyright (C) 2010 - 2018 by the deal.II authors -// -// This file is part of the deal.II library. -// -// The deal.II library is free software; you can use it, redistribute -// it, and/or modify it under the terms of the GNU Lesser General -// Public License as published by the Free Software Foundation; either -// version 2.1 of the License, or (at your option) any later version. -// The full text of the license can be found in the file LICENSE.md at -// the top level directory of deal.II. -// -// --------------------------------------------------------------------- - - - -for (deal_II_dimension : DIMENSIONS; deal_II_space_dimension : DIMENSIONS) - { - namespace parallel - \{ - namespace fullydistributed - \{ - namespace Utilities - \{ -#if deal_II_dimension <= deal_II_space_dimension - template ConstructionData - create_construction_data_from_triangulation( - const dealii::Triangulation &tria, - const MPI_Comm comm, - const bool construct_multilevel_hierarchy, - const unsigned int my_rank_in); - - template ConstructionData - create_construction_data_from_triangulation_in_groups( - std::function - &)> serial_grid_generator, - std::function &, - const MPI_Comm, - const unsigned int)> serial_grid_partitioner, - const MPI_Comm comm, - const int group_size, - const bool construct_multilevel_hierarchy); -#endif - \} - \} - \} - }