profiling_monitor.hpp

Go to the documentation of this file.

#pragma once
 
#include <deal.II/base/mpi.h>
#include <deal.II/base/timer.h>
 
#include <meltpooldg/time_integration/time_iterator.hpp>
#include <meltpooldg/utilities/conditional_ostream.hpp>
#include <meltpooldg/utilities/profiling_data.hpp>
 
#include <boost/signals2/signal.hpp>
 
#include <chrono>
 
 
namespace MeltPoolDG::Profiling
{
  template <typename number>
  class ProfilingMonitor
  {
  public:
    ProfilingMonitor(const ProfilingData<number>                 &data,
                     const TimeIntegration::TimeIterator<number> &time);
 
    bool
    now() const;
 
    void
    print(const ConditionalOStream  &pcout,
          const dealii::TimerOutput &timer,
          const MPI_Comm            &mpi_communicator) const;
 
    void
    subscribe(const std::function<void(const ConditionalOStream &)> &callback);
 
  private:
    const ProfilingData<number> &data;
 
    const TimeIntegration::TimeIterator<number> &time;
 
    mutable number last_written_time = 0.0;
 
    std::chrono::time_point<std::chrono::system_clock> real_time_start;
 
    boost::signals2::signal<void(const ConditionalOStream &pcout)> notify_signal;
 
    number
    compute_current_time() const;
  };
} // namespace MeltPoolDG::Profiling