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

Merge pull request #4080 from akva2/parallelrestart_serializer

Browse Source 
ParallelRestart: use eclmpiserializer
This commit is contained in:
Bård Skaflestad 2022-09-06 12:51:24 +02:00 committed by GitHub
commit 6b9cb43ac7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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 <ctime>
#include <memory>
#include <dune/common/parallel/mpitraits.hh>
#include <ebos/eclmpiserializer.hh>
#include <opm/output/data/Aquifer.hpp>
#include <opm/output/data/Cells.hpp>
#include <opm/output/data/Groups.hpp>
@ -1407,30 +1409,11 @@ RestartValue loadParallelRestart(const EclipseIO* eclIO, Action::State& actionSt
{
assert(comm.rank() == 0);
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;
#else
(void) comm;