Lines Matching refs:outgoing_messages
126 outgoing_messages msg; in set_batch_size()
130 oa << const_cast<const outgoing_messages&>(msg); in set_batch_size()
148 mpi_process_group::outgoing_messages& batch,bool out_of_band) in handle_batch()
215 global_trigger<outgoing_messages>(msg_batch,&detail::handle_batch); in mpi_process_group()
217 global_trigger<outgoing_messages>(msg_batch,&detail::handle_batch, in mpi_process_group()
220 global_trigger<outgoing_messages>(msg_large_batch,&detail::handle_batch); in mpi_process_group()
237 global_trigger<outgoing_messages>(msg_batch,&detail::handle_batch); in mpi_process_group()
239 global_trigger<outgoing_messages>(msg_batch,&detail::handle_batch, in mpi_process_group()
242 global_trigger<outgoing_messages>(msg_large_batch,&detail::handle_batch); in mpi_process_group()
481 impl::outgoing_messages& outgoing = impl_->outgoing[dest]; in maybe_send_batch()
485 outgoing_messages batch; in maybe_send_batch()
506 impl::outgoing_messages& outgoing = impl_->outgoing[dest]; in send_batch()
509 outgoing_messages batch; in send_batch()
519 outgoing_messages& outgoing) const in send_batch()
649 outgoing_messages& new_messages) const in receive_batch()
678 impl_->new_batches.push(std::make_pair(int(source),outgoing_messages())); in receive_batch()
721 outgoing_messages batch; in receive_batch()