| /third_party/boost/boost/graph/distributed/detail/ |
| D | queue.ipp | 12 #include <boost/graph/parallel/process_group.hpp>
25 distributed_queue(const ProcessGroup& process_group, const OwnerMap& owner,
27 : process_group(process_group, attach_distributed_object()),
34 new outgoing_buffers_t(num_processes(process_group)));
41 distributed_queue(const ProcessGroup& process_group, const OwnerMap& owner,
44 : process_group(process_group, attach_distributed_object()),
52 new outgoing_buffers_t(num_processes(process_group)));
59 distributed_queue(const ProcessGroup& process_group, const OwnerMap& owner,
61 : process_group(process_group, attach_distributed_object()),
68 new outgoing_buffers_t(num_processes(process_group)));
[all …]
|
| D | remote_update_set.hpp | 104 receive(self->process_group, source, tag, num_updates); in operator ()()
117 receive(self->process_group, source, msg_updates, &updates[0], in operator ()()
139 : process_group(pg, handle_messages(this, pg)), in remote_update_set()
146 if (get(owner, key) == process_id(process_group)) { in update()
163 send(process_group, p, msg_num_updates, updates[p].size()); in synchronize()
164 send(process_group, p, msg_updates, in synchronize()
170 do_synchronize(process_group); in synchronize()
173 ProcessGroup process_group; member in boost::graph::detail::remote_update_set
212 receive(self->process_group, source, tag, update); in operator ()()
227 : process_group(pg, handle_messages(this, pg)), owner(owner) { } in remote_update_set()
[all …]
|
| /third_party/boost/libs/graph_parallel/test/ |
| D | adjlist_remove_test.cpp | 42 assert(num_processes(g.process_group()) == 2); in test_bidirectional_graph()
44 if (process_id(g.process_group()) == 0) in test_bidirectional_graph()
46 synchronize(g.process_group()); in test_bidirectional_graph()
54 BOOST_CHECK((process_id(g.process_group()) == 0 && out_degree(u, g) == 1) in test_bidirectional_graph()
55 || (process_id(g.process_group()) == 1 && in_degree(u, g) == 1)); in test_bidirectional_graph()
57 BOOST_CHECK((process_id(g.process_group()) == 0 && out_degree(v, g) == 1) in test_bidirectional_graph()
58 || (process_id(g.process_group()) == 1 && in_degree(v, g) == 1)); in test_bidirectional_graph()
60 BOOST_CHECK((process_id(g.process_group()) == 0 && out_degree(w, g) == 1) in test_bidirectional_graph()
61 || (process_id(g.process_group()) == 1 && in_degree(w, g) == 1)); in test_bidirectional_graph()
64 if (process_id(g.process_group()) == 0) { in test_bidirectional_graph()
[all …]
|
| D | distributed_mst_test.cpp | 45 if (process_id(g.process_group()) == 0) { in total_weight()
83 if (process_id(g.process_group()) == 0) in test_distributed_dense_boruvka()
98 if (process_id(g.process_group()) == 0) in test_distributed_dense_boruvka()
106 if (process_id(g.process_group()) == 0) { in test_distributed_dense_boruvka()
114 if (process_id(g.process_group()) == 0) in test_distributed_dense_boruvka()
122 if (process_id(g.process_group()) == 0) { in test_distributed_dense_boruvka()
130 if (process_id(g.process_group()) == 0) in test_distributed_dense_boruvka()
138 if (process_id(g.process_group()) == 0) { in test_distributed_dense_boruvka()
|
| D | distributed_queue_test.cpp | 72 mpi_process_group process_group; in test_distributed_queue() local
80 dist_queue_type Q(process_group, global_value_owner_map()); in test_distributed_queue()
82 mpi_process_group::process_id_type id = process_id(process_group), in test_distributed_queue()
83 n = num_processes(process_group); in test_distributed_queue()
89 synchronize(process_group); in test_distributed_queue()
|
| D | distributed_page_rank_test.cpp | 80 boost::mpi::reduce(communicator(g.process_group()), in test_distributed_page_rank()
82 if (process_id(g.process_group()) == 0) { in test_distributed_page_rank()
92 && owner(v) == process_id(g.process_group())) { in test_distributed_page_rank()
|
| /third_party/boost/boost/graph/distributed/ |
| D | queue.hpp | 120 distributed_queue(const ProcessGroup& process_group,
132 distributed_queue(const ProcessGroup& process_group = ProcessGroup(),
144 distributed_queue(const ProcessGroup& process_group, const OwnerMap& owner,
224 mutable ProcessGroup process_group; member in boost::graph::distributed::distributed_queue
262 make_distributed_queue(const ProcessGroup& process_group, in make_distributed_queue() argument
268 return result_type(process_group, owner, buffer, polling); in make_distributed_queue()
|
| D | local_subgraph.hpp | 75 return get(owner, v) == process_id(process_group(*g)); in operator ()()
126 process_group_type& process_group() in process_group() function in boost::local_subgraph
128 using boost::graph::parallel::process_group; in process_group()
129 return process_group(g); in process_group()
131 const process_group_type& process_group() const in process_group() function in boost::local_subgraph
133 using boost::graph::parallel::process_group; in process_group()
134 return boost::graph::parallel::process_group(g); in process_group()
|
| D | named_graph.hpp | 257 process_group_type& process_group() { return process_group_; } in process_group() function in boost::graph::distributed::named_graph
258 const process_group_type& process_group() const { return process_group_; } in process_group() function in boost::graph::distributed::named_graph
385 if (owner == process_id(self.process_group())) in ~lazy_add_vertex()
390 send(self.process_group(), owner, msg_add_vertex_name, name); in ~lazy_add_vertex()
402 if (owner == process_id(self.process_group())) in commit()
409 send_oob_with_reply(self.process_group(), owner, in commit()
501 send(self.process_group(), self.distribution_(*v_name), in ~lazy_add_edge()
505 send(self.process_group(), self.distribution_(*v_name), in ~lazy_add_edge()
513 send(self.process_group(), self.distribution_(*u_name), in ~lazy_add_edge()
543 process_id_type rank = process_id(self.process_group()); in commit()
[all …]
|
| D | graphviz.hpp | 39 out << " label=\"p" << process_id(g.process_group()) << "\";\n"; in operator ()()
122 using boost::graph::parallel::process_group; in write_graphviz()
123 process_group_type pg = process_group(g); in write_graphviz()
224 if (process_id(g.process_group()) == 0) { in write_graphviz()
241 if (process_id(g.process_group()) == 0) { in write_graphviz()
256 if (process_id(g.process_group()) == 0) { in write_graphviz()
269 if (process_id(g.process_group()) == 0) { in write_graphviz()
|
| D | reverse_graph.hpp | 33 process_group(reverse_graph<Graph, GraphRef> const& g) { in process_group() function
34 return process_group(g.m_g); in process_group()
|
| D | dehne_gotz_min_spanning_tree.hpp | 546 using boost::graph::parallel::process_group; in dense_boruvka_minimum_spanning_tree()
590 out = detail::boruvka_merge_step(process_group(g), g, in dense_boruvka_minimum_spanning_tree()
638 using boost::graph::parallel::process_group; in merge_local_minimum_spanning_trees()
663 typename process_group_type<Graph>::type pg = process_group(g); in merge_local_minimum_spanning_trees()
677 synchronize(process_group(g)); in merge_local_minimum_spanning_trees()
703 using boost::graph::parallel::process_group; in boruvka_then_merge()
740 double log_d_p = log((double)num_processes(process_group(g))) in boruvka_then_merge()
747 out = detail::boruvka_merge_step(process_group(g), g, in boruvka_then_merge()
761 typename process_group_type<Graph>::type pg = process_group(g); in boruvka_then_merge()
780 synchronize(process_group(g)); in boruvka_then_merge()
[all …]
|
| D | filtered_graph.hpp | 38 process_group(filtered_graph<Graph, EdgePredicate, VertexPredicate> const& g) { in process_group() function
39 return process_group(g.m_g); in process_group()
|
| D | page_rank.hpp | 100 process_group_type pg = process_group(g); in page_rank_impl()
142 synchronize(boost::graph::parallel::process_group(g)); in page_rank_impl()
175 using boost::graph::parallel::process_group; in page_rank_impl()
176 synchronize(process_group(g)); in page_rank_impl()
|
| D | strong_components.hpp | 185 using boost::graph::parallel::process_group; in fleischer_hendrickson_pinar_strong_components()
186 process_group_type pg = process_group(g); in fleischer_hendrickson_pinar_strong_components()
369 queue_t Q(process_group(g), in fleischer_hendrickson_pinar_strong_components()
376 rev_queue_t Qr(process_group(gr), in fleischer_hendrickson_pinar_strong_components()
735 process_group_type pg = process_group(g); in build_reverse_graph()
817 all_gather( process_group(g), my_roots.begin(), my_roots.end(), all_roots ); in number_components()
833 if (process_id(process_group(g)) == 0) { in number_components()
836 for (process_size_type dest = 1, n = num_processes(process_group(g)); in number_components()
838 send(process_group(g), dest, 0, c_num); in number_components()
841 synchronize(process_group(g)); in number_components()
[all …]
|
| D | crauser_et_al_shortest_paths.hpp | 235 : inherited(boost::graph::parallel::process_group(g), get(vertex_owner, g)), in crauser_et_al_dijkstra_queue()
321 all_reduce(this->process_group, local_distances, local_distances + 2, in do_synchronize()
328 all_reduce(this->process_group, &local_deletions, &local_deletions + 1, in do_synchronize()
330 if (process_id(this->process_group) == 0) { in do_synchronize()
373 && source == process_id(this->process_group))) { in receive_update()
441 using boost::graph::parallel::process_group; in initialize_min_in_weights()
442 synchronize(process_group(g)); in initialize_min_in_weights()
|
| /third_party/boost/boost/property_map/parallel/ |
| D | distributed_property_map.hpp | 330 data->process_group.replace_handler(handler, true); in distributed_property_map()
331 data->process_group.template get_receiver<Handler>() in distributed_property_map()
332 ->setup_triggers(data->process_group); in distributed_property_map()
374 if (p.first == process_id(data->process_group)) { in operator []()
381 process_group_type process_group() const in process_group() function in boost::parallel::distributed_property_map
383 return data->process_group.base(); in process_group()
396 send(data->process_group, p, property_map_put, in request_put()
418 : process_group(pg), global(global), storage(pm), in data_t()
423 ProcessGroup process_group; member
555 if (get(pm.data->global, key).first != process_id(pm.data->process_group)) in request()
[all …]
|
| D | local_property_map.hpp | 39 local_property_map(const ProcessGroup& process_group, in local_property_map() argument
41 : process_group_(process_group), global_(global), storage(storage) { } in local_property_map()
53 ProcessGroup& process_group() { return process_group_; } in process_group() function in boost::local_property_map
54 const ProcessGroup& process_group() const { return process_group_; } in process_group() function in boost::local_property_map
83 BOOST_ASSERT(p.first == process_id(pm.process_group())); in put()
|
| D | vector_property_map.hpp | 49 : inherited(index.process_group(), index.global(), in vector_property_map()
54 : inherited(index.process_group(), index.global(), in vector_property_map()
93 : inherited(index.process_group(), index.global(), in vector_property_map()
98 : inherited(index.process_group(), index.global(), in vector_property_map()
|
| D | parallel_property_maps.hpp | 72 : inherited(id.process_group(), id.global(), in iterator_property_map()
115 : inherited(id.process_group(), id.global(), in iterator_property_map()
136 return result_type(index_map.process_group(), index_map.global(), in make_iterator_property_map()
179 : inherited(id.process_group(), id.global(), in safe_iterator_property_map()
222 : inherited(id.process_group(), id.global(), in safe_iterator_property_map()
|
| /third_party/boost/boost/property_map/parallel/impl/ |
| D | distributed_property_map.ipp | 30 data->process_group.replace_handler(Handler(data, reduce));
31 data->process_group.template get_receiver<Handler>()
32 ->setup_triggers(data->process_group);
44 data->process_group.replace_handler(Handler(data, reduce));
45 Handler* handler = data->process_group.template get_receiver<Handler>();
47 handler->setup_triggers(data->process_group);
68 send(data->process_group, get(data->global, victim.first).first,
96 send_oob_with_reply(data->process_group, get(data->global, key).first,
136 BOOST_ASSERT(p.first == process_id(data->process_group));
181 send(data->process_group, source, property_map_multiget_reply, results);
[all …]
|
| /third_party/boost/boost/graph/parallel/ |
| D | container_traits.hpp | 30 process_group(const T& x) in process_group() function
31 { return x.process_group(); } in process_group()
39 return process_group(container); in process_group_adl()
|
| /third_party/boost/libs/log/test/run/ |
| D | util_ipc_object_name.cpp | 81 …std::cout << boost::log::ipc::object_name(boost::log::ipc::object_name::process_group, test_object… in BOOST_AUTO_TEST_CASE()
110 …boost::log::ipc::object_name name1(boost::log::ipc::object_name::process_group, test_object_name1); in BOOST_AUTO_TEST_CASE()
111 …boost::log::ipc::object_name name2(boost::log::ipc::object_name::process_group, test_object_name1); in BOOST_AUTO_TEST_CASE()
132 …boost::log::ipc::object_name name1(boost::log::ipc::object_name::process_group, test_object_name1); in BOOST_AUTO_TEST_CASE()
133 …boost::log::ipc::object_name name2(boost::log::ipc::object_name::process_group, test_object_name2); in BOOST_AUTO_TEST_CASE()
150 …boost::log::ipc::object_name name2(boost::log::ipc::object_name::process_group, test_object_name1); in BOOST_AUTO_TEST_CASE()
160 …boost::log::ipc::object_name name2(boost::log::ipc::object_name::process_group, test_object_name1); in BOOST_AUTO_TEST_CASE()
165 …boost::log::ipc::object_name name2(boost::log::ipc::object_name::process_group, test_object_name1); in BOOST_AUTO_TEST_CASE()
|
| /third_party/boost/libs/graph_parallel/doc/ |
| D | distributed_queue.rst | 22 distributed_queue(const ProcessGroup& process_group = ProcessGroup(),
26 distributed_queue(const ProcessGroup& process_group, bool polling);
38 make_distributed_queue(const ProcessGroup& process_group, const Buffer& buffer,
106 distributed_queue(const ProcessGroup& process_group = ProcessGroup(),
111 ``process_group``, whose local queue is initialized via ``buffer`` and
118 distributed_queue(const ProcessGroup& process_group, bool polling);
121 ``process_group``, whose local queue is default-initalized and which
193 make_distributed_queue(const ProcessGroup& process_group, const Buffer& buffer,
|
| /third_party/boost/libs/graph_parallel/example/ |
| D | dijkstra_shortest_paths.cpp | 87 if (process_id(process_group(g)) == 0) { in main()
94 if (process_id(process_group(g)) == 0) in main()
|