Searched refs:outgoing_messages (Results 1 – 3 of 3) sorted by relevance
| /third_party/boost/boost/graph/distributed/ |
| D | mpi_process_group.hpp | 111 struct outgoing_messages { struct in boost::graph::distributed::mpi_process_group
112 outgoing_messages() {} in outgoing_messages() function
113 ~outgoing_messages() {} in ~outgoing_messages() argument
124 void swap(outgoing_messages& x) in swap() argument
487 void receive_batch(process_id_type source, outgoing_messages& batch) const;
517 void send_batch(process_id_type dest, outgoing_messages& batch) const;
796 swap(boost::graph::distributed::mpi_process_group::outgoing_messages& x, in swap()
797 boost::graph::distributed::mpi_process_group::outgoing_messages& y) in swap()
805 BOOST_CLASS_IMPLEMENTATION(boost::graph::distributed::mpi_process_group::outgoing_messages,object_s…
806 BOOST_CLASS_TRACKING(boost::graph::distributed::mpi_process_group::outgoing_messages,track_never)
|
| /third_party/boost/libs/graph_parallel/src/ |
| D | mpi_process_group.cpp | 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()
[all …]
|
| /third_party/boost/boost/graph/distributed/detail/ |
| D | mpi_process_group.ipp | 46 typedef mpi_process_group::outgoing_messages outgoing_messages;
87 std::vector<outgoing_messages> outgoing;
133 std::queue<std::pair<int,outgoing_messages> > new_batches;
172 impl::outgoing_messages& outgoing = impl_->outgoing[dest];
203 impl::outgoing_messages& outgoing = impl_->outgoing[dest];
252 impl::outgoing_messages& outgoing = impl_->outgoing[dest];
|