InSituLib Namespace Reference

Detailed Description

Copyright

Copyright (c) 2012-2021, OpenGeoSys Community (http://www.opengeosys.org) Distributed under a Modified BSD License. See accompanying file LICENSE.txt or http://www.opengeosys.org/project/license

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 67 of file Adaptor.cpp.

{
    if (Processor == nullptr)
        return;
 
    vtkNew<vtkCPDataDescription> dataDescription;
    dataDescription->AddInput("input");
    dataDescription->SetTimeData(time, timeStep);
    if (lastTimeStep == true)
    {
        // assume that we want to all the pipelines to execute if it
        // is the last time step.
        dataDescription->ForceOutputOn();
    }
    if (Processor->RequestDataDescription(dataDescription.GetPointer()) != 0)
    {
        INFO("Start InSitu process: timestep #{:d} (t={:g}, last={:d})",
             timeStep, time, lastTimeStep);
        vtkNew<MeshLib::VtkMappedMeshSource> vtkSource;
        vtkSource->SetMesh(&mesh);
        vtkSource->Update();
        dataDescription->GetInputDescriptionByName("input")->SetGrid(
            vtkSource->GetOutput());
        auto const cwd = fs::current_path();
        fs::current_path(std::move(output_directory));
        Processor->CoProcess(dataDescription.GetPointer());
        fs::current_path(cwd);
        INFO("End InSitu process.");
    }
}

References INFO(), and Processor.

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

Finalize()

void InSituLib::Finalize

(

)

Definition at line 59 of file Adaptor.cpp.

{
    if (Processor)
    {
        Processor->Delete();
        Processor = nullptr;
    }
}

References Processor.

Referenced by main().

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 27 of file Adaptor.cpp.

{
    if (Processor == nullptr)
    {
        Processor = vtkCPProcessor::New();
        Processor->Initialize();
    }
    else
    {
        Processor->RemoveAllPipelines();
    }
    for (auto script_config : scripts_config.getConfigSubtreeList("script"))
    {
        auto scriptPath =
            fs::path(script_config.getConfigParameter<std::string>("name"));
        if (scriptPath.is_relative())
        {
            scriptPath = fs::path(path) / scriptPath;
        }
        if (!fs::exists(scriptPath))
        {
            ERR("In-situ script {:s} does not exist!", scriptPath.string());
        }
        INFO("Initializing in-situ script: {:s}", scriptPath.string());
        vtkNew<vtkCPPythonScriptPipeline> pipeline;
        pipeline->Initialize(scriptPath.c_str());
        Processor->AddPipeline(pipeline.GetPointer());
    }
}

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

Referenced by main(), and MeshLib::VtkMeshNodalCoordinatesTemplate< Scalar >::SetNodes().

Variable Documentation

Processor

vtkCPProcessor* InSituLib::Processor = nullptr

Definition at line 25 of file Adaptor.cpp.

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