Write and read meshtags using ADIOS2

cpp/demo/checkpointing/CMakeLists.txt

@@ -0,0 +1,40 @@
+# This file was generated by running
+#
+# python cmake/scripts/generate-cmakefiles.py from dolfinx/cpp
+#
+cmake_minimum_required(VERSION 3.19)
+
+set(PROJECT_NAME demo_checkpointing)
+project(${PROJECT_NAME} LANGUAGES C CXX)
+
+# Set C++20 standard
+set(CMAKE_CXX_STANDARD 20)
+set(CMAKE_CXX_STANDARD_REQUIRED ON)
+set(CMAKE_CXX_EXTENSIONS OFF)
+
+if(NOT TARGET dolfinx)
+  find_package(DOLFINX REQUIRED)
+endif()
+
+set(CMAKE_INCLUDE_CURRENT_DIR ON)
+
+add_executable(${PROJECT_NAME} main.cpp)
+target_link_libraries(${PROJECT_NAME} dolfinx)
+
+# Do not throw error for 'multi-line comments' (these are typical in rst which
+# includes LaTeX)
+include(CheckCXXCompilerFlag)
+check_cxx_compiler_flag("-Wno-comment" HAVE_NO_MULTLINE)
+set_source_files_properties(
+  main.cpp
+  PROPERTIES
+    COMPILE_FLAGS
+    "$<$<BOOL:${HAVE_NO_MULTLINE}>:-Wno-comment -Wall -Wextra -pedantic -Werror>"
+)
+
+# Test targets (used by DOLFINx testing system)
+set(TEST_PARAMETERS2 -np 2 ${MPIEXEC_PARAMS} "./${PROJECT_NAME}")
+set(TEST_PARAMETERS3 -np 3 ${MPIEXEC_PARAMS} "./${PROJECT_NAME}")
+add_test(NAME ${PROJECT_NAME}_mpi_2 COMMAND "mpirun" ${TEST_PARAMETERS2})
+add_test(NAME ${PROJECT_NAME}_mpi_3 COMMAND "mpirun" ${TEST_PARAMETERS3})
+add_test(NAME ${PROJECT_NAME}_serial COMMAND ${PROJECT_NAME})

cpp/demo/checkpointing/checkpointing.yml

@@ -0,0 +1,10 @@
+---
+# adios2 config.yaml
+# IO YAML Sequence (-) Nodes to allow for multiple IO nodes
+# IO name referred in code with DeclareIO is mandatory
+
+- IO: "mesh-write"
+
+  Engine:
+     # If Type is missing or commented out, default Engine is picked up
+     Type: "BP5"

cpp/demo/checkpointing/main.cpp

@@ -0,0 +1,250 @@
+// ```text
+// Copyright (C) 2024 Abdullah Mujahid, Jørgen S. Dokken, Jack S. Hale
+// This file is part of DOLFINx (https://www.fenicsproject.org)
+// SPDX-License-Identifier:    LGPL-3.0-or-later
+// ```
+
+// # Checkpointing
+//
+
+#include <adios2.h>
+#include <dolfinx.h>
+#include <dolfinx/common/version.h>
+#include <dolfinx/io/ADIOS2_utils.h>
+#include <dolfinx/io/checkpointing.h>
+#include <mpi.h>
+#include <typeinfo>
+#include <variant>
+
+using namespace dolfinx;
+using namespace dolfinx::io;
+
+// Create cell meshtags
+
+template <std::floating_point T>
+std::shared_ptr<mesh::MeshTags<std::int32_t>>
+create_meshtags(dolfinx::mesh::Mesh<T>& mesh)
+{
+  // Create cell meshtags
+  auto geometry = mesh.geometry();
+  auto topology = mesh.topology();
+
+  int dim = geometry.dim();
+  topology->create_entities(dim);
+  const std::shared_ptr<const dolfinx::common::IndexMap> topo_imap
+      = topology->index_map(dim);
+
+  std::int32_t num_entities = topo_imap->size_local();
+
+  auto cmap = geometry.cmap();
+  auto geom_layout = cmap.create_dof_layout();
+  std::uint32_t num_dofs_per_entity = geom_layout.num_entity_closure_dofs(dim);
+
+  std::vector<int32_t> entities_array(num_entities * num_dofs_per_entity);
+  std::vector<int32_t> entities_offsets(num_entities + 1);
+  std::uint64_t offset = topo_imap->local_range()[0];
+  std::vector<std::int32_t> values(num_entities);
+
+  for (std::int32_t i = 0; i < num_entities; ++i)
+  {
+    values[i] = i + offset;
+  }
+
+  auto entities = topology->connectivity(dim, 0);
+
+  for (int i = 0; i < (int)num_entities + 1; ++i)
+    entities_offsets[i] = entities->offsets()[i];
+
+  for (int i = 0; i < (int)(num_entities * num_dofs_per_entity); ++i)
+    entities_array[i] = entities->array()[i];
+
+  graph::AdjacencyList<std::int32_t> entities_local(entities_array,
+                                                    entities_offsets);
+
+  auto meshtags = std::make_shared<mesh::MeshTags<std::int32_t>>(
+      mesh::create_meshtags<std::int32_t>(topology, dim, entities_local,
+                                          values));
+
+  return meshtags;
+}
+
+int main(int argc, char* argv[])
+{
+  dolfinx::init_logging(argc, argv);
+  MPI_Init(&argc, &argv);
+
+  // Create mesh and function space
+  auto part = mesh::create_cell_partitioner(mesh::GhostMode::shared_facet);
+  auto mesh = std::make_shared<mesh::Mesh<float>>(mesh::create_rectangle<float>(
+      MPI_COMM_WORLD, {{{0.0, 0.0}, {1.0, 1.0}}}, {4, 4},
+      mesh::CellType::quadrilateral, part));
+
+  auto meshtags = create_meshtags<float>(*mesh);
+
+  try
+  {
+    // Set up ADIOS2 for writing
+    adios2::ADIOS adios(mesh->comm());
+
+    {
+      adios2::IO io = adios.DeclareIO("mesh-write");
+      io.SetEngine("BP5");
+      adios2::Engine engine = io.Open("mesh.bp", adios2::Mode::Append);
+      io::native::write_mesh(io, engine, *mesh);
+      engine.Close();
+    }
+
+    {
+      adios2::IO io = adios.DeclareIO("meshtags-write");
+      io.SetEngine("BP5");
+      adios2::Engine engine = io.Open("meshtags.bp", adios2::Mode::Append);
+
+      io::native::write_meshtags<float, std::int32_t>(io, engine, *mesh,
+                                                      *meshtags);
+      engine.Close();
+    }
+
+    // time dependent write
+    {
+      adios2::IO io = adios.DeclareIO("mesh-time-write");
+      io.SetEngine("BP5");
+      adios2::Engine engine = io.Open("mesh-time.bp", adios2::Mode::Append);
+
+      io::native::write_mesh(io, engine, *mesh);
+      std::span<float> x = mesh->geometry().x();
+      std::ranges::transform(x, x.begin(), [](auto xi) { return xi *= 4; });
+
+      io::native::write_mesh(io, engine, *mesh, 0.5);
+
+      engine.Close();
+    }
+  }
+  catch (std::exception& e)
+  {
+    std::cout << "ERROR: ADIOS2 exception: " << e.what() << "\n";
+    MPI_Abort(MPI_COMM_WORLD, -1);
+  }
+
+  try
+  {
+    // Set up ADIOS2 for reading
+    adios2::ADIOS adios(MPI_COMM_WORLD);
+
+    {
+      // Read mesh
+      adios2::IO io = adios.DeclareIO("mesh-read");
+      io.SetEngine("BP5");
+      adios2::Engine engine = io.Open("mesh.bp", adios2::Mode::Read);
+
+      engine.BeginStep();
+      auto mesh_read = io::native::read_mesh<float>(io, engine, MPI_COMM_WORLD);
+
+      engine.Close();
+
+      // Read meshtags
+      adios2::IO io_mt = adios.DeclareIO("meshtags-read");
+      io_mt.SetEngine("BP5");
+      adios2::Engine engine_mt = io_mt.Open("meshtags.bp", adios2::Mode::Read);
+
+      mesh::MeshTags<std::int32_t> mt
+          = io::native::read_meshtags<float, std::int32_t>(
+              io_mt, engine_mt, mesh_read, "mesh_tags");
+
+      engine_mt.Close();
+
+      {
+        adios2::IO io_write = adios.DeclareIO("mesh-write");
+        io_write.SetEngine("BP5");
+        adios2::Engine engine_write
+            = io_write.Open("mesh2.bp", adios2::Mode::Write);
+
+        io::native::write_mesh(io_write, engine_write, mesh_read);
+        engine_write.Close();
+      }
+      {
+        adios2::IO io_write = adios.DeclareIO("meshtags-write");
+        io_write.SetEngine("BP5");
+        adios2::Engine engine_write
+            = io_write.Open("meshtags2.bp", adios2::Mode::Write);
+
+        io::native::write_meshtags<float, std::int32_t>(io_write, engine_write,
+                                                        mesh_read, mt);
+        engine_write.Close();
+      }
+    }
+
+    // ReadRandomAccess mode
+    adios2::IO io_rra = adios.DeclareIO("mesh-rra");
+    io_rra.SetEngine("BP5");
+    adios2::Engine engine_rra
+        = io_rra.Open("mesh-time.bp", adios2::Mode::ReadRandomAccess);
+
+    // Find the time stamps array
+    auto var_time = io_rra.InquireVariable<double>("time");
+    const std::vector<std::vector<adios2::Variable<double>::Info>> timestepsinfo
+        = var_time.AllStepsBlocksInfo();
+
+    std::size_t num_steps = timestepsinfo.size();
+    std::vector<double> times(num_steps);
+
+    for (std::size_t step = 0; step < num_steps; ++step)
+    {
+      var_time.SetStepSelection({step, 1});
+      engine_rra.Get(var_time, times[step]);
+    }
+    engine_rra.Close();
+
+    // Read and rewrite time dependent mesh
+    adios2::IO io_read = adios.DeclareIO("mesh-time-read");
+    io_read.SetEngine("BP5");
+    adios2::Engine engine_read
+        = io_read.Open("mesh-time.bp", adios2::Mode::Read);
+
+    adios2::IO io_write = adios.DeclareIO("mesh-time-write");
+    io_write.SetEngine("BP5");
+    adios2::Engine engine_write
+        = io_write.Open("mesh-time2.bp", adios2::Mode::Write);
+
+    // Read mesh
+    engine_read.BeginStep();
+    auto mesh_read
+        = io::native::read_mesh<float>(io_read, engine_read, MPI_COMM_WORLD);
+    if (engine_read.BetweenStepPairs())
+    {
+      engine_read.EndStep();
+    }
+    // Write mesh
+    io::native::write_mesh(io_write, engine_write, mesh_read);
+
+    // Update mesh
+    double time = 0.5;
+    std::size_t querystep;
+    auto pos = std::ranges::find(times, time);
+    if (pos != times.end())
+    {
+      querystep = std::ranges::distance(times.begin(), pos);
+      std::cout << "Query step is : " << querystep << "\n";
+    }
+    else
+    {
+      throw std::runtime_error("Step corresponding to time : "
+                               + std::to_string(time) + " not found");
+    }
+
+    io::native::update_mesh<float>(io_read, engine_read, mesh_read, querystep);
+
+    // Write updated mesh
+    io::native::write_mesh(io_write, engine_write, mesh_read, time);
+
+    engine_read.Close();
+    engine_write.Close();
+  }
+  catch (std::exception& e)
+  {
+    std::cout << "ERROR: ADIOS2 exception: " << e.what() << "\n";
+    MPI_Abort(MPI_COMM_WORLD, -1);
+  }
+
+  MPI_Finalize();
+  return 0;
+}

cpp/doc/source/demo.rst

@@ -42,3 +42,4 @@ Experimental
    :maxdepth: 1
 
    demos/demo_mixed_topology.md
+   demos/demo_checkpointing.md