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)
122 Parallel::Communication m_comm;
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(T &data, int root=0)
Serialize and broadcast on root process, de-serialize on others.
Definition MPISerializer.hpp:46