mirror of
https://github.com/OPM/opm-simulators.git
synced 2026-11-02 20:30:55 -06:00
changed: move banner printing to separate compile unit
This commit is contained in:
1 parent
e25cabd06c
commit
e5dc2996e2
6 files changed
+209
-108
No files matched your search
@@ -40,6 +40,7 @@ list (APPEND MAIN_SOURCE_FILES
|
|||||||
opm/core/props/phaseUsageFromDeck.cpp
|
opm/core/props/phaseUsageFromDeck.cpp
|
||||||
opm/core/props/satfunc/RelpermDiagnostics.cpp
|
opm/core/props/satfunc/RelpermDiagnostics.cpp
|
||||||
opm/simulators/timestepping/SimulatorReport.cpp
|
opm/simulators/timestepping/SimulatorReport.cpp
|
||||||
|
opm/simulators/flow/Banners.cpp
|
||||||
opm/simulators/flow/countGlobalCells.cpp
|
opm/simulators/flow/countGlobalCells.cpp
|
||||||
opm/simulators/flow/ConvergenceOutputConfiguration.cpp
|
opm/simulators/flow/ConvergenceOutputConfiguration.cpp
|
||||||
opm/simulators/flow/ExtraConvergenceOutputThread.cpp
|
opm/simulators/flow/ExtraConvergenceOutputThread.cpp
|
||||||
@@ -280,6 +281,7 @@ list (APPEND PUBLIC_HEADER_FILES
|
|||||||
opm/simulators/flow/countGlobalCells.hpp
|
opm/simulators/flow/countGlobalCells.hpp
|
||||||
opm/simulators/flow/BlackoilModelEbos.hpp
|
opm/simulators/flow/BlackoilModelEbos.hpp
|
||||||
opm/simulators/flow/BlackoilModelParametersEbos.hpp
|
opm/simulators/flow/BlackoilModelParametersEbos.hpp
|
||||||
|
opm/simulators/flow/Banners.hpp
|
||||||
opm/simulators/flow/ConvergenceOutputConfiguration.hpp
|
opm/simulators/flow/ConvergenceOutputConfiguration.hpp
|
||||||
opm/simulators/flow/ExtraConvergenceOutputThread.hpp
|
opm/simulators/flow/ExtraConvergenceOutputThread.hpp
|
||||||
opm/simulators/flow/FlowMainEbos.hpp
|
opm/simulators/flow/FlowMainEbos.hpp
|
||||||
|
|||||||
@@ -0,0 +1,125 @@
|
|||||||
|
/*
|
||||||
|
Copyright 2013, 2014, 2015 SINTEF ICT, Applied Mathematics.
|
||||||
|
Copyright 2014 Dr. Blatt - HPC-Simulation-Software & Services
|
||||||
|
Copyright 2015 IRIS AS
|
||||||
|
Copyright 2014 STATOIL ASA.
|
||||||
|
|
||||||
|
This file is part of the Open Porous Media project (OPM).
|
||||||
|
|
||||||
|
OPM is free software: you can redistribute it and/or modify
|
||||||
|
it under the terms of the GNU General Public License as published by
|
||||||
|
the Free Software Foundation, either version 3 of the License, or
|
||||||
|
(at your option) any later version.
|
||||||
|
|
||||||
|
OPM is distributed in the hope that it will be useful,
|
||||||
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
|
GNU General Public License for more details.
|
||||||
|
|
||||||
|
You should have received a copy of the GNU General Public License
|
||||||
|
along with OPM. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include <config.h>
|
||||||
|
#include <opm/simulators/flow/Banners.hpp>
|
||||||
|
|
||||||
|
#include <opm/common/OpmLog/OpmLog.hpp>
|
||||||
|
|
||||||
|
#include <opm/simulators/timestepping/SimulatorReport.hpp>
|
||||||
|
#include <opm/simulators/utils/moduleVersion.hpp>
|
||||||
|
|
||||||
|
#include <fmt/format.h>
|
||||||
|
|
||||||
|
#include <ctime>
|
||||||
|
#include <iomanip>
|
||||||
|
#include <iostream>
|
||||||
|
#include <sstream>
|
||||||
|
#include <sys/utsname.h>
|
||||||
|
#include <thread>
|
||||||
|
#include <unistd.h>
|
||||||
|
|
||||||
|
namespace {
|
||||||
|
|
||||||
|
unsigned long long getTotalSystemMemory()
|
||||||
|
{
|
||||||
|
long pages = sysconf(_SC_PHYS_PAGES);
|
||||||
|
long page_size = sysconf(_SC_PAGE_SIZE);
|
||||||
|
return pages * page_size;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
namespace Opm {
|
||||||
|
|
||||||
|
void printPRTHeader(const std::string& parameters)
|
||||||
|
{
|
||||||
|
const std::string version = moduleVersion();
|
||||||
|
const double megabyte = 1024 * 1024;
|
||||||
|
unsigned num_cpu = std::thread::hardware_concurrency();
|
||||||
|
struct utsname arch;
|
||||||
|
const char* user = getlogin();
|
||||||
|
std::time_t now = std::time(0);
|
||||||
|
struct std::tm tstruct;
|
||||||
|
char tmstr[80];
|
||||||
|
tstruct = *std::localtime(&now);
|
||||||
|
std::strftime(tmstr, sizeof(tmstr), "%d-%m-%Y at %X", &tstruct);
|
||||||
|
const double mem_size = getTotalSystemMemory() / megabyte;
|
||||||
|
std::ostringstream ss;
|
||||||
|
ss << "\n\n\n";
|
||||||
|
ss << " ######## # ###### # #\n";
|
||||||
|
ss << " # # # # # # \n";
|
||||||
|
ss << " ##### # # # # # # \n";
|
||||||
|
ss << " # # # # # # # # \n";
|
||||||
|
ss << " # ####### ###### # # \n\n";
|
||||||
|
ss << "Flow is a simulator for fully implicit three-phase black-oil flow,";
|
||||||
|
ss << " and is part of OPM.\nFor more information visit: https://opm-project.org \n\n";
|
||||||
|
ss << "Flow Version = " + version + "\n";
|
||||||
|
if (uname(&arch) == 0) {
|
||||||
|
ss << "Machine name = " << arch.nodename << " (Number of logical cores: " << num_cpu;
|
||||||
|
ss << ", Memory size: " << std::fixed << std::setprecision (2) << mem_size << " MB) \n";
|
||||||
|
ss << "Operating system = " << arch.sysname << " " << arch.machine << " (Kernel: " << arch.release;
|
||||||
|
ss << ", " << arch.version << " )\n";
|
||||||
|
ss << "Build time = " << compileTimestamp() << "\n";
|
||||||
|
}
|
||||||
|
if (user) {
|
||||||
|
ss << "User = " << user << std::endl;
|
||||||
|
}
|
||||||
|
ss << "Simulation started on " << tmstr << " hrs\n";
|
||||||
|
|
||||||
|
ss << "Parameters used by Flow:\n" << parameters;
|
||||||
|
|
||||||
|
OpmLog::note(ss.str());
|
||||||
|
}
|
||||||
|
|
||||||
|
void printFlowBanner(int nprocs, int nthreads)
|
||||||
|
{
|
||||||
|
const int lineLen = 70;
|
||||||
|
const std::string version = moduleVersionName();
|
||||||
|
const std::string banner = "This is flow "+version;
|
||||||
|
const int bannerPreLen = (lineLen - 2 - banner.size())/2;
|
||||||
|
const int bannerPostLen = bannerPreLen + (lineLen - 2 - banner.size())%2;
|
||||||
|
std::cout << "**********************************************************************\n";
|
||||||
|
std::cout << "* *\n";
|
||||||
|
std::cout << "*" << std::string(bannerPreLen, ' ') << banner << std::string(bannerPostLen, ' ') << "*\n";
|
||||||
|
std::cout << "* *\n";
|
||||||
|
std::cout << "* Flow is a simulator for fully implicit three-phase black-oil flow, *\n";
|
||||||
|
std::cout << "* including solvent and polymer capabilities. *\n";
|
||||||
|
std::cout << "* For more information, see https://opm-project.org *\n";
|
||||||
|
std::cout << "* *\n";
|
||||||
|
std::cout << "**********************************************************************\n\n";
|
||||||
|
|
||||||
|
std::cout << "Using "<< nprocs << " MPI processes with "<< nthreads <<" OMP threads on each \n\n";
|
||||||
|
}
|
||||||
|
|
||||||
|
void printFlowTrailer(int nprocs, int nthreads,
|
||||||
|
const SimulatorReport& report)
|
||||||
|
{
|
||||||
|
std::ostringstream ss;
|
||||||
|
ss << "\n\n================ End of simulation ===============\n\n";
|
||||||
|
ss << fmt::format("Number of MPI processes: {:9}\n", nprocs);
|
||||||
|
ss << fmt::format("Threads per MPI process: {:9}\n", nthreads);
|
||||||
|
report.reportFullyImplicit(ss);
|
||||||
|
OpmLog::info(ss.str());
|
||||||
|
}
|
||||||
|
|
||||||
|
} // namespace Opm
|
||||||
@@ -0,0 +1,43 @@
|
|||||||
|
/*
|
||||||
|
Copyright 2013, 2014, 2015 SINTEF ICT, Applied Mathematics.
|
||||||
|
Copyright 2014 Dr. Blatt - HPC-Simulation-Software & Services
|
||||||
|
Copyright 2015 IRIS AS
|
||||||
|
Copyright 2014 STATOIL ASA.
|
||||||
|
|
||||||
|
This file is part of the Open Porous Media project (OPM).
|
||||||
|
|
||||||
|
OPM is free software: you can redistribute it and/or modify
|
||||||
|
it under the terms of the GNU General Public License as published by
|
||||||
|
the Free Software Foundation, either version 3 of the License, or
|
||||||
|
(at your option) any later version.
|
||||||
|
|
||||||
|
OPM is distributed in the hope that it will be useful,
|
||||||
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
|
GNU General Public License for more details.
|
||||||
|
|
||||||
|
You should have received a copy of the GNU General Public License
|
||||||
|
along with OPM. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
#ifndef OPM_FLOW_BANNERS_HEADER_INCLUDED
|
||||||
|
#define OPM_FLOW_BANNERS_HEADER_INCLUDED
|
||||||
|
|
||||||
|
#include <string>
|
||||||
|
|
||||||
|
namespace Opm {
|
||||||
|
|
||||||
|
class SimulatorReport;
|
||||||
|
|
||||||
|
// Print an ASCII-art header to the PRT and DEBUG files.
|
||||||
|
void printPRTHeader(const std::string& parameters);
|
||||||
|
|
||||||
|
// Print flow application banner.
|
||||||
|
void printFlowBanner(int nprocs, int threads);
|
||||||
|
|
||||||
|
// Print flow application trailer.
|
||||||
|
void printFlowTrailer(int nprocs, int nthreads,
|
||||||
|
const SimulatorReport& report);
|
||||||
|
|
||||||
|
} // namespace Opm
|
||||||
|
|
||||||
|
#endif // OPM_FLOW_BANNERS_EBOS_HEADER_INCLUDED
|
||||||
@@ -22,10 +22,8 @@
|
|||||||
#ifndef OPM_FLOW_MAIN_EBOS_HEADER_INCLUDED
|
#ifndef OPM_FLOW_MAIN_EBOS_HEADER_INCLUDED
|
||||||
#define OPM_FLOW_MAIN_EBOS_HEADER_INCLUDED
|
#define OPM_FLOW_MAIN_EBOS_HEADER_INCLUDED
|
||||||
|
|
||||||
|
|
||||||
#include <sys/utsname.h>
|
|
||||||
|
|
||||||
#include <opm/simulators/flow/ConvergenceOutputConfiguration.hpp>
|
#include <opm/simulators/flow/ConvergenceOutputConfiguration.hpp>
|
||||||
|
#include <opm/simulators/flow/Banners.hpp>
|
||||||
#include <opm/simulators/flow/SimulatorFullyImplicitBlackoilEbos.hpp>
|
#include <opm/simulators/flow/SimulatorFullyImplicitBlackoilEbos.hpp>
|
||||||
#include <opm/simulators/utils/ParallelFileMerger.hpp>
|
#include <opm/simulators/utils/ParallelFileMerger.hpp>
|
||||||
#include <opm/simulators/utils/moduleVersion.hpp>
|
#include <opm/simulators/utils/moduleVersion.hpp>
|
||||||
@@ -37,7 +35,6 @@
|
|||||||
#include <opm/input/eclipse/EclipseState/InitConfig/InitConfig.hpp>
|
#include <opm/input/eclipse/EclipseState/InitConfig/InitConfig.hpp>
|
||||||
#include <opm/common/utility/String.hpp>
|
#include <opm/common/utility/String.hpp>
|
||||||
|
|
||||||
#include <fmt/format.h>
|
|
||||||
#include <filesystem>
|
#include <filesystem>
|
||||||
|
|
||||||
#if HAVE_DUNE_FEM
|
#if HAVE_DUNE_FEM
|
||||||
@@ -274,45 +271,6 @@ namespace Opm
|
|||||||
return status;
|
return status;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void printBanner(Parallel::Communication comm)
|
|
||||||
{
|
|
||||||
const int lineLen = 70;
|
|
||||||
const std::string version = moduleVersionName();
|
|
||||||
const std::string banner = "This is flow "+version;
|
|
||||||
const int bannerPreLen = (lineLen - 2 - banner.size())/2;
|
|
||||||
const int bannerPostLen = bannerPreLen + (lineLen - 2 - banner.size())%2;
|
|
||||||
std::cout << "**********************************************************************\n";
|
|
||||||
std::cout << "* *\n";
|
|
||||||
std::cout << "*" << std::string(bannerPreLen, ' ') << banner << std::string(bannerPostLen, ' ') << "*\n";
|
|
||||||
std::cout << "* *\n";
|
|
||||||
std::cout << "* Flow is a simulator for fully implicit three-phase black-oil flow, *\n";
|
|
||||||
std::cout << "* including solvent and polymer capabilities. *\n";
|
|
||||||
std::cout << "* For more information, see https://opm-project.org *\n";
|
|
||||||
std::cout << "* *\n";
|
|
||||||
std::cout << "**********************************************************************\n\n";
|
|
||||||
|
|
||||||
int threads = 1;
|
|
||||||
|
|
||||||
#ifdef _OPENMP
|
|
||||||
// This function is called before the parallel OpenMP stuff gets initialized.
|
|
||||||
// That initialization happends after the deck is read and we want this message.
|
|
||||||
// Hence we duplicate the code of setupParallelism to get the number of threads.
|
|
||||||
if (getenv("OMP_NUM_THREADS"))
|
|
||||||
threads = omp_get_max_threads();
|
|
||||||
else
|
|
||||||
threads = std::min(2, omp_get_max_threads());
|
|
||||||
|
|
||||||
const int input_threads = EWOMS_GET_PARAM(TypeTag, int, ThreadsPerProcess);
|
|
||||||
|
|
||||||
if (input_threads > 0)
|
|
||||||
threads = std::min(input_threads, omp_get_max_threads());
|
|
||||||
#endif
|
|
||||||
|
|
||||||
int mpiSize = comm.size();
|
|
||||||
|
|
||||||
std::cout << "Using "<< mpiSize << " MPI processes with "<< threads <<" OMP threads on each \n\n";
|
|
||||||
}
|
|
||||||
|
|
||||||
/// This is the main function of Flow. It runs a complete simulation with the
|
/// This is the main function of Flow. It runs a complete simulation with the
|
||||||
/// given grid and simulator classes, based on the user-specified command-line
|
/// given grid and simulator classes, based on the user-specified command-line
|
||||||
/// input.
|
/// input.
|
||||||
@@ -342,50 +300,6 @@ namespace Opm
|
|||||||
return report.success.exit_status;
|
return report.success.exit_status;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Print an ASCII-art header to the PRT and DEBUG files.
|
|
||||||
static void printPRTHeader(bool output_cout)
|
|
||||||
{
|
|
||||||
if (output_cout) {
|
|
||||||
const std::string version = moduleVersion();
|
|
||||||
const double megabyte = 1024 * 1024;
|
|
||||||
unsigned num_cpu = std::thread::hardware_concurrency();
|
|
||||||
struct utsname arch;
|
|
||||||
const char* user = getlogin();
|
|
||||||
time_t now = std::time(0);
|
|
||||||
struct tm tstruct;
|
|
||||||
char tmstr[80];
|
|
||||||
tstruct = *localtime(&now);
|
|
||||||
strftime(tmstr, sizeof(tmstr), "%d-%m-%Y at %X", &tstruct);
|
|
||||||
const double mem_size = getTotalSystemMemory() / megabyte;
|
|
||||||
std::ostringstream ss;
|
|
||||||
ss << "\n\n\n";
|
|
||||||
ss << " ######## # ###### # #\n";
|
|
||||||
ss << " # # # # # # \n";
|
|
||||||
ss << " ##### # # # # # # \n";
|
|
||||||
ss << " # # # # # # # # \n";
|
|
||||||
ss << " # ####### ###### # # \n\n";
|
|
||||||
ss << "Flow is a simulator for fully implicit three-phase black-oil flow,";
|
|
||||||
ss << " and is part of OPM.\nFor more information visit: https://opm-project.org \n\n";
|
|
||||||
ss << "Flow Version = " + version + "\n";
|
|
||||||
if (uname(&arch) == 0) {
|
|
||||||
ss << "Machine name = " << arch.nodename << " (Number of logical cores: " << num_cpu;
|
|
||||||
ss << ", Memory size: " << std::fixed << std::setprecision (2) << mem_size << " MB) \n";
|
|
||||||
ss << "Operating system = " << arch.sysname << " " << arch.machine << " (Kernel: " << arch.release;
|
|
||||||
ss << ", " << arch.version << " )\n";
|
|
||||||
ss << "Build time = " << compileTimestamp() << "\n";
|
|
||||||
}
|
|
||||||
if (user) {
|
|
||||||
ss << "User = " << user << std::endl;
|
|
||||||
}
|
|
||||||
ss << "Simulation started on " << tmstr << " hrs\n";
|
|
||||||
|
|
||||||
ss << "Parameters used by Flow:\n";
|
|
||||||
Parameters::printValues<TypeTag>(ss);
|
|
||||||
|
|
||||||
OpmLog::note(ss.str());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
EbosSimulator *getSimulatorPtr() {
|
EbosSimulator *getSimulatorPtr() {
|
||||||
return ebosSimulator_.get();
|
return ebosSimulator_.get();
|
||||||
}
|
}
|
||||||
@@ -584,12 +498,7 @@ namespace Opm
|
|||||||
= omp_get_max_threads();
|
= omp_get_max_threads();
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
std::ostringstream ss;
|
printFlowTrailer(mpi_size_, threads, report);
|
||||||
ss << "\n\n================ End of simulation ===============\n\n";
|
|
||||||
ss << fmt::format("Number of MPI processes: {:9}\n", mpi_size_ );
|
|
||||||
ss << fmt::format("Threads per MPI process: {:9}\n", threads);
|
|
||||||
report.reportFullyImplicit(ss);
|
|
||||||
OpmLog::info(ss.str());
|
|
||||||
|
|
||||||
const auto extraConvOutput = ConvergenceOutputConfiguration {
|
const auto extraConvOutput = ConvergenceOutputConfiguration {
|
||||||
EWOMS_GET_PARAM(TypeTag, std::string, OutputExtraConvergenceInfo),
|
EWOMS_GET_PARAM(TypeTag, std::string, OutputExtraConvergenceInfo),
|
||||||
@@ -660,14 +569,6 @@ namespace Opm
|
|||||||
simulator_.reset(new Simulator(*ebosSimulator_));
|
simulator_.reset(new Simulator(*ebosSimulator_));
|
||||||
}
|
}
|
||||||
|
|
||||||
static unsigned long long getTotalSystemMemory()
|
|
||||||
{
|
|
||||||
long pages = sysconf(_SC_PHYS_PAGES);
|
|
||||||
long page_size = sysconf(_SC_PAGE_SIZE);
|
|
||||||
return pages * page_size;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
Grid& grid()
|
Grid& grid()
|
||||||
{ return ebosSimulator_->vanguard().grid(); }
|
{ return ebosSimulator_->vanguard().grid(); }
|
||||||
|
|
||||||
@@ -683,6 +584,7 @@ namespace Opm
|
|||||||
bool output_cout_;
|
bool output_cout_;
|
||||||
bool output_files_;
|
bool output_files_;
|
||||||
};
|
};
|
||||||
|
|
||||||
} // namespace Opm
|
} // namespace Opm
|
||||||
|
|
||||||
#endif // OPM_FLOW_MAIN_EBOS_HEADER_INCLUDED
|
#endif // OPM_FLOW_MAIN_EBOS_HEADER_INCLUDED
|
||||||
@@ -27,6 +27,7 @@
|
|||||||
#include <opm/input/eclipse/Schedule/Action/State.hpp>
|
#include <opm/input/eclipse/Schedule/Action/State.hpp>
|
||||||
#include <opm/input/eclipse/Schedule/UDQ/UDQState.hpp>
|
#include <opm/input/eclipse/Schedule/UDQ/UDQState.hpp>
|
||||||
|
|
||||||
|
#include <opm/simulators/flow/Banners.hpp>
|
||||||
#include <opm/simulators/utils/readDeck.hpp>
|
#include <opm/simulators/utils/readDeck.hpp>
|
||||||
|
|
||||||
#if HAVE_DAMARIS
|
#if HAVE_DAMARIS
|
||||||
@@ -172,7 +173,7 @@ void Main::readDeck(const std::string& deckFilename,
|
|||||||
const bool strictParsing,
|
const bool strictParsing,
|
||||||
const int mpiRank,
|
const int mpiRank,
|
||||||
const int output_param,
|
const int output_param,
|
||||||
std::function<void(bool)> outputPrt)
|
const std::string& parameters)
|
||||||
{
|
{
|
||||||
auto omode = setupLogging(mpiRank,
|
auto omode = setupLogging(mpiRank,
|
||||||
deckFilename,
|
deckFilename,
|
||||||
@@ -180,9 +181,8 @@ void Main::readDeck(const std::string& deckFilename,
|
|||||||
outputMode,
|
outputMode,
|
||||||
outputCout_, "STDOUT_LOGGER", allRanksDbgPrtLog);
|
outputCout_, "STDOUT_LOGGER", allRanksDbgPrtLog);
|
||||||
|
|
||||||
outputPrt(outputCout_);
|
|
||||||
|
|
||||||
if (outputCout_) {
|
if (outputCout_) {
|
||||||
|
printPRTHeader(parameters);
|
||||||
OpmLog::info("Reading deck file '" + deckFilename + "'");
|
OpmLog::info("Reading deck file '" + deckFilename + "'");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -54,6 +54,7 @@
|
|||||||
#include <opm/models/utils/propertysystem.hh>
|
#include <opm/models/utils/propertysystem.hh>
|
||||||
#include <opm/models/utils/parametersystem.hh>
|
#include <opm/models/utils/parametersystem.hh>
|
||||||
|
|
||||||
|
#include <opm/simulators/flow/Banners.hpp>
|
||||||
#include <opm/simulators/flow/FlowMainEbos.hpp>
|
#include <opm/simulators/flow/FlowMainEbos.hpp>
|
||||||
|
|
||||||
#if HAVE_DUNE_FEM
|
#if HAVE_DUNE_FEM
|
||||||
@@ -68,7 +69,6 @@
|
|||||||
|
|
||||||
#include <cassert>
|
#include <cassert>
|
||||||
#include <cstdlib>
|
#include <cstdlib>
|
||||||
#include <functional>
|
|
||||||
#include <iostream>
|
#include <iostream>
|
||||||
#include <memory>
|
#include <memory>
|
||||||
#include <stdexcept>
|
#include <stdexcept>
|
||||||
@@ -354,8 +354,13 @@ private:
|
|||||||
exitCode = EXIT_FAILURE;
|
exitCode = EXIT_FAILURE;
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
std::string cmdline_params;
|
||||||
if (outputCout_) {
|
if (outputCout_) {
|
||||||
FlowMainEbos<PreTypeTag>::printBanner(EclGenericVanguard::comm());
|
printFlowBanner(EclGenericVanguard::comm().size(), getNumThreads<PreTypeTag>());
|
||||||
|
std::ostringstream str;
|
||||||
|
Parameters::printValues<PreTypeTag>(str);
|
||||||
|
cmdline_params = str.str();
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create Deck and EclipseState.
|
// Create Deck and EclipseState.
|
||||||
@@ -368,7 +373,7 @@ private:
|
|||||||
EWOMS_GET_PARAM(PreTypeTag, bool, EclStrictParsing),
|
EWOMS_GET_PARAM(PreTypeTag, bool, EclStrictParsing),
|
||||||
mpiRank,
|
mpiRank,
|
||||||
EWOMS_GET_PARAM(PreTypeTag, int, EclOutputInterval),
|
EWOMS_GET_PARAM(PreTypeTag, int, EclOutputInterval),
|
||||||
FlowMainEbos<PreTypeTag>::printPRTHeader);
|
cmdline_params);
|
||||||
setupTime_ = externalSetupTimer.elapsed();
|
setupTime_ = externalSetupTimer.elapsed();
|
||||||
}
|
}
|
||||||
catch (const std::invalid_argument& e)
|
catch (const std::invalid_argument& e)
|
||||||
@@ -612,10 +617,34 @@ private:
|
|||||||
const bool strictParsing,
|
const bool strictParsing,
|
||||||
const int mpiRank,
|
const int mpiRank,
|
||||||
const int output_param,
|
const int output_param,
|
||||||
std::function<void(bool)> outputPrt);
|
const std::string& parameters);
|
||||||
|
|
||||||
void setupVanguard();
|
void setupVanguard();
|
||||||
|
|
||||||
|
template<class TypeTag>
|
||||||
|
static int getNumThreads()
|
||||||
|
{
|
||||||
|
|
||||||
|
int threads = 1;
|
||||||
|
|
||||||
|
#ifdef _OPENMP
|
||||||
|
// This function is called before the parallel OpenMP stuff gets initialized.
|
||||||
|
// That initialization happends after the deck is read and we want this message.
|
||||||
|
// Hence we duplicate the code of setupParallelism to get the number of threads.
|
||||||
|
if (std::getenv("OMP_NUM_THREADS"))
|
||||||
|
threads = omp_get_max_threads();
|
||||||
|
else
|
||||||
|
threads = std::min(2, omp_get_max_threads());
|
||||||
|
|
||||||
|
const int input_threads = EWOMS_GET_PARAM(TypeTag, int, ThreadsPerProcess);
|
||||||
|
|
||||||
|
if (input_threads > 0)
|
||||||
|
threads = std::min(input_threads, omp_get_max_threads());
|
||||||
|
#endif
|
||||||
|
|
||||||
|
return threads;
|
||||||
|
}
|
||||||
|
|
||||||
#if HAVE_DAMARIS
|
#if HAVE_DAMARIS
|
||||||
void setupDamaris(const std::string& outputDir,
|
void setupDamaris(const std::string& outputDir,
|
||||||
const bool enableDamarisOutputCollective);
|
const bool enableDamarisOutputCollective);
|
||||||
|
|||||||
Reference in new issue
Block a user