time_loop.template.h

Go to the documentation of this file.

//
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
// Copyright (C) 2020 - 2024 by the ryujin authors
//
 
#pragma once
 
#include "scope.h"
#include "state_vector.h"
#include "time_loop.h"
#include "version_info.h"
 
#include <deal.II/base/logstream.h>
#include <deal.II/base/work_stream.h>
#include <deal.II/numerics/vector_tools.h>
#include <deal.II/numerics/vector_tools.templates.h>
 
#include <filesystem>
#include <fstream>
#include <iomanip>
 
using namespace dealii;
 
namespace ryujin
{
  template <typename Description, int dim, typename Number>
  TimeLoop<Description, dim, Number>::TimeLoop(const MPI_Comm &mpi_comm)
      : ParameterAcceptor("/A - TimeLoop")
      , mpi_ensemble_(mpi_comm)
      , hyperbolic_system_(mpi_ensemble_, "/B - Equation")
      , parabolic_system_(mpi_ensemble_, "/B - Equation")
      , discretization_(mpi_ensemble_, "/C - Discretization")
      , offline_data_(mpi_ensemble_, discretization_, "/D - OfflineData")
      , initial_values_(mpi_ensemble_,
                        "/E - InitialValues",
                        mpi_ensemble_,
                        offline_data_,
                        hyperbolic_system_,
                        parabolic_system_)
      , hyperbolic_module_(mpi_ensemble_,
                           computing_timer_,
                           offline_data_,
                           hyperbolic_system_,
                           initial_values_,
                           "/F - HyperbolicModule")
      , parabolic_module_(mpi_ensemble_,
                          computing_timer_,
                          offline_data_,
                          hyperbolic_system_,
                          parabolic_system_,
                          initial_values_,
                          "/G - ParabolicModule")
      , time_integrator_(mpi_ensemble_,
                         offline_data_,
                         hyperbolic_module_,
                         parabolic_module_,
                         "/H - TimeIntegrator")
      , mesh_adaptor_(mpi_ensemble_,
                      offline_data_,
                      hyperbolic_system_,
                      parabolic_system_,
                      hyperbolic_module_.initial_precomputed(),
                      hyperbolic_module_.alpha(),
                      "/I - MeshAdaptor")
      , solution_transfer_(
            mpi_ensemble_, offline_data_, hyperbolic_system_, parabolic_system_)
      , postprocessor_(mpi_ensemble_,
                       offline_data_,
                       hyperbolic_system_,
                       parabolic_system_,
                       "/J - VTUOutput")
      , vtu_output_(mpi_ensemble_,
                    offline_data_,
                    hyperbolic_system_,
                    parabolic_system_,
                    postprocessor_,
                    hyperbolic_module_.initial_precomputed(),
                    hyperbolic_module_.alpha(),
                    "/J - VTUOutput")
      , quantities_(mpi_ensemble_,
                    offline_data_,
                    hyperbolic_system_,
                    parabolic_system_,
                    "/K - Quantities")
  {
    base_name_ = "test";
    add_parameter("basename", base_name_, "Base name for all output files");
 
    t_final_ = Number(5.);
    add_parameter("final time", t_final_, "Final time");
 
    enforce_t_final_ = false;
    add_parameter("enforce final time",
                  enforce_t_final_,
                  "Boolean indicating whether the final time should be "
                  "enforced strictly. If set to true the last time step is "
                  "shortened so that the simulation ends precisely at t_final");
 
    timer_granularity_ = Number(0.01);
    add_parameter("timer granularity",
                  timer_granularity_,
                  "The timer granularity specifies the time interval after "
                  "which compute, output, postprocessing, and mesh adaptation "
                  "routines are run. This \"baseline tick\" is further "
                  "modified by the corresponding \"*_multiplier\" options");
 
    enable_checkpointing_ = false;
    add_parameter(
        "enable checkpointing",
        enable_checkpointing_,
        "Write out checkpoints to resume an interrupted computation at timer "
        "granularity intervals. The frequency is determined by \"timer "
        "granularity\" and \"timer checkpoint multiplier\"");
 
    enable_output_full_ = false;
    add_parameter("enable output full",
                  enable_output_full_,
                  "Write out full pvtu records. The frequency is determined by "
                  "\"timer granularity\" and \"timer output full multiplier\"");
 
    enable_output_levelsets_ = false;
    add_parameter(
        "enable output levelsets",
        enable_output_levelsets_,
        "Write out levelsets pvtu records. The frequency is determined by "
        "\"timer granularity\" and \"timer output levelsets multiplier\"");
 
    enable_compute_error_ = false;
    add_parameter("enable compute error",
                  enable_compute_error_,
                  "Flag to control whether we compute the Linfty Linf_norm of "
                  "the difference to an analytic solution. Implemented only "
                  "for certain initial state configurations.");
 
    enable_compute_quantities_ = false;
    add_parameter(
        "enable compute quantities",
        enable_compute_quantities_,
        "Flag to control whether we compute quantities of interest. The "
        "frequency how often quantities are logged is determined by \"timer "
        "granularity\" and \"timer compute quantities multiplier\"");
 
    enable_mesh_adaptivity_ = false;
    add_parameter(
        "enable mesh adaptivity",
        enable_mesh_adaptivity_,
        "Flag to control whether we use an adaptive mesh refinement strategy. "
        "The frequency how often we query MeshAdaptor::analyze() for deciding "
        "on adapting the mesh is determined by \"timer granularity\" and "
        "\"timer mesh refinement multiplier\"");
 
    timer_checkpoint_multiplier_ = 1;
    add_parameter("timer checkpoint multiplier",
                  timer_checkpoint_multiplier_,
                  "Multiplicative modifier applied to \"timer granularity\" "
                  "that determines the checkpointing granularity");
 
    timer_output_full_multiplier_ = 1;
    add_parameter("timer output full multiplier",
                  timer_output_full_multiplier_,
                  "Multiplicative modifier applied to \"timer granularity\" "
                  "that determines the full pvtu writeout granularity");
 
    timer_output_levelsets_multiplier_ = 1;
    add_parameter("timer output levelsets multiplier",
                  timer_output_levelsets_multiplier_,
                  "Multiplicative modifier applied to \"timer granularity\" "
                  "that determines the levelsets pvtu writeout granularity");
 
    timer_compute_quantities_multiplier_ = 1;
    add_parameter(
        "timer compute quantities multiplier",
        timer_compute_quantities_multiplier_,
        "Multiplicative modifier applied to \"timer granularity\" that "
        "determines the writeout granularity for quantities of interest");
 
    std::copy(std::begin(View::component_names),
              std::end(View::component_names),
              std::back_inserter(error_quantities_));
 
    add_parameter("error quantities",
                  error_quantities_,
                  "List of conserved quantities used in the computation of the "
                  "error norms.");
 
    error_normalize_ = true;
    add_parameter("error normalize",
                  error_normalize_,
                  "Flag to control whether the error should be normalized by "
                  "the corresponding norm of the analytic solution.");
 
    resume_ = false;
    add_parameter("resume", resume_, "Resume an interrupted computation");
 
    resume_at_time_zero_ = false;
    add_parameter("resume at time zero",
                  resume_at_time_zero_,
                  "Resume from the latest checkpoint but set the time to t=0.");
 
    terminal_update_interval_ = 5;
    add_parameter("terminal update interval",
                  terminal_update_interval_,
                  "Number of seconds after which output statistics are "
                  "recomputed and printed on the terminal");
 
    terminal_show_rank_throughput_ = true;
    add_parameter("terminal show rank throughput",
                  terminal_show_rank_throughput_,
                  "If set to true an average per rank throughput is computed "
                  "by dividing the total consumed CPU time (per rank) by the "
                  "number of threads (per rank). If set to false then a plain "
                  "average per thread \"CPU\" throughput value is computed by "
                  "using the umodified total accumulated CPU time.");
 
    debug_filename_ = "";
    add_parameter("debug filename",
                  debug_filename_,
                  "If set to a nonempty string then we output the contents of "
                  "this file at the end. This is mainly useful in the "
                  "testsuite to output files we wish to compare");
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::run()
  {
#ifdef DEBUG_OUTPUT
    std::cout << "TimeLoop<dim, Number>::run()" << std::endl;
#endif
 
    {
      base_name_ensemble_ = base_name_;
      if (mpi_ensemble_.n_ensembles() > 1) {
        print_info("setting up MPI ensemble");
        base_name_ensemble_ += "-ensemble_" + dealii::Utilities::int_to_string(
                                                  mpi_ensemble_.ensemble(),
                                                  mpi_ensemble_.n_ensembles());
      }
    }
 
    /* Attach log file and record runtime parameters: */
 
    if (mpi_ensemble_.world_rank() == 0)
      logfile_.open(base_name_ + ".log");
 
    print_parameters(logfile_);
 
    /*
     * Prepare data structures:
     */
 
    Number t = 0.;
    unsigned int timer_cycle = 0;
    StateVector state_vector;
 
    /* Create a small lambda for preparing compute kernels: */
    const auto prepare_compute_kernels = [&]() {
      print_info("preparing compute kernels");
 
      unsigned int n_parabolic_state_vectors =
          parabolic_system_.get().n_parabolic_state_vectors();
 
      offline_data_.prepare(
          problem_dimension, n_precomputed_values, n_parabolic_state_vectors);
 
      hyperbolic_module_.prepare();
      parabolic_module_.prepare();
      time_integrator_.prepare();
      mesh_adaptor_.prepare(/*needs current timepoint*/ t);
      postprocessor_.prepare();
      vtu_output_.prepare();
      quantities_.prepare(base_name_ensemble_);
      print_mpi_partition(logfile_);
 
      if (mpi_ensemble_.ensemble_rank() == 0)
        n_global_dofs_ = dealii::Utilities::MPI::sum(
            offline_data_.dof_handler().n_dofs(),
            mpi_ensemble_.ensemble_leader_communicator());
    };
 
    {
      Scope scope(computing_timer_, "(re)initialize data structures");
      print_info("initializing data structures");
 
      if (resume_) {
        print_info("resume: reading mesh and loading state vector");
 
        read_checkpoint(state_vector,
                        base_name_ensemble_,
                        t,
                        timer_cycle,
                        prepare_compute_kernels);
 
        if (resume_at_time_zero_) {
          /* Reset the current time t and the output cycle count to zero: */
          t = 0.;
          timer_cycle = 0;
        }
 
      } else {
        print_info("creating mesh and interpolating initial values");
 
        discretization_.prepare(base_name_ensemble_);
 
        prepare_compute_kernels();
 
        Vectors::reinit_state_vector<Description>(state_vector, offline_data_);
        std::get<0>(state_vector) =
            initial_values_.get().interpolate_hyperbolic_vector();
      }
    }
 
    /*
     * In debug mode poison constrained degrees of freedom and precomputed
     * values:
     */
    Vectors::debug_poison_constrained_dofs<Description>(state_vector,
                                                        offline_data_);
    Vectors::debug_poison_precomputed_values<Description>(state_vector,
                                                          offline_data_);
 
    unsigned int cycle = 1;
    Number last_terminal_output = (terminal_update_interval_ == Number(0.)
                                       ? std::numeric_limits<Number>::max()
                                       : std::numeric_limits<Number>::lowest());
 
    /*
     * The honorable main loop:
     */
 
    print_info("entering main loop");
    computing_timer_["time loop"].start();
 
    constexpr Number relax =
        Number(1.) - Number(10.) * std::numeric_limits<Number>::epsilon();
 
    for (;; ++cycle) {
 
#ifdef DEBUG_OUTPUT
      std::cout << "\n\n###   cycle = " << cycle << "   ###\n\n" << std::endl;
#endif
 
      /* Accumulate quantities of interest: */
 
      if (enable_compute_quantities_) {
        Scope scope(computing_timer_,
                    "time step [X]   - accumulate quantities");
        quantities_.accumulate(state_vector, t);
      }
 
      /* Perform various tasks whenever we reach a timer tick: */
 
      if (t >= relax * timer_cycle * timer_granularity_) {
        if (enable_compute_error_) {
          StateVector analytic;
          {
            /*
             * FIXME: We interpolate the analytic solution at every timer
             * tick. If we happen to actually not output anything then this
             * is terribly inefficient...
             */
            Scope scope(computing_timer_,
                        "time step [X]   - interpolate analytic solution");
            Vectors::reinit_state_vector<Description>(analytic, offline_data_);
            std::get<0>(analytic) =
                initial_values_.get().interpolate_hyperbolic_vector(t);
          }
 
          /*
           * FIXME: a call to output() will also write a checkpoint (if
           * enabled). So as a workaround we simply call the output()
           * function for the analytic solution first...
           */
          output(analytic,
                 base_name_ensemble_ + "-analytic_solution",
                 t,
                 timer_cycle);
        }
 
        output(state_vector, base_name_ensemble_ + "-solution", t, timer_cycle);
 
        if (enable_compute_quantities_ &&
            (timer_cycle % timer_compute_quantities_multiplier_ == 0)) {
          Scope scope(computing_timer_,
                      "time step [X]   - write out quantities");
          quantities_.write_out(state_vector, t, timer_cycle);
        }
 
        ++timer_cycle;
      }
 
      /* Break if we have reached the final time. */
 
      if (t >= relax * t_final_)
        break;
 
      /* Peform a mesh adaptation cycle: */
 
      if (enable_mesh_adaptivity_) {
        {
          Scope scope(computing_timer_,
                      "time step [X]   - analyze for mesh adaptation");
 
          mesh_adaptor_.analyze(state_vector, t, cycle);
        }
 
        if (mesh_adaptor_.need_mesh_adaptation()) {
          Scope scope(computing_timer_, "(re)initialize data structures");
          print_info("performing mesh adaptation");
 
          hyperbolic_module_.prepare_state_vector(state_vector, t);
          adapt_mesh_and_transfer_state_vector(state_vector,
                                               prepare_compute_kernels);
        }
      }
 
      /* Perform a time step: */
 
      const auto tau = time_integrator_.step(
          state_vector,
          t,
          enforce_t_final_
              ? std::min(t_final_, timer_cycle * timer_granularity_)
              : std::numeric_limits<Number>::max());
 
      t += tau;
 
      /* Print and record cycle statistics: */
      if (terminal_update_interval_ != Number(0.)) {
 
        /* Do we need to update the log file? */
        const bool write_to_log_file =
            (t >= relax * timer_cycle * timer_granularity_);
 
        /* Do we need to update the terminal? */
        const auto wall_time = computing_timer_["time loop"].wall_time();
        int update_terminal =
            (wall_time >= last_terminal_output + terminal_update_interval_);
 
        /* Broadcast boolean from rank 0 to all other ranks: */
        const auto ierr = MPI_Bcast(&update_terminal,
                                    1,
                                    MPI_INT,
                                    0,
                                    mpi_ensemble_.world_communicator());
        AssertThrowMPI(ierr);
 
        if (write_to_log_file || update_terminal) {
          print_cycle_statistics(
              cycle, t, timer_cycle, /*logfile*/ write_to_log_file);
          last_terminal_output = wall_time;
        }
      }
    } /* end of loop */
 
    /* We have actually performed one cycle less. */
    --cycle;
 
    computing_timer_["time loop"].stop();
 
    if (terminal_update_interval_ != Number(0.)) {
      /* Write final timing statistics to screen and logfile: */
      print_cycle_statistics(
          cycle, t, timer_cycle, /*logfile*/ true, /*final*/ true);
    }
 
    if (enable_compute_error_) {
      /* Output final error: */
      compute_error(state_vector, t);
    }
 
    if (mpi_ensemble_.world_rank() == 0 && debug_filename_ != "") {
      std::ifstream f(debug_filename_);
      if (f.is_open())
        std::cout << f.rdbuf();
    }
 
#ifdef WITH_VALGRIND
    CALLGRIND_DUMP_STATS;
#endif
  }
 
 
  template <typename Description, int dim, typename Number>
  template <typename Callable>
  void TimeLoop<Description, dim, Number>::read_checkpoint(
      StateVector &state_vector,
      const std::string &base_name,
      Number &t,
      unsigned int &output_cycle,
      const Callable &prepare_compute_kernels)
  {
#ifdef DEBUG_OUTPUT
    std::cout << "TimeLoop<dim, Number>::read_checkpoint()" << std::endl;
#endif
 
    AssertThrow(have_distributed_triangulation<dim>,
                dealii::ExcMessage(
                    "read_checkpoint() is not implemented for "
                    "distributed::shared::Triangulation which we use in 1D"));
 
    /*
     * Initialize discretization, read in the mesh, and initialize everything:
     */
 
#if !DEAL_II_VERSION_GTE(9, 6, 0)
    if constexpr (have_distributed_triangulation<dim>) {
#endif
      discretization_.refinement() = 0; /* do not refine */
      discretization_.prepare(base_name);
      discretization_.triangulation().load(base_name + "-checkpoint.mesh");
#if !DEAL_II_VERSION_GTE(9, 6, 0)
    }
#endif
 
    prepare_compute_kernels();
 
    /*
     * Read in and broadcast metadata:
     */
 
    std::string name = base_name + "-checkpoint";
 
    unsigned int transfer_handle;
    if (mpi_ensemble_.ensemble_rank() == 0) {
      std::string meta = name + ".metadata";
 
      std::ifstream file(meta, std::ios::binary);
      boost::archive::binary_iarchive ia(file);
      ia >> t >> output_cycle >> transfer_handle;
    }
 
    int ierr;
    if constexpr (std::is_same_v<Number, double>)
      ierr = MPI_Bcast(
          &t, 1, MPI_DOUBLE, 0, mpi_ensemble_.ensemble_communicator());
    else
      ierr =
          MPI_Bcast(&t, 1, MPI_FLOAT, 0, mpi_ensemble_.ensemble_communicator());
    AssertThrowMPI(ierr);
 
    ierr = MPI_Bcast(&output_cycle,
                     1,
                     MPI_UNSIGNED,
                     0,
                     mpi_ensemble_.ensemble_communicator());
    AssertThrowMPI(ierr);
 
    ierr = MPI_Bcast(&transfer_handle,
                     1,
                     MPI_UNSIGNED,
                     0,
                     mpi_ensemble_.ensemble_communicator());
    AssertThrowMPI(ierr);
 
    /* Now read in the state vector: */
 
    Vectors::reinit_state_vector<Description>(state_vector, offline_data_);
 
    solution_transfer_.set_handle(transfer_handle);
    solution_transfer_.project(state_vector);
    solution_transfer_.reset_handle();
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::write_checkpoint(
      const StateVector &state_vector,
      const std::string &base_name,
      const Number &t,
      const unsigned int &output_cycle)
  {
#ifdef DEBUG_OUTPUT
    std::cout << "TimeLoop<dim, Number>::write_checkpoint()" << std::endl;
#endif
 
    AssertThrow(have_distributed_triangulation<dim>,
                dealii::ExcMessage(
                    "write_checkpoint() is not implemented for "
                    "distributed::shared::Triangulation which we use in 1D"));
 
    /* We need hyperbolic_module.prepare_state_vector() prior to this call! */
    solution_transfer_.prepare_projection(state_vector);
    const auto transfer_handle = solution_transfer_.get_handle();
    solution_transfer_.reset_handle();
 
    std::string name = base_name + "-checkpoint";
 
    if (mpi_ensemble_.ensemble_rank() == 0) {
      for (const std::string suffix :
           {".mesh", ".mesh_fixed.data", ".mesh.info", ".metadata"})
        if (std::filesystem::exists(name + suffix))
          std::filesystem::rename(name + suffix, name + suffix + "~");
    }
 
#if !DEAL_II_VERSION_GTE(9, 6, 0)
    if constexpr (have_distributed_triangulation<dim>) {
#endif
      const auto &triangulation = discretization_.triangulation();
      triangulation.save(name + ".mesh");
#if !DEAL_II_VERSION_GTE(9, 6, 0)
    }
#endif
 
    /*
     * Now, write out metadata on rank 0:
     */
 
    if (mpi_ensemble_.ensemble_rank() == 0) {
      std::string meta = name + ".metadata";
      std::ofstream file(meta, std::ios::binary | std::ios::trunc);
      boost::archive::binary_oarchive oa(file);
      oa << t << output_cycle << transfer_handle;
    }
 
    const int ierr = MPI_Barrier(mpi_ensemble_.ensemble_communicator());
    AssertThrowMPI(ierr);
  }
 
 
  template <typename Description, int dim, typename Number>
  template <typename Callable>
  void TimeLoop<Description, dim, Number>::adapt_mesh_and_transfer_state_vector(
      StateVector &state_vector, const Callable &prepare_compute_kernels)
  {
#ifdef DEBUG_OUTPUT
    std::cout << "TimeLoop<dim, Number>::adapt_mesh_and_transfer_state_vector()"
              << std::endl;
#endif
 
    AssertThrow(mpi_ensemble_.n_ensembles() == 1, dealii::ExcNotImplemented());
 
    /*
     * Mark cells for coarsening and refinement and set up triangulation:
     */
 
    auto &triangulation = discretization_.triangulation();
    mesh_adaptor_.mark_cells_for_coarsening_and_refinement(triangulation);
 
    triangulation.prepare_coarsening_and_refinement();
 
    /* We need hyperbolic_module.prepare_state_vector() prior to this call! */
    solution_transfer_.prepare_projection(state_vector);
 
    /* Execute mesh adaptation and project old state to new state vector: */
 
    triangulation.execute_coarsening_and_refinement();
    prepare_compute_kernels();
 
    Vectors::reinit_state_vector<Description>(state_vector, offline_data_);
    solution_transfer_.project(state_vector);
    solution_transfer_.reset_handle();
  }
 
 
  template <typename Description, int dim, typename Number>
  void
  TimeLoop<Description, dim, Number>::compute_error(StateVector &state_vector,
                                                    const Number t)
  {
#ifdef DEBUG_OUTPUT
    std::cout << "TimeLoop<dim, Number>::compute_error()" << std::endl;
#endif
 
    hyperbolic_module_.prepare_state_vector(state_vector, t);
 
    Vector<Number> difference_per_cell(
        discretization_.triangulation().n_active_cells());
 
    Number linf_norm = 0.;
    Number l1_norm = 0;
    Number l2_norm = 0;
 
    const auto analytic_U =
        initial_values_.get().interpolate_hyperbolic_vector(t);
    const auto &U = std::get<0>(state_vector);
 
    ScalarVector analytic_component;
    ScalarVector error_component;
    analytic_component.reinit(offline_data_.scalar_partitioner());
    error_component.reinit(offline_data_.scalar_partitioner());
 
    /* Loop over all selected components: */
    for (const auto &entry : error_quantities_) {
      const auto &names = View::component_names;
      const auto pos = std::find(std::begin(names), std::end(names), entry);
      if (pos == std::end(names)) {
        AssertThrow(
            false,
            dealii::ExcMessage("Unknown component name »" + entry + "«"));
        __builtin_trap();
      }
 
      const auto index = std::distance(std::begin(names), pos);
 
      analytic_U.extract_component(analytic_component, index);
 
      /* Compute norms of analytic solution: */
 
      Number linf_norm_analytic = 0.;
      Number l1_norm_analytic = 0.;
      Number l2_norm_analytic = 0.;
 
      if (error_normalize_) {
        linf_norm_analytic =
            Utilities::MPI::max(analytic_component.linfty_norm(),
                                mpi_ensemble_.ensemble_communicator());
 
        VectorTools::integrate_difference(
            offline_data_.dof_handler(),
            analytic_component,
            Functions::ZeroFunction<dim, Number>(),
            difference_per_cell,
            QGauss<dim>(3),
            VectorTools::L1_norm);
 
        l1_norm_analytic =
            Utilities::MPI::sum(difference_per_cell.l1_norm(),
                                mpi_ensemble_.ensemble_communicator());
 
        VectorTools::integrate_difference(
            offline_data_.dof_handler(),
            analytic_component,
            Functions::ZeroFunction<dim, Number>(),
            difference_per_cell,
            QGauss<dim>(3),
            VectorTools::L2_norm);
 
        l2_norm_analytic = Number(std::sqrt(
            Utilities::MPI::sum(std::pow(difference_per_cell.l2_norm(), 2),
                                mpi_ensemble_.ensemble_communicator())));
      }
 
      /* Compute norms of error: */
 
      U.extract_component(error_component, index);
      /* Populate constrained dofs due to periodicity: */
      offline_data_.affine_constraints().distribute(error_component);
      error_component.update_ghost_values();
      error_component -= analytic_component;
 
      const Number linf_norm_error = Utilities::MPI::max(
          error_component.linfty_norm(), mpi_ensemble_.ensemble_communicator());
 
      VectorTools::integrate_difference(offline_data_.dof_handler(),
                                        error_component,
                                        Functions::ZeroFunction<dim, Number>(),
                                        difference_per_cell,
                                        QGauss<dim>(3),
                                        VectorTools::L1_norm);
 
      const Number l1_norm_error = Utilities::MPI::sum(
          difference_per_cell.l1_norm(), mpi_ensemble_.ensemble_communicator());
 
      VectorTools::integrate_difference(offline_data_.dof_handler(),
                                        error_component,
                                        Functions::ZeroFunction<dim, Number>(),
                                        difference_per_cell,
                                        QGauss<dim>(3),
                                        VectorTools::L2_norm);
 
      const Number l2_norm_error = Number(std::sqrt(
          Utilities::MPI::sum(std::pow(difference_per_cell.l2_norm(), 2),
                              mpi_ensemble_.ensemble_communicator())));
 
      if (error_normalize_) {
        linf_norm += linf_norm_error / linf_norm_analytic;
        l1_norm += l1_norm_error / l1_norm_analytic;
        l2_norm += l2_norm_error / l2_norm_analytic;
      } else {
        linf_norm += linf_norm_error;
        l1_norm += l1_norm_error;
        l2_norm += l2_norm_error;
      }
    }
 
    if (mpi_ensemble_.ensemble_rank() != 0)
      return;
 
    /*
     * Sum up over all participating MPI ranks. Note: we only perform this
     * operation on "peer" ranks zero:
     */
 
    if (mpi_ensemble_.n_ensembles() > 1) {
      linf_norm = Utilities::MPI::sum(
          linf_norm, mpi_ensemble_.ensemble_leader_communicator());
      l1_norm = Utilities::MPI::sum(
          l1_norm, mpi_ensemble_.ensemble_leader_communicator());
      l2_norm = Utilities::MPI::sum(
          l2_norm, mpi_ensemble_.ensemble_leader_communicator());
    }
 
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    logfile_ << std::endl << "Computed errors:" << std::endl << std::endl;
    logfile_ << std::setprecision(16);
 
    std::string description =
        error_normalize_ ? "Normalized consolidated" : "Consolidated";
 
    logfile_ << description + " Linf, L1, and L2 errors at final time \n";
    logfile_ << std::setprecision(16);
    logfile_ << "#dofs = " << n_global_dofs_ << std::endl;
    logfile_ << "t     = " << t << std::endl;
    logfile_ << "Linf  = " << linf_norm << std::endl;
    logfile_ << "L1    = " << l1_norm << std::endl;
    logfile_ << "L2    = " << l2_norm << std::endl;
 
    std::cout << description + " Linf, L1, and L2 errors at final time \n";
    std::cout << std::setprecision(16);
    std::cout << "#dofs = " << n_global_dofs_ << std::endl;
    std::cout << "t     = " << t << std::endl;
    std::cout << "Linf  = " << linf_norm << std::endl;
    std::cout << "L1    = " << l1_norm << std::endl;
    std::cout << "L2    = " << l2_norm << std::endl;
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::output(StateVector &state_vector,
                                                  const std::string &name,
                                                  const Number t,
                                                  const unsigned int cycle)
  {
#ifdef DEBUG_OUTPUT
    std::cout << "TimeLoop<dim, Number>::output(t = " << t << ")" << std::endl;
#endif
 
    const bool do_full_output =
        (cycle % timer_output_full_multiplier_ == 0) && enable_output_full_;
    const bool do_levelsets =
        (cycle % timer_output_levelsets_multiplier_ == 0) &&
        enable_output_levelsets_;
    const bool do_checkpointing =
        (cycle % timer_checkpoint_multiplier_ == 0) && enable_checkpointing_;
 
    /* There is nothing to do: */
    if (!(do_full_output || do_levelsets || do_checkpointing))
      return;
 
    hyperbolic_module_.prepare_state_vector(state_vector, t);
 
    /* Data output: */
    if (do_full_output || do_levelsets) {
      Scope scope(computing_timer_, "time step [X]   - perform vtu output");
      print_info("scheduling output");
 
      postprocessor_.compute(state_vector);
      /*
       * Workaround: Manually reset bounds during the first output cycle
       * (which is often just a uniform flow field) to obtain a better
       * normailization:
       */
      if (cycle == 0)
        postprocessor_.reset_bounds();
 
      vtu_output_.schedule_output(
          state_vector, name, t, cycle, do_full_output, do_levelsets);
    }
 
    /* Checkpointing: */
    if (do_checkpointing) {
      Scope scope(computing_timer_, "time step [X]   - perform checkpointing");
      print_info("scheduling checkpointing");
      write_checkpoint(state_vector, base_name_ensemble_, t, cycle);
    }
  }
 
 
  /*
   * Output and logging related functions:
   */
 
 
  template <typename Description, int dim, typename Number>
  void
  TimeLoop<Description, dim, Number>::print_parameters(std::ostream &stream)
  {
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    /* Output commit and library information: */
 
    print_revision_and_version(stream);
 
    /* Print run time parameters: */
 
    stream << std::endl << "Run time parameters:" << std::endl << std::endl;
    ParameterAcceptor::prm.print_parameters(
        stream, ParameterHandler::OutputStyle::ShortPRM);
    stream << std::endl;
 
    /* Also print out parameters to a prm file: */
 
    std::ofstream output(base_name_ + "-parameters.prm");
    ParameterAcceptor::prm.print_parameters(output, ParameterHandler::ShortPRM);
  }
 
 
  template <typename Description, int dim, typename Number>
  void
  TimeLoop<Description, dim, Number>::print_mpi_partition(std::ostream &stream)
  {
    /*
     * Fixme: this conversion to double is really not elegant. We should
     * improve the Utilities::MPI::min_max_avg function in deal.II to
     * handle different data types
     */
 
    // NOLINTBEGIN
    std::vector<double> values = {
        (double)offline_data_.n_export_indices(),
        (double)offline_data_.n_locally_internal(),
        (double)offline_data_.n_locally_owned(),
        (double)offline_data_.n_locally_relevant(),
        (double)offline_data_.n_export_indices() /
            (double)offline_data_.n_locally_relevant(),
        (double)offline_data_.n_locally_internal() /
            (double)offline_data_.n_locally_relevant(),
        (double)offline_data_.n_locally_owned() /
            (double)offline_data_.n_locally_relevant()};
    // NOLINTEND
 
    const auto data =
        Utilities::MPI::min_max_avg(values, mpi_ensemble_.world_communicator());
 
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    std::ostringstream output;
 
    unsigned int n =
        dealii::Utilities::needed_digits(mpi_ensemble_.n_world_ranks());
 
    const auto print_snippet = [&output, n](const std::string &name,
                                            const auto &values) {
      output << name << ": ";
      // NOLINTBEGIN
      output << std::setw(9) << (unsigned int)values.min          //
             << " [p" << std::setw(n) << values.min_index << "] " //
             << std::setw(9) << (unsigned int)values.avg << " "   //
             << std::setw(9) << (unsigned int)values.max          //
             << " [p" << std::setw(n) << values.max_index << "]"; //
      // NOLINTEND
    };
 
    const auto print_percentages = [&output, n](const auto &percentages) {
      output << std::endl << "                  ";
      output << "  (" << std::setw(3) << std::setprecision(2)
             << percentages.min * 100 << "% )"
             << " [p" << std::setw(n) << percentages.min_index << "] "
             << "   (" << std::setw(3) << std::setprecision(2)
             << percentages.avg * 100 << "% )"
             << " "
             << "   (" << std::setw(3) << std::setprecision(2)
             << percentages.max * 100 << "% )"
             << " [p" << std::setw(n) << percentages.max_index << "]";
    };
 
    output << std::endl << std::endl << "Partition:   ";
    print_snippet("exp", data[0]);
    print_percentages(data[4]);
 
    output << std::endl << "             ";
    print_snippet("int", data[1]);
    print_percentages(data[5]);
 
    output << std::endl << "             ";
    print_snippet("own", data[2]);
    print_percentages(data[6]);
 
    output << std::endl << "             ";
    print_snippet("rel", data[3]);
 
    stream << output.str() << std::endl;
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::print_memory_statistics(
      std::ostream &stream)
  {
    Utilities::System::MemoryStats stats;
    Utilities::System::get_memory_stats(stats);
 
    Utilities::MPI::MinMaxAvg data = Utilities::MPI::min_max_avg(
        stats.VmRSS / 1024., mpi_ensemble_.world_communicator());
 
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    std::ostringstream output;
 
    unsigned int n =
        dealii::Utilities::needed_digits(mpi_ensemble_.n_world_ranks());
 
    output << "\nMemory:      [MiB]"                          //
           << std::setw(8) << data.min                        //
           << " [p" << std::setw(n) << data.min_index << "] " //
           << std::setw(8) << data.avg << " "                 //
           << std::setw(8) << data.max                        //
           << " [p" << std::setw(n) << data.max_index << "]"; //
 
    stream << output.str() << std::endl;
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::print_timers(std::ostream &stream)
  {
    std::vector<std::ostringstream> output(computing_timer_.size());
 
    const auto equalize = [&]() {
      const auto ptr =
          std::max_element(output.begin(),
                           output.end(),
                           [](const auto &left, const auto &right) {
                             return left.str().length() < right.str().length();
                           });
      const auto length = ptr->str().length();
      for (auto &it : output)
        it << std::string(length - it.str().length() + 1, ' ');
    };
 
    const auto print_wall_time = [&](auto &timer, auto &stream) {
      const auto wall_time = Utilities::MPI::min_max_avg(
          timer.wall_time(), mpi_ensemble_.world_communicator());
 
      constexpr auto eps = std::numeric_limits<double>::epsilon();
      /*
       * Cut off at 99.9% to avoid silly percentages cluttering up the
       * output.
       */
      const auto skew_negative = std::max(
          100. * (wall_time.min - wall_time.avg) / wall_time.avg - eps, -99.9);
      const auto skew_positive = std::min(
          100. * (wall_time.max - wall_time.avg) / wall_time.avg + eps, 99.9);
 
      stream << std::setprecision(2) << std::fixed << std::setw(8)
             << wall_time.avg << "s [sk: " << std::setprecision(1)
             << std::setw(5) << std::fixed << skew_negative << "%/"
             << std::setw(4) << std::fixed << skew_positive << "%]";
      unsigned int n =
          dealii::Utilities::needed_digits(mpi_ensemble_.n_world_ranks());
      stream << " [p" << std::setw(n) << wall_time.min_index << "/"
             << wall_time.max_index << "]";
    };
 
    const auto cpu_time_statistics =
        Utilities::MPI::min_max_avg(computing_timer_["time loop"].cpu_time(),
                                    mpi_ensemble_.world_communicator());
    const double total_cpu_time = cpu_time_statistics.sum;
 
    const auto print_cpu_time =
        [&](auto &timer, auto &stream, bool percentage) {
          const auto cpu_time = Utilities::MPI::min_max_avg(
              timer.cpu_time(), mpi_ensemble_.world_communicator());
 
          stream << std::setprecision(2) << std::fixed << std::setw(9)
                 << cpu_time.sum << "s ";
 
          if (percentage)
            stream << "(" << std::setprecision(1) << std::setw(4)
                   << 100. * cpu_time.sum / total_cpu_time << "%)";
        };
 
    auto jt = output.begin();
    for (auto &it : computing_timer_)
      *jt++ << "  " << it.first;
    equalize();
 
    jt = output.begin();
    for (auto &it : computing_timer_)
      print_wall_time(it.second, *jt++);
    equalize();
 
    jt = output.begin();
    bool compute_percentages = false;
    for (auto &it : computing_timer_) {
      print_cpu_time(it.second, *jt++, compute_percentages);
      if (it.first.starts_with("time loop"))
        compute_percentages = true;
    }
    equalize();
 
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    stream << std::endl << "Timer statistics:\n";
    for (auto &it : output)
      stream << it.str() << std::endl;
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::print_throughput(
      unsigned int cycle, Number t, std::ostream &stream, bool final_time)
  {
    /*
     * Fixme: The global state kept in this function should be refactored
     * into its own class object.
     */
    static struct Data {
      unsigned int cycle = 0;
      double t = 0.;
      double cpu_time_sum = 0.;
      double cpu_time_avg = 0.;
      double cpu_time_min = 0.;
      double cpu_time_max = 0.;
      double wall_time = 0.;
    } previous, current;
 
    static double time_per_second_exp = 0.;
 
    /* Update statistics: */
 
    {
      previous = current;
 
      current.cycle = cycle;
      current.t = t;
 
      const auto wall_time_statistics =
          Utilities::MPI::min_max_avg(computing_timer_["time loop"].wall_time(),
                                      mpi_ensemble_.world_communicator());
      current.wall_time = wall_time_statistics.max;
 
      const auto cpu_time_statistics =
          Utilities::MPI::min_max_avg(computing_timer_["time loop"].cpu_time(),
                                      mpi_ensemble_.world_communicator());
      current.cpu_time_sum = cpu_time_statistics.sum;
      current.cpu_time_avg = cpu_time_statistics.avg;
      current.cpu_time_min = cpu_time_statistics.min;
      current.cpu_time_max = cpu_time_statistics.max;
    }
 
    if (final_time)
      previous = Data();
 
    /* Take averages: */
 
    double delta_cycles = current.cycle - previous.cycle;
    const double cycles_per_second =
        delta_cycles / (current.wall_time - previous.wall_time);
 
    const auto efficiency = time_integrator_.efficiency();
    const auto n_dofs = static_cast<double>(n_global_dofs_);
 
    const double wall_m_dofs_per_sec =
        delta_cycles * n_dofs / 1.e6 /
        (current.wall_time - previous.wall_time) * efficiency;
 
    double cpu_m_dofs_per_sec = delta_cycles * n_dofs / 1.e6 /
                                (current.cpu_time_sum - previous.cpu_time_sum) *
                                efficiency;
#ifdef WITH_OPENMP
    if (terminal_show_rank_throughput_)
      cpu_m_dofs_per_sec *= MultithreadInfo::n_threads();
#endif
 
    double cpu_time_skew = (current.cpu_time_max - current.cpu_time_min - //
                            previous.cpu_time_max + previous.cpu_time_min) /
                           delta_cycles;
    /* avoid printing small negative numbers: */
    cpu_time_skew = std::max(0., cpu_time_skew);
 
    const double cpu_time_skew_percentage =
        cpu_time_skew * delta_cycles /
        (current.cpu_time_avg - previous.cpu_time_avg);
 
    const double delta_time =
        (current.t - previous.t) / (current.cycle - previous.cycle);
    const double time_per_second =
        (current.t - previous.t) / (current.wall_time - previous.wall_time);
 
    /* Print Jean-Luc and Martin metrics: */
 
    std::ostringstream output;
 
    /* clang-format off */
    output << std::endl;
 
    output << "Throughput:\n  "
           << (terminal_show_rank_throughput_? "RANK: " : "CPU : ")
           << std::setprecision(4) << std::fixed << cpu_m_dofs_per_sec
           << " MQ/s  ("
           << std::scientific << 1. / cpu_m_dofs_per_sec * 1.e-6
           << " s/Qdof/substep)" << std::endl;
 
    output << "        [cpu time skew: "
           << std::setprecision(2) << std::scientific << cpu_time_skew
           << "s/cycle ("
           << std::setprecision(1) << std::setw(4) << std::setfill(' ') << std::fixed
           << 100. * cpu_time_skew_percentage
           << "%)]" << std::endl;
 
    output << "  WALL: "
           << std::setprecision(4) << std::fixed << wall_m_dofs_per_sec
           << " MQ/s  ("
           << std::scientific << 1. / wall_m_dofs_per_sec * 1.e-6
           << " s/Qdof/substep)  ("
           << std::setprecision(2) << std::fixed << cycles_per_second
           << " cycles/s)" << std::endl;
 
    const auto &scheme = time_integrator_.time_stepping_scheme();
    output << "        [ "
           << Patterns::Tools::Convert<TimeSteppingScheme>::to_string(scheme)
           << " with CFL = "
           << std::setprecision(2) << std::fixed << hyperbolic_module_.cfl()
           << " ("
           << std::setprecision(0) << std::fixed << hyperbolic_module_.n_restarts()
           << "/"
           << std::setprecision(0) << std::fixed << parabolic_module_.n_restarts()
           << " rsts) ("
           << std::setprecision(0) << std::fixed << hyperbolic_module_.n_warnings()
           << "/"
           << std::setprecision(0) << std::fixed << parabolic_module_.n_warnings()
           << " warn) ("
           << std::setprecision(0) << std::fixed << hyperbolic_module_.n_corrections()
           << "/"
           << std::setprecision(0) << std::fixed << parabolic_module_.n_corrections()
           << " corr) ]" << std::endl;
 
    if constexpr (!ParabolicSystem::is_identity)
      parabolic_module_.print_solver_statistics(output);
 
    output << "        [ dt = "
           << std::scientific << std::setprecision(2) << delta_time
           << " ( "
           << time_per_second
           << " dt/s) ]" << std::endl;
    /* clang-format on */
 
    /* and print an ETA */
    time_per_second_exp = 0.8 * time_per_second_exp + 0.2 * time_per_second;
    auto eta = static_cast<unsigned int>(std::max(t_final_ - t, Number(0.)) /
                                         time_per_second_exp);
 
    output << "\n  ETA : ";
 
    const unsigned int days = eta / (24 * 3600);
    if (days > 0) {
      output << days << " d  ";
      eta %= 24 * 3600;
    }
 
    const unsigned int hours = eta / 3600;
    if (hours > 0) {
      output << hours << " h  ";
      eta %= 3600;
    }
 
    const unsigned int minutes = eta / 60;
    output << minutes << " min";
 
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    stream << output.str() << std::endl;
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::print_info(const std::string &header)
  {
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    std::cout << "[INFO] " << header << std::endl;
  }
 
 
  template <typename Description, int dim, typename Number>
  void
  TimeLoop<Description, dim, Number>::print_head(const std::string &header,
                                                 const std::string &secondary,
                                                 std::ostream &stream)
  {
    if (mpi_ensemble_.world_rank() != 0)
      return;
 
    const int header_size = header.size();
    const auto padded_header =
        std::string(std::max(0, 34 - header_size) / 2, ' ') + header +
        std::string(std::max(0, 35 - header_size) / 2, ' ');
 
    const int secondary_size = secondary.size();
    const auto padded_secondary =
        std::string(std::max(0, 34 - secondary_size) / 2, ' ') + secondary +
        std::string(std::max(0, 35 - secondary_size) / 2, ' ');
 
    /* clang-format off */
    stream << "\n";
    stream << "    ####################################################\n";
    stream << "    #########"     <<  padded_header   <<     "#########\n";
    stream << "    #########"     << padded_secondary <<     "#########\n";
    stream << "    ####################################################\n";
    stream << std::endl;
    /* clang-format on */
  }
 
 
  template <typename Description, int dim, typename Number>
  void TimeLoop<Description, dim, Number>::print_cycle_statistics(
      unsigned int cycle,
      Number t,
      unsigned int timer_cycle,
      bool write_to_logfile,
      bool final_time)
  {
    static const std::string vectorization_name = [] {
      constexpr auto width = VectorizedArray<Number>::size();
 
      std::string result;
      if (width == 1)
        result = "scalar ";
      else
        result = std::to_string(width * 8 * sizeof(Number)) + " bit packed ";
 
      if constexpr (std::is_same_v<Number, double>)
        return result + "double";
      else if constexpr (std::is_same_v<Number, float>)
        return result + "float";
      else
        __builtin_trap();
    }();
 
    std::ostringstream output;
 
    std::ostringstream primary;
    if (final_time) {
      primary << "FINAL  (cycle " << Utilities::int_to_string(cycle, 6) << ")";
    } else {
      primary << "Cycle  " << Utilities::int_to_string(cycle, 6) //
              << "  (" << std::fixed << std::setprecision(1)     //
              << t / t_final_ * 100 << "%)";
    }
 
    std::ostringstream secondary;
    secondary << "at time t = " << std::setprecision(8) << std::fixed << t;
 
    print_head(primary.str(), secondary.str(), output);
 
    output << "Information: (HYP) " << hyperbolic_system_.get().problem_name;
    if constexpr (!ParabolicSystem::is_identity) {
      output << "\n             (PAR) " << parabolic_system_.get().problem_name;
    }
    output << "\n             [" << base_name_ << "] ";
    if (mpi_ensemble_.n_ensembles() > 1) {
      output << mpi_ensemble_.n_ensembles() << " ensembles ";
    }
    output << "with "                                      //
           << n_global_dofs_ << " Qdofs on "               //
           << mpi_ensemble_.n_world_ranks() << " ranks / " //
#ifdef WITH_OPENMP
           << MultithreadInfo::n_threads() << " threads <" //
#else
           << "[openmp disabled] <" //
#endif
           << vectorization_name                                         //
           << ">\n             Last output cycle "                       //
           << timer_cycle - 1                                            //
           << " at t = " << timer_granularity_ * (timer_cycle - 1)       //
           << " (terminal update interval " << terminal_update_interval_ //
           << "s)\n";
 
    print_memory_statistics(output);
    print_timers(output);
    print_throughput(cycle, t, output, final_time);
 
    if (mpi_ensemble_.world_rank() == 0) {
#ifndef DEBUG_OUTPUT
      std::cout << "\033[2J\033[H";
#endif
      std::cout << output.str() << std::flush;
 
      if (write_to_logfile) {
        logfile_ << "\n" << output.str() << std::flush;
      }
    }
  }
 
} // namespace ryujin