| /third_party/boost/boost/graph/distributed/ |
| D | mpi_process_group.hpp | 40 class mpi_process_group class
155 receive(mpi_process_group const& pg, int source, int tag,
172 explicit trigger_launcher(mpi_process_group& self, int tag, in trigger_launcher()
178 receive(mpi_process_group const& pg, int source, int tag,
182 mpi_process_group& self;
195 explicit reply_trigger_launcher(mpi_process_group& self, int tag, in reply_trigger_launcher()
201 receive(mpi_process_group const& pg, int source, int tag,
205 mpi_process_group& self;
213 explicit global_trigger_launcher(mpi_process_group& self, int tag, in global_trigger_launcher()
220 receive(mpi_process_group const& pg, int source, int tag,
[all …]
|
| /third_party/boost/libs/graph_parallel/doc/ |
| D | mpi_bsp_process_group.rst | 15 The MPI ``mpi_process_group`` is an implementation of the `process
22 Header ``<boost/graph/distributed/mpi_process_group.hpp>``
31 class mpi_process_group
37 mpi_process_group(communicator_type comm = communicator_type());
38 mpi_process_group(std::size_t num_headers, std::size_t buffer_size,
41 mpi_process_group();
42 mpi_process_group(const mpi_process_group&, boost::parallel::attach_distributed_object);
55 mpi_process_group base() const;
59 int process_id(const mpi_process_group&);
60 int num_processes(const mpi_process_group&);
[all …]
|
| D | sorted_unique_rmat_generator.rst | 85 #include <boost/graph/distributed/mpi_process_group.hpp>
90 using boost::graph::distributed::mpi_process_group;
93 distributedS<mpi_process_group> > Graph;
94 typedef keep_local_edges<boost::parallel::variant_distribution<mpi_process_group>,
95 mpi_process_group::process_id_type> EdgeFilter;
101 mpi_process_group pg;
108 mpi_process_group::process_id_type id = process_id(pg);
|
| D | scalable_rmat_generator.rst | 78 #include <boost/graph/distributed/mpi_process_group.hpp>
83 using boost::graph::distributed::mpi_process_group;
86 distributedS<mpi_process_group> > Graph;
92 mpi_process_group pg;
|
| /third_party/boost/libs/graph_parallel/src/ |
| D | mpi_process_group.cpp | 48 struct mpi_process_group::deallocate_block
73 mpi_process_group::impl::incoming_messages::incoming_messages() in incoming_messages()
78 mpi_process_group::impl::impl(std::size_t num_headers, std::size_t buffer_sz, in impl()
120 void mpi_process_group::impl::set_batch_size(std::size_t header_num, std::size_t buffer_sz) in set_batch_size()
135 mpi_process_group::impl::~impl() in ~impl()
147 void handle_batch (mpi_process_group const& self, int source, int, in handle_batch()
148 mpi_process_group::outgoing_messages& batch,bool out_of_band) in handle_batch()
170 void handle_sync (mpi_process_group const& self, int source, int tag, int val, in handle_sync()
210 mpi_process_group::mpi_process_group(communicator_type parent_comm) in mpi_process_group() function in boost::graph::distributed::mpi_process_group
232 mpi_process_group::mpi_process_group(std::size_t h, std::size_t sz, in mpi_process_group() function in boost::graph::distributed::mpi_process_group
[all …]
|
| /third_party/boost/boost/graph/distributed/detail/ |
| D | mpi_process_group.ipp | 42 struct mpi_process_group::impl
45 typedef mpi_process_group::message_header message_header;
46 typedef mpi_process_group::outgoing_messages outgoing_messages;
160 inline trigger_receive_context mpi_process_group::trigger_context() const
167 mpi_process_group::send_impl(int dest, int tag, const T& value,
198 mpi_process_group::send_impl(int dest, int tag, const T& value,
228 send(const mpi_process_group& pg, mpi_process_group::process_id_type dest,
237 send(const mpi_process_group& pg, mpi_process_group::process_id_type dest,
247 mpi_process_group::
280 send(const mpi_process_group& pg, mpi_process_group::process_id_type dest,
[all …]
|
| /third_party/boost/libs/graph_parallel/test/ |
| D | distributed_rmat_cc.cpp | 39 using boost::graph::distributed::mpi_process_group;
58 mpi_process_group pg; in test_filtered_rmat_cc()
59 mpi_process_group::process_id_type id = process_id(pg); in test_filtered_rmat_cc()
64 parallel::variant_distribution<mpi_process_group> distrib in test_filtered_rmat_cc()
68 distributedS<mpi_process_group, vecS>, in test_filtered_rmat_cc()
71 typedef keep_local_edges<parallel::variant_distribution<mpi_process_group>, in test_filtered_rmat_cc()
72 mpi_process_group::process_id_type> in test_filtered_rmat_cc()
|
| D | distributed_rmat_pagerank.cpp | 39 using boost::graph::distributed::mpi_process_group;
58 mpi_process_group pg; in test_filtered_rmat_pagerank()
64 typedef parallel::variant_distribution<mpi_process_group> Distribution; in test_filtered_rmat_pagerank()
68 distributedS<mpi_process_group, vecS>, in test_filtered_rmat_pagerank()
71 typedef scalable_rmat_iterator<mpi_process_group, Distribution, rand48, Graph> in test_filtered_rmat_pagerank()
|
| D | distributed_dimacs_reader.cpp | 37 using boost::graph::distributed::mpi_process_group;
56 mpi_process_group pg; in test_dimacs_reader()
59 distributedS<mpi_process_group, vecS>, in test_dimacs_reader()
65 boost::parallel::variant_distribution<mpi_process_group> distrib = in test_dimacs_reader()
|
| D | distributed_rmat_cc_ps.cpp | 39 using boost::graph::distributed::mpi_process_group;
58 mpi_process_group pg; in test_filtered_rmat_cc()
64 typedef parallel::variant_distribution<mpi_process_group> Distribution; in test_filtered_rmat_cc()
68 distributedS<mpi_process_group, vecS>, in test_filtered_rmat_cc()
71 typedef scalable_rmat_iterator<mpi_process_group, Distribution, rand48, Graph> in test_filtered_rmat_cc()
|
| D | distributed_queue_test.cpp | 30 using boost::graph::distributed::mpi_process_group;
72 mpi_process_group process_group; in test_distributed_queue()
76 typedef boost::graph::distributed::distributed_queue<mpi_process_group, in test_distributed_queue()
82 mpi_process_group::process_id_type id = process_id(process_group), in test_distributed_queue()
|
| D | distributed_strong_components_test.cpp | 64 using boost::graph::distributed::mpi_process_group;
71 distributedS<mpi_process_group> > Graph; in test_distributed_strong_components()
74 distributedS<mpi_process_group, vecS>, in test_distributed_strong_components()
82 mpi_process_group pg; in test_distributed_strong_components()
83 parallel::variant_distribution<mpi_process_group> distrib in test_distributed_strong_components()
|
| D | distributed_csr_test.cpp | 35 using boost::graph::distributed::mpi_process_group;
40 distributedS<mpi_process_group> > in concept_checks()
86 distributedS<mpi_process_group> > in test_main()
|
| D | algorithm_performance.cpp | 48 using boost::graph::distributed::mpi_process_group;
348 distributedS<mpi_process_group> > Graph; in test_csr()
383 distributedS<mpi_process_group> > Graph; in test_csr()
419 distributedS<mpi_process_group> > Graph; in test_csr()
455 distributedS<mpi_process_group> > Graph; in test_csr()
494 typedef adjacency_list<vecS, distributedS<mpi_process_group, vecS>, in test_adjacency_list()
506 typedef adjacency_list<vecS, distributedS<mpi_process_group, vecS>, in test_adjacency_list()
555 typedef adjacency_list<vecS, distributedS<mpi_process_group, vecS>, in test_adjacency_list()
567 typedef adjacency_list<vecS, distributedS<mpi_process_group, vecS>, in test_adjacency_list()
616 typedef adjacency_list<vecS, distributedS<mpi_process_group, vecS>, in test_adjacency_list()
[all …]
|
| D | distributed_property_map_test.cpp | 33 using boost::graph::distributed::mpi_process_group;
96 mpi_process_group pg; in colored_test()
114 typedef boost::parallel::distributed_property_map<mpi_process_group, in colored_test()
181 mpi_process_group pg; in bool_test()
199 typedef boost::parallel::distributed_property_map<mpi_process_group, in bool_test()
266 mpi_process_group pg; in string_test()
284 typedef boost::parallel::distributed_property_map<mpi_process_group, in string_test()
|
| D | distributed_connected_components_test.cpp | 42 using boost::graph::distributed::mpi_process_group;
74 distributedS<mpi_process_group> > Graph; in test_distributed_connected_components()
80 mpi_process_group pg; in test_distributed_connected_components()
81 parallel::variant_distribution<mpi_process_group> distrib in test_distributed_connected_components()
|
| D | named_vertices_test.cpp | 27 using boost::graph::distributed::mpi_process_group;
66 typedef boost::adjacency_list<vecS, distributedS<mpi_process_group, vecS>,
76 int rank = process_id(mpi_process_group()); in test_main()
|
| D | adjlist_redist_test.cpp | 39 using boost::graph::distributed::mpi_process_group;
118 mpi_process_group pg = g.process_group(); in test_redistribution()
195 distributedS<mpi_process_group, vecS>, in test_main()
203 distributedS<mpi_process_group, listS>, in test_main()
|
| D | process_group_serialization.cpp | 30 using boost::graph::distributed::mpi_process_group;
36 mpi_process_group pg; in test_main()
|
| D | named_vertices_hash_test.cpp | 28 using boost::graph::distributed::mpi_process_group;
102 distributedS<mpi_process_group, vecS, hasher_type>,
110 mpi_process_group pg; in test_main()
|
| D | distributed_graph_coloring_test.cpp | 36 using boost::graph::distributed::mpi_process_group;
43 distributedS<mpi_process_group, vecS>, in test_distributed_graph_coloring()
|
| D | distributed_adjacency_list_test.cpp | 31 using boost::graph::distributed::mpi_process_group;
46 mpi_process_group pg; in test_main()
49 typedef adjacency_list<listS, distributedS<mpi_process_group, vecS>, in test_main()
51 typedef adjacency_list<listS, distributedS<mpi_process_group, vecS>, in test_main()
53 typedef adjacency_list<listS, distributedS<mpi_process_group, vecS>, in test_main()
|
| D | adjlist_remove_test.cpp | 30 using boost::graph::distributed::mpi_process_group;
34 typedef adjacency_list<listS, distributedS<mpi_process_group, vecS>, in test_bidirectional_graph()
87 typedef adjacency_list<listS, distributedS<mpi_process_group, vecS>, in test_undirected_graph()
|
| /third_party/boost/libs/graph_parallel/example/ |
| D | dijkstra_shortest_paths.cpp | 44 using boost::graph::distributed::mpi_process_group;
48 typedef adjacency_list<vecS, distributedS<mpi_process_group, vecS>, undirectedS,
|
| D | breadth_first_search.cpp | 47 using boost::graph::distributed::mpi_process_group;
50 typedef adjacency_list<vecS, distributedS<mpi_process_group, vecS>, undirectedS,
|