else
send_to.emplace_back(m.first);
- const unsigned int n_point_point_communications =
+ const unsigned int n_expected_incoming_messages =
Utilities::MPI::compute_n_point_to_point_communications(comm, send_to);
// Protect the following communication:
// processors, we need to visit one of the two scopes below. Otherwise,
// no other action is required by this mpi process, and we can safely
// return.
- if (send_to.size() == 0 && n_point_point_communications == 0)
+ if (send_to.size() == 0 && n_expected_incoming_messages == 0)
return received_objects;
const int mpi_tag =
{
std::vector<char> buffer;
// We do this on a first come/first served basis
- for (unsigned int i = 0; i < n_point_point_communications; ++i)
+ for (unsigned int i = 0; i < n_expected_incoming_messages; ++i)
{
// Probe what's going on. Take data from the first available sender
MPI_Status status;
# endif // deal.II with MPI
}
+
+
template <typename T>
std::vector<T>
all_gather(const MPI_Comm &comm, const T &object)