Skip to content
Snippets Groups Projects
Select Git revision
  • 5d3e5b3d5c69f60c503eee6221e5b1135e728809
  • develop default protected
  • feature/advection
  • feature/composite-scheme-other-fluxes
  • origin/stage/bouguettaia
  • save_clemence
  • feature/local-dt-fsi
  • feature/variational-hydro
  • feature/gmsh-reader
  • feature/reconstruction
  • feature/kinetic-schemes
  • feature/composite-scheme-sources
  • feature/serraille
  • feature/composite-scheme
  • hyperplastic
  • feature/polynomials
  • feature/gks
  • feature/implicit-solver-o2
  • feature/coupling_module
  • feature/implicit-solver
  • feature/merge-local-dt-fsi
  • v0.5.0 protected
  • v0.4.1 protected
  • v0.4.0 protected
  • v0.3.0 protected
  • v0.2.0 protected
  • v0.1.0 protected
  • Kidder
  • v0.0.4 protected
  • v0.0.3 protected
  • v0.0.2 protected
  • v0 protected
  • v0.0.1 protected
33 results

ASTNodeDataTypeBuilder.cpp

Blame
  • ParallelChecker.hpp 60.47 KiB
    #ifndef PARALLEL_CHECKER_HPP
    #define PARALLEL_CHECKER_HPP
    
    #include <utils/pugs_config.hpp>
    #ifdef PUGS_HAS_HDF5
    #include <highfive/highfive.hpp>
    #endif   // PUGS_HAS_HDF5
    
    #include <mesh/Connectivity.hpp>
    #include <mesh/ItemArrayVariant.hpp>
    #include <mesh/ItemValueVariant.hpp>
    #include <mesh/SubItemArrayPerItemVariant.hpp>
    #include <mesh/SubItemValuePerItemVariant.hpp>
    #include <scheme/DiscreteFunctionVariant.hpp>
    #include <utils/Demangle.hpp>
    #include <utils/Filesystem.hpp>
    #include <utils/Messenger.hpp>
    #include <utils/SourceLocation.hpp>
    
    #include <fstream>
    
    template <typename DataType, ItemType item_type, typename ConnectivityPtr>
    void parallel_check(const ItemValue<DataType, item_type, ConnectivityPtr>& item_value,
                        const std::string& name,
                        const SourceLocation& source_location = SourceLocation{});
    
    template <typename DataType, ItemType item_type, typename ConnectivityPtr>
    void parallel_check(const ItemArray<DataType, item_type, ConnectivityPtr>& item_array,
                        const std::string& name,
                        const SourceLocation& source_location = SourceLocation{});
    
    template <typename DataType, typename ItemOfItem, typename ConnectivityPtr>
    void parallel_check(const SubItemValuePerItem<DataType, ItemOfItem, ConnectivityPtr>& subitem_value_per_item,
                        const std::string& name,
                        const SourceLocation& source_location = SourceLocation{});
    
    template <typename DataType, typename ItemOfItem, typename ConnectivityPtr>
    void parallel_check(const SubItemArrayPerItem<DataType, ItemOfItem, ConnectivityPtr>& subitem_array_per_item,
                        const std::string& name,
                        const SourceLocation& source_location = SourceLocation{});
    
    class ParallelChecker
    {
     public:
      enum class Mode
      {
        automatic,   // write in sequential, read in parallel
        read,
        write
      };
    
      // to allow special manipulations in tests
      friend class ParallelCheckerTester;
    
     private:
      static ParallelChecker* m_instance;
    
      Mode m_mode  = Mode::automatic;
      size_t m_tag = 0;
    
      std::string m_filename = "parallel_checker.h5";
      std::string m_path     = "";
    
      ParallelChecker() = default;
    
     public:
      template <typename DataType, ItemType item_type, typename ConnectivityPtr>
      friend void parallel_check(const ItemValue<DataType, item_type, ConnectivityPtr>& item_value,
                                 const std::string& name,
                                 const SourceLocation& source_location);