21#ifndef MPI_SERIALIZER_HPP
22#define MPI_SERIALIZER_HPP
24#include <opm/common/utility/Serializer.hpp>
34 : Serializer<Mpi::Packer>(m_packer)
48 if (m_comm.size() == 1)
51 if (m_comm.rank() == root) {
54 m_comm.broadcast(&m_packSize, 1, root);
55 m_comm.broadcast(m_buffer.data(), m_packSize, root);
57 m_packSize = std::numeric_limits<size_t>::max();
58 m_comm.broadcast(&m_packSize, 1, root);
62 m_comm.broadcast(&m_packSize, 1, root);
63 if (m_packSize == std::numeric_limits<size_t>::max()) {
64 throw std::runtime_error(
"Error detected in parallel serialization");
67 m_buffer.resize(m_packSize);
68 m_comm.broadcast(m_buffer.data(), m_packSize, root);
73 template<
typename... Args>
76 if (m_comm.size() == 1)
79 if (m_comm.rank() == root) {
81 this->
pack(std::forward<Args>(args)...);
82 m_comm.broadcast(&m_packSize, 1, root);
83 m_comm.broadcast(m_buffer.data(), m_packSize, root);
85 m_packSize = std::numeric_limits<size_t>::max();
86 m_comm.broadcast(&m_packSize, 1, root);
90 m_comm.broadcast(&m_packSize, 1, root);
91 if (m_packSize == std::numeric_limits<size_t>::max()) {
92 throw std::runtime_error(
"Error detected in parallel serialization");
94 m_buffer.resize(m_packSize);
95 m_comm.broadcast(m_buffer.data(), m_packSize, root);
96 this->unpack(std::forward<Args>(args)...);
109 if (m_comm.size() == 1)
113 T& bcast = m_comm.rank() == root ? data : tmp;
116 if (m_comm.rank() != root)
Class for serializing and broadcasting data using MPI.
Definition: MPISerializer.hpp:31
void append(T &data, int root=0)
Serialize and broadcast on root process, de-serialize and append on others.
Definition: MPISerializer.hpp:107
void broadcast(int root, Args &&... args)
Definition: MPISerializer.hpp:74
MpiSerializer(Parallel::Communication comm)
Definition: MPISerializer.hpp:33
void broadcast(T &data, int root=0)
Serialize and broadcast on root process, de-serialize on others.
Definition: MPISerializer.hpp:46
std::size_t pack(const PV &privar)
Definition: priVarsPacking.hpp:31
Definition: MPISerializer.hpp:28
Dune::Communication< MPIComm > Communication
Definition: ParallelCommunication.hpp:30
Struct handling packing of serialization for MPI communication.
Definition: MPIPacker.hpp:175