OilfieldToolsNet/opm-simulators
4
0
Fork 0
mirror of https://github.com/OPM/opm-simulators.git synced 2025-02-25 18:55:30 -06:00
Code Issues Packages Projects Releases Wiki Activity

Refactor execute()

Browse Source 
Currently, execute() calls runSimulator() to run the simulation. When
the Python step_init() is implemented (see a later commit), it will
instead call an executeStepInit() that will need to do the same
initialization as in execute() except that it should call a
runSimulatorInit() instead of runSimulator(). In order to avoid code
duplication for execute() and executeStepInit(), execute() is here
refactored into an execute_() method.
This commit is contained in:
Håkon Hægland 2020-02-26 22:45:52 +01:00
parent 2a1c1f9bfd
commit 224ddd9b73
1 changed files with 46 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
opm/simulators/flow/FlowMainEbos.hpp
View File

@ -245,45 +245,11 @@ namespace Opm
/// input.
int execute(int argc, char** argv, bool output_cout, bool output_to_files)
{
try {
// deal with some administrative boilerplate
int status = setupParameters_(argc, argv);
if (status)
return status;
setupParallelism();
setupEbosSimulator(output_cout);
runDiagnostics(output_cout);
createSimulator();
// do the actual work
runSimulator(output_cout);
// clean up
mergeParallelLogFiles(output_to_files);
return EXIT_SUCCESS;
}
catch (const std::exception& e) {
std::ostringstream message;
message << "Program threw an exception: " << e.what();
if (output_cout) {
// in some cases exceptions are thrown before the logging system is set
// up.
if (OpmLog::hasBackend("STREAMLOG")) {
OpmLog::error(message.str());
}
else {
std::cout << message.str() << "\n";
}
}
return EXIT_FAILURE;
}
return execute_(argc, argv, output_cout, output_to_files,
&FlowMainEbos::runSimulator);
}
// Print an ASCII-art header to the PRT and DEBUG files.
// \return Whether unkown keywords were seen during parsing.
static void printPRTHeader(bool output_cout)
@ -328,6 +294,49 @@ namespace Opm
}
}
private:
// called by execute() or executeInitStep()
int execute_(int argc, char** argv, bool output_cout, bool output_to_files,
void (FlowMainEbos::* runOrInitFunc)(bool))
{
try {
// deal with some administrative boilerplate
int status = setupParameters_(argc, argv);
if (status)
return status;
setupParallelism();
setupEbosSimulator(output_cout);
runDiagnostics(output_cout);
createSimulator();
// if run, do the actual work, else just initialize
(this->*runOrInitFunc)(output_cout);
// clean up
mergeParallelLogFiles(output_to_files);
return EXIT_SUCCESS;
}
catch (const std::exception& e) {
std::ostringstream message;
message << "Program threw an exception: " << e.what();
if (output_cout) {
// in some cases exceptions are thrown before the logging system is set
// up.
if (OpmLog::hasBackend("STREAMLOG")) {
OpmLog::error(message.str());
}
else {
std::cout << message.str() << "\n";
}
}
return EXIT_FAILURE;
}
}
protected:
void setupParallelism()
{