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

changed: use EclMpiSerializer in loadParallelRestart

Browse Source
This commit is contained in:
Arne Morten Kvarving 2022-09-06 09:47:15 +02:00
parent 3273ef04f4
commit 1d00ed47ba
1 changed files with 6 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
opm/simulators/utils/ParallelRestart.cpp
View File

@ -27,7 +27,9 @@
#include <cstring> #include <cstring>
#include <ctime> #include <ctime>
#include <memory> #include <memory>
#include <dune/common/parallel/mpitraits.hh> #include <dune/common/parallel/mpitraits.hh>
#include <ebos/eclmpiserializer.hh>
#include <opm/output/data/Aquifer.hpp> #include <opm/output/data/Aquifer.hpp>
#include <opm/output/data/Cells.hpp> #include <opm/output/data/Cells.hpp>
#include <opm/output/data/Groups.hpp> #include <opm/output/data/Groups.hpp>
@ -1407,30 +1409,11 @@ RestartValue loadParallelRestart(const EclipseIO* eclIO, Action::State& actionSt
{ {
assert(comm.rank() == 0); assert(comm.rank() == 0);
restartValues = eclIO->loadRestart(actionState, summaryState, solutionKeys, extraKeys); restartValues = eclIO->loadRestart(actionState, summaryState, solutionKeys, extraKeys);
int packedSize = Mpi::packSize(restartValues, comm);
std::vector<char> buffer(packedSize);
int position=0;
Mpi::pack(restartValues, buffer, position, comm);
comm.broadcast(&position, 1, 0);
comm.broadcast(buffer.data(), position, 0);
std::vector<char> buf2 = summaryState.serialize();
int size = buf2.size();
comm.broadcast(&size, 1, 0);
comm.broadcast(buf2.data(), size, 0);
}
else
{
int bufferSize{};
comm.broadcast(&bufferSize, 1, 0);
std::vector<char> buffer(bufferSize);
comm.broadcast(buffer.data(), bufferSize, 0);
int position{};
Mpi::unpack(restartValues, buffer, position, comm);
comm.broadcast(&bufferSize, 1, 0);
buffer.resize(bufferSize);
comm.broadcast(buffer.data(), bufferSize, 0);
summaryState.deserialize(buffer);
} }
EclMpiSerializer ser(comm);
ser.broadcast(restartValues);
ser.broadcast(summaryState);
return restartValues; return restartValues;
#else #else
(void) comm; (void) comm;