33 #ifndef __H__pcl_multi_group_communicator
34 #define __H__pcl_multi_group_communicator
68 void allreduce (
const T *sendBuf, T *recvBuf,
communicator for simultaneous data exchange between many small groups
Definition: pcl_multi_group_communicator.h:49
bool participates(size_t igrp) const
Definition: pcl_multi_group_communicator.cpp:138
std::vector< bool > m_participates
size: #groups
Definition: pcl_multi_group_communicator.h:73
MultiGroupCommunicator(ProcessCommunicator com=ProcessCommunicator())
Definition: pcl_multi_group_communicator.cpp:41
size_t membership_group_index(size_t imem) const
Definition: pcl_multi_group_communicator.cpp:158
std::vector< int > m_groupMembers
size: m_groupOffsets.back(). Consecutively holds proc-indices of each group in which the process part...
Definition: pcl_multi_group_communicator.h:75
size_t num_groups() const
Definition: pcl_multi_group_communicator.cpp:145
std::vector< size_t > m_memberships
size: #memberships. Holds indices to groups in which the process participates
Definition: pcl_multi_group_communicator.h:74
ProcessCommunicator m_com
Definition: pcl_multi_group_communicator.h:72
std::map< int, ug::BinaryBuffer > m_binBufs
used for sending/receiving data from/to processes
Definition: pcl_multi_group_communicator.h:77
std::vector< size_t > m_groupOffsets
size: #memberships+1. Offset of each group in m_groupMembers. The last entry always holds m_groupMemb...
Definition: pcl_multi_group_communicator.h:76
void allreduce(const T *sendBuf, T *recvBuf, size_t countPerGroup, ReduceOperation op) const
performs an allreduce between all groups
Definition: pcl_multi_group_communicator_impl.hpp:44
void reinit(const std::vector< bool > &participates)
Definition: pcl_multi_group_communicator.cpp:56
size_t num_memberships() const
Definition: pcl_multi_group_communicator.cpp:152
Definition: pcl_process_communicator.h:70
MPI_Op ReduceOperation
Definition: pcl_methods.h:74
Definition: parallel_grid_layout.h:46