EnclaveBookkeeping.h

Go to the documentation of this file.

// This file is part of the ExaHyPE2 project. For conditions of distribution and
// use, please see the copyright notice at www.peano-framework.org
#pragma once
 
 
#include "tarch/logging/Log.h"
#include "tarch/multicore/BooleanSemaphore.h"
 
 
#include "peano4/datamanagement/CellMarker.h"
 
#include <set>
#include <map>
#include <unordered_map>
#include <string>
 
 
namespace exahype2 {
  class EnclaveBookkeeping;
  class EnclaveTask;
}
 
 
class exahype2::EnclaveBookkeeping {
  public:
    struct Entry {
      int      numberOfResultValues;
      double*  data;
      double   maxEigenvalue;
 
      Entry( int  numberOfResultValues_, double*  data_, double   maxEigenvalue_ );
      Entry( const Entry& copy ) = default;
 
      ~Entry() = default;
      std::string toString() const;
    };
  private:
    static tarch::logging::Log          _log;
 
    static const std::string MemoryAllocationsInLookupTableIdentifier;
 
    using FinishedTaskMap = std::unordered_map<int, Entry >;
 
    FinishedTaskMap   _finishedTasks;
 
    #if PeanoDebug>0
    std::map<int, ::peano4::datamanagement::CellMarker >       _taskToMarkerMapping;
    #endif
 
    std::set<int>  _tasksThatHaveToBeCancelled;
 
    tarch::multicore::BooleanSemaphore  _finishedTasksSemaphore;
 
    EnclaveBookkeeping() = default;
    EnclaveBookkeeping(const EnclaveBookkeeping&) = delete;
 
    Entry waitForTaskToTerminateAndReturnResult(
      int number,
      const tarch::la::Vector<Dimensions, double>& x,
      const tarch::la::Vector<Dimensions, double>& h
    );
  public:
    static constexpr int NoEnclaveTaskNumber = -1;
    static constexpr int SkeletonTask        = -2;
 
    static EnclaveBookkeeping& getInstance();
 
    void dumpStatistics();
 
    void waitForTaskToTerminateAndCopyResultOver(
      int number,
      double* destination,
      double& maxEigenvalue,
      const tarch::la::Vector<Dimensions, double>& x,
      const tarch::la::Vector<Dimensions, double>& h
    );
 
    void waitForTaskAndDiscardResult(
      int number,
      const tarch::la::Vector<Dimensions, double>& x,
      const tarch::la::Vector<Dimensions, double>& h
    );
 
    void waitForTaskToTerminateAndWriteResultDirectly(
      int number,
      const tarch::la::Vector<Dimensions, double>& x,
      const tarch::la::Vector<Dimensions, double>& h
    );
 
    void finishedTask(
      int taskNumber,
      int numberOfResultValues,
      double* data,
      double maxEigenvalue,
      const tarch::la::Vector<Dimensions, double>& x,
      const tarch::la::Vector<Dimensions, double>& h
    );
 
    void registerTask( int taskNumber, const ::peano4::datamanagement::CellMarker& marker );
 
};