OGS
InSituLib Namespace Reference

Functions

void Initialize (BaseLib::ConfigTree const &scripts_config, std::string const &path)
void Finalize ()
void CoProcess (MeshLib::Mesh const &mesh, double const time, unsigned int const timeStep, bool const lastTimeStep, std::string output_directory)

Variables

vtkCPProcessor * Processor = nullptr

Function Documentation

◆ CoProcess()

void InSituLib::CoProcess ( MeshLib::Mesh const & mesh,
double const time,
unsigned int const timeStep,
bool const lastTimeStep,
std::string output_directory )

Definition at line 63 of file Adaptor.cpp.

66{
67 if (Processor == nullptr)
68 return;
69
70 vtkNew<vtkCPDataDescription> dataDescription;
71 dataDescription->AddInput("input");
72 dataDescription->SetTimeData(time, timeStep);
73 if (lastTimeStep == true)
74 {
75 // assume that we want to all the pipelines to execute if it
76 // is the last time step.
77 dataDescription->ForceOutputOn();
78 }
79 if (Processor->RequestDataDescription(dataDescription.GetPointer()) != 0)
80 {
81 INFO("Start InSitu process: timestep #{:d} (t={:g}, last={:d})",
82 timeStep, time, lastTimeStep);
83 vtkNew<MeshLib::VtkMappedMeshSource> vtkSource;
84 vtkSource->SetMesh(&mesh);
85 vtkSource->Update();
86 dataDescription->GetInputDescriptionByName("input")->SetGrid(
87 vtkSource->GetOutput());
88 auto const cwd = std::filesystem::current_path();
89 std::filesystem::current_path(std::move(output_directory));
90 Processor->CoProcess(dataDescription.GetPointer());
91 std::filesystem::current_path(cwd);
92 INFO("End InSitu process.");
93 }
94}
void INFO(fmt::format_string< Args... > fmt, Args &&... args)
Definition Logging.h:28
vtkCPProcessor * Processor
Definition Adaptor.cpp:21

References INFO(), and Processor.

Referenced by ProcessLib::Output::doOutput(), and ProcessLib::Output::doOutputLastTimestep().

◆ Finalize()

void InSituLib::Finalize ( )

Definition at line 55 of file Adaptor.cpp.

56{
57 if (Processor)
58 {
59 Processor->Delete();
60 Processor = nullptr;
61 }
62}

References Processor.

Referenced by Simulation::~Simulation().

◆ Initialize()

void InSituLib::Initialize ( BaseLib::ConfigTree const & scripts_config,
std::string const & path )
Input File Parameter
prj__insitu__scripts__script
Input File Parameter
prj__insitu__scripts__script__name

Definition at line 23 of file Adaptor.cpp.

25{
26 if (Processor == nullptr)
27 {
28 Processor = vtkCPProcessor::New();
29 Processor->Initialize();
30 }
31 else
32 {
33 Processor->RemoveAllPipelines();
34 }
36 for (auto script_config : scripts_config.getConfigSubtreeList("script"))
37 {
38 auto scriptPath = std::filesystem::path(
40 script_config.getConfigParameter<std::string>("name"));
41 if (scriptPath.is_relative())
42 {
43 scriptPath = std::filesystem::path(path) / scriptPath;
44 }
45 if (!std::filesystem::exists(scriptPath))
46 {
47 ERR("In-situ script {:s} does not exist!", scriptPath.string());
48 }
49 INFO("Initializing in-situ script: {:s}", scriptPath.string());
50 vtkNew<vtkCPPythonScriptPipeline> pipeline;
51 pipeline->Initialize(scriptPath.c_str());
52 Processor->AddPipeline(pipeline.GetPointer());
53 }
54}
void ERR(fmt::format_string< Args... > fmt, Args &&... args)
Definition Logging.h:40

References ERR(), BaseLib::ConfigTree::getConfigSubtreeList(), INFO(), and Processor.

Referenced by Simulation::initializeDataStructures().

Variable Documentation

◆ Processor

vtkCPProcessor* InSituLib::Processor = nullptr

Definition at line 21 of file Adaptor.cpp.

Referenced by CoProcess(), Finalize(), and Initialize().