| /third_party/boost/boost/mpi/ |
| D | collectives.hpp | 52 all_gather(const communicator& comm, const T& in_value,
60 all_gather(const communicator& comm, const T& in_value, T* out_values);
67 all_gather(const communicator& comm, const T* in_values, int n,
75 all_gather(const communicator& comm, const T* in_values, int n, T* out_values);
128 all_reduce(const communicator& comm, const T* value, int n, T* out_value,
135 all_reduce(const communicator& comm, const T& value, T& out_value, Op op);
140 T all_reduce(const communicator& comm, const T& value, Op op);
147 all_reduce(const communicator& comm, inplace_t<T*> value, int n,
154 all_reduce(const communicator& comm, inplace_t<T> value, Op op);
183 all_to_all(const communicator& comm, const std::vector<T>& in_values,
[all …]
|
| D | communicator.hpp | 134 class BOOST_MPI_DECL communicator class
144 communicator();
175 communicator(const MPI_Comm& comm, comm_create_kind kind);
190 communicator(const communicator& comm, const boost::mpi::group& subgroup);
816 communicator split(int color, int key) const;
817 communicator split(int color) const;
1130 BOOST_MPI_DECL bool operator==(const communicator& comm1, const communicator& comm2);
1137 inline bool operator!=(const communicator& comm1, const communicator& comm2) in operator !=()
1156 communicator::send<packed_oarchive>(int dest, int tag,
1164 communicator::send<packed_skeleton_oarchive>
[all …]
|
| D | request.hpp | 24 class communicator;
45 static request make_trivial_send(communicator const& comm, int dest, int tag, T const& value);
47 …static request make_trivial_send(communicator const& comm, int dest, int tag, T const* values, int…
48 …static request make_packed_send(communicator const& comm, int dest, int tag, void const* values, s…
50 static request make_bottom_send(communicator const& comm, int dest, int tag, MPI_Datatype tp);
51 static request make_empty_send(communicator const& comm, int dest, int tag);
56 static request make_trivial_recv(communicator const& comm, int dest, int tag, T& value);
58 static request make_trivial_recv(communicator const& comm, int dest, int tag, T* values, int n);
60 static request make_bottom_recv(communicator const& comm, int dest, int tag, MPI_Datatype tp);
61 static request make_empty_recv(communicator const& comm, int dest, int tag);
[all …]
|
| D | intercommunicator.hpp | 50 class BOOST_MPI_DECL intercommunicator : public communicator
53 friend class communicator;
96 : communicator(comm, kind) { } in intercommunicator()
116 intercommunicator(const communicator& local, int local_leader,
117 const communicator& peer, int remote_leader);
160 communicator merge(bool high) const;
|
| /third_party/boost/libs/mpi/src/ |
| D | communicator.cpp | 16 communicator::communicator() in communicator() function in boost::mpi::communicator
21 communicator::communicator(const MPI_Comm& comm, comm_create_kind kind) in communicator() function in boost::mpi::communicator
47 communicator::communicator(const communicator& comm, in communicator() function in boost::mpi::communicator
57 int communicator::size() const in size()
64 int communicator::rank() const in rank()
71 boost::mpi::group communicator::group() const in group()
78 void communicator::send(int dest, int tag) const in send()
85 status communicator::recv(int source, int tag) const in recv()
94 optional<status> communicator::iprobe(int source, int tag) const in iprobe()
107 status communicator::probe(int source, int tag) const in probe()
[all …]
|
| D | broadcast.cpp | 20 broadcast<const packed_oarchive>(const communicator& comm, in broadcast()
46 broadcast<packed_oarchive>(const communicator& comm, packed_oarchive& oa, in broadcast()
54 broadcast<packed_iarchive>(const communicator& comm, packed_iarchive& ia, in broadcast()
82 broadcast<const packed_skeleton_oarchive>(const communicator& comm, in broadcast()
91 broadcast<packed_skeleton_oarchive>(const communicator& comm, in broadcast()
99 broadcast<packed_skeleton_iarchive>(const communicator& comm, in broadcast()
106 void broadcast<content>(const communicator& comm, content& c, int root) in broadcast()
112 void broadcast<const content>(const communicator& comm, const content& c, in broadcast()
|
| /third_party/boost/libs/mpi/src/python/ |
| D | py_communicator.cpp | 40 communicator_recv(const communicator& comm, int source, int tag, in communicator_recv()
54 communicator_irecv(const communicator& comm, int source, int tag) in communicator_irecv()
63 communicator_iprobe(const communicator& comm, int source, int tag) in communicator_iprobe()
71 extern void export_skeleton_and_content(class_<communicator>&);
78 class_<communicator> comm("Communicator", communicator_docstring); in export_communicator()
81 .add_property("rank", &communicator::rank, communicator_rank_docstring) in export_communicator()
82 .add_property("size", &communicator::size, communicator_size_docstring) in export_communicator()
84 (void (communicator::*)(int, int, const object&) const) in export_communicator()
85 &communicator::send<object>, in export_communicator()
93 (request (communicator::*)(int, int, const object&) const) in export_communicator()
[all …]
|
| D | collectives.cpp | 32 object all_gather(const communicator& comm, object value) in all_gather()
43 object all_to_all(const communicator& comm, object in_values) in all_to_all()
60 object broadcast(const communicator& comm, object value, int root) in broadcast()
66 object gather(const communicator& comm, object value, int root) in gather()
82 object reduce(const communicator& comm, object value, object op, int root) in reduce()
94 object scatter(const communicator& comm, object values, int root) in scatter()
116 (object (*)(const communicator&, const object&, object))&all_reduce, in export_collectives()
117 (arg("comm") = communicator(), arg("value"), arg("op")), in export_collectives()
120 (arg("comm") = communicator(), arg("value") = object()), in export_collectives()
123 (arg("comm") = communicator(), arg("values") = object()), in export_collectives()
[all …]
|
| /third_party/boost/libs/mpi/doc/ |
| D | communicator.qbk | 4 Communication with Boost.MPI always occurs over a communicator. A
5 communicator contains a set of processes that can send messages among
11 When the MPI environment is initialized, only the "world" communicator
13 available. The "world" communicator, accessed by default-constructing
14 a [classref boost::mpi::communicator mpi::communicator]
17 duplicating or building subsets of the "world" communicator. For
30 void generate_data(mpi::communicator local, mpi::communicator world);
31 void collect_data(mpi::communicator local, mpi::communicator world);
36 mpi::communicator world;
39 mpi::communicator local = world.split(is_generator? 0 : 1);
[all …]
|
| D | c_mapping.qbk | 46 [[memberref boost::mpi::communicator::iprobe `communicator::iprobe`]]]
53 [[memberref boost::mpi::communicator::isend
54 `communicator::isend`]]]
61 [[memberref boost::mpi::communicator::isend
62 `communicator::irecv`]]]
66 [[memberref boost::mpi::communicator::probe `communicator::probe`]]]
72 [[memberref boost::mpi::communicator::recv
73 `communicator::recv`]]]
89 [[memberref boost::mpi::communicator::send
90 `communicator::send`]]]
[all …]
|
| /third_party/mindspore/mindspore/ccsrc/ps/ |
| D | CMakeLists.txt | 9 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/http_message_handler.cc")
10 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/http_server.cc")
12 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/tcp_client.cc")
13 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/tcp_message_handler.cc")
14 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/tcp_server.cc")
22 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/http_client.cc")
25 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/http_request_handler.cc")
26 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/ssl_wrapper.cc")
27 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/ssl_http.cc")
28 list(REMOVE_ITEM _PS_SRC_FILES "core/communicator/ssl_client.cc")
[all …]
|
| /third_party/boost/boost/mpi/collectives/ |
| D | broadcast.hpp | 27 broadcast<const packed_oarchive>(const communicator& comm,
36 broadcast<packed_oarchive>(const communicator& comm, packed_oarchive& oa,
44 broadcast<packed_iarchive>(const communicator& comm, packed_iarchive& ia,
52 broadcast<const packed_skeleton_oarchive>(const communicator& comm,
61 broadcast<packed_skeleton_oarchive>(const communicator& comm,
69 broadcast<packed_skeleton_iarchive>(const communicator& comm,
76 void broadcast<content>(const communicator& comm, content& c, int root);
82 void broadcast<const content>(const communicator& comm, const content& c,
93 broadcast_impl(const communicator& comm, T* values, int n, int root, in broadcast_impl()
106 broadcast_impl(const communicator& comm, T* values, int n, int root, in broadcast_impl()
[all …]
|
| D | scatterv.hpp | 28 scatterv_impl(const communicator& comm, const T* in_values, T* out_values, int out_size, in scatterv_impl()
47 scatterv_impl(const communicator& comm, T* out_values, int out_size, int root, in scatterv_impl()
62 scatterv_impl(const communicator& comm, const T* in_values, T* out_values, int out_size, in scatterv_impl()
88 scatterv_impl(const communicator& comm, T* out_values, int n, int root, in scatterv_impl()
99 scatterv(const communicator& comm, const T* in_values, in scatterv()
110 scatterv(const communicator& comm, const std::vector<T>& in_values, in scatterv()
120 void scatterv(const communicator& comm, T* out_values, int out_size, int root) in scatterv()
131 scatterv(const communicator& comm, const T* in_values, in scatterv()
142 scatterv(const communicator& comm, const std::vector<T>& in_values, in scatterv()
150 scatterv(const communicator& comm, const T* in_values, in scatterv()
[all …]
|
| D | scatter.hpp | 30 scatter_impl(const communicator& comm, const T* in_values, T* out_values, in scatter_impl()
43 scatter_impl(const communicator& comm, T* out_values, int n, int root, in scatter_impl()
62 fill_scatter_sendbuf(const communicator& comm, T const* values, in fill_scatter_sendbuf()
96 dispatch_scatter_sendbuf(const communicator& comm, in dispatch_scatter_sendbuf()
133 scatter_impl(const communicator& comm, const T* in_values, T* out_values, in scatter_impl()
148 scatter_impl(const communicator& comm, T* out_values, int n, int root, in scatter_impl()
157 scatter(const communicator& comm, const T* in_values, T& out_value, int root) in scatter()
164 scatter(const communicator& comm, const std::vector<T>& in_values, T& out_value, in scatter()
172 void scatter(const communicator& comm, T& out_value, int root) in scatter()
180 scatter(const communicator& comm, const T* in_values, T* out_values, int n, in scatter()
[all …]
|
| D | gatherv.hpp | 31 gatherv_impl(const communicator& comm, const T* in_values, int in_size, in gatherv_impl()
45 gatherv_impl(const communicator& comm, const T* in_values, int in_size, int root, in gatherv_impl()
61 gatherv_impl(const communicator& comm, const T* in_values, int in_size, in gatherv_impl()
74 gatherv_impl(const communicator& comm, const T* in_values, int in_size, int root, in gatherv_impl()
84 gatherv(const communicator& comm, const T* in_values, int in_size, in gatherv()
98 gatherv(const communicator& comm, const std::vector<T>& in_values, in gatherv()
106 void gatherv(const communicator& comm, const T* in_values, int in_size, int root) in gatherv()
113 void gatherv(const communicator& comm, const std::vector<T>& in_values, int root) in gatherv()
124 gatherv(const communicator& comm, const T* in_values, int in_size, in gatherv()
139 gatherv(const communicator& comm, const std::vector<T>& in_values, in gatherv()
|
| D | all_reduce.hpp | 32 all_reduce_impl(const communicator& comm, const T* in_values, int n, in all_reduce_impl()
50 all_reduce_impl(const communicator& comm, const T* in_values, int n, in all_reduce_impl()
69 all_reduce_impl(const communicator& comm, const T* in_values, int n, in all_reduce_impl()
90 all_reduce(const communicator& comm, const T* in_values, int n, T* out_values, in all_reduce()
99 all_reduce(const communicator& comm, inplace_t<T*> inout_values, int n, Op op) in all_reduce()
106 all_reduce(const communicator& comm, inplace_t<T> inout_values, Op op) in all_reduce()
113 all_reduce(const communicator& comm, const T& in_value, T& out_value, Op op) in all_reduce()
120 T all_reduce(const communicator& comm, const T& in_value, Op op) in all_reduce()
|
| D | gather.hpp | 33 gather_impl(const communicator& comm, const T* in_values, int n, in gather_impl()
46 gather_impl(const communicator& comm, const T* in_values, int n, int root, in gather_impl()
58 gather_impl(const communicator& comm, const T* in_values, int n, T* out_values, in gather_impl()
112 gather_impl(const communicator& comm, const T* in_values, int n, T* out_values,int root, in gather_impl()
121 gather(const communicator& comm, const T& in_value, T* out_values, int root) in gather()
128 void gather(const communicator& comm, const T& in_value, int root) in gather()
136 gather(const communicator& comm, const T& in_value, std::vector<T>& out_values, in gather()
148 gather(const communicator& comm, const T* in_values, int n, T* out_values, in gather()
157 gather(const communicator& comm, const T* in_values, int n, in gather()
167 void gather(const communicator& comm, const T* in_values, int n, int root) in gather()
|
| D | reduce.hpp | 48 reduce_impl(const communicator& comm, const T* in_values, int n, in reduce_impl()
62 reduce_impl(const communicator& comm, const T* in_values, int n, Op /*op*/, in reduce_impl()
80 reduce_impl(const communicator& comm, const T* in_values, int n, in reduce_impl()
96 reduce_impl(const communicator& comm, const T* in_values, int n, Op op, in reduce_impl()
113 tree_reduce_impl(const communicator& comm, const T* in_values, int n, in tree_reduce_impl()
155 tree_reduce_impl(const communicator& comm, const T* in_values, int n, Op op, in tree_reduce_impl()
166 tree_reduce_impl(const communicator& comm, const T* in_values, int n, in tree_reduce_impl()
207 tree_reduce_impl(const communicator& comm, const T* in_values, int n, Op op, in tree_reduce_impl()
288 reduce_impl(const communicator& comm, const T* in_values, int n, in reduce_impl()
301 reduce_impl(const communicator& comm, const T* in_values, int n, Op op, in reduce_impl()
[all …]
|
| D | all_gatherv.hpp | 35 all_gatherv_impl(const communicator& comm, const T* in_values, in all_gatherv_impl()
56 all_gatherv_impl(const communicator& comm, const T* in_values, in all_gatherv_impl()
69 all_gatherv(const communicator& comm, const T& in_value, T* out_values, in all_gatherv()
80 all_gatherv(const communicator& comm, const T* in_values, T* out_values, in all_gatherv()
90 all_gatherv(const communicator& comm, std::vector<T> const& in_values, std::vector<T>& out_values, in all_gatherv()
103 all_gatherv(const communicator& comm, const T& in_value, T* out_values, in all_gatherv()
115 all_gatherv(const communicator& comm, const T* in_values, T* out_values, in all_gatherv()
127 all_gatherv(const communicator& comm, std::vector<T> const& in_values, std::vector<T>& out_values, in all_gatherv()
|
| D | all_gather.hpp | 33 all_gather_impl(const communicator& comm, const T* in_values, int n, in all_gather_impl()
47 all_gather_impl(const communicator& comm, const T* in_values, int n, in all_gather_impl()
96 all_gather_impl(const communicator& comm, const T* in_values, int n, in all_gather_impl()
105 all_gather(const communicator& comm, const T& in_value, T* out_values) in all_gather()
112 all_gather(const communicator& comm, const T& in_value, std::vector<T>& out_values) in all_gather()
121 all_gather(const communicator& comm, const T* in_values, int n, T* out_values) in all_gather()
128 all_gather(const communicator& comm, const T* in_values, int n, std::vector<T>& out_values) in all_gather()
|
| D | scan.hpp | 49 scan_impl(const communicator& comm, const T* in_values, int n, T* out_values, in scan_impl()
67 scan_impl(const communicator& comm, const T* in_values, int n, T* out_values, in scan_impl()
83 upper_lower_scan(const communicator& comm, const T* in_values, int n, in upper_lower_scan()
132 scan_impl(const communicator& comm, const T* in_values, int n, T* out_values, in scan_impl()
142 scan(const communicator& comm, const T& in_value, T& out_value, Op op) in scan()
150 scan(const communicator& comm, const T* in_values, int n, T* out_values, Op op) in scan()
158 scan(const communicator& comm, const T& in_value, Op op) in scan()
|
| /third_party/boost/boost/mpi/detail/ |
| D | request_handlers.hpp | 25 serialized_irecv_data(const communicator& comm, T& value) in serialized_irecv_data()
42 serialized_irecv_data(communicator const&, packed_iarchive& ia) : m_ia(ia) { } in serialized_irecv_data()
57 serialized_array_irecv_data(const communicator& comm, T* values, int n) in serialized_array_irecv_data()
100 serialized_irecv_data(const communicator& comm, skeleton_proxy<T> proxy) in serialized_irecv_data()
121 serialized_irecv_data(const communicator& comm, const skeleton_proxy<T>& proxy) in serialized_irecv_data()
134 probe_handler(communicator const& comm, int source, int tag, I1& i1) in probe_handler()
141 probe_handler(communicator const& comm, int source, int tag, I1& i1, I2& i2) in probe_handler()
186 communicator const& m_comm;
195 dynamic_primitive_array_data(communicator const&, A& arr) : m_buffer(arr) {} in dynamic_primitive_array_data()
207 serialized_data(communicator const& comm, T& value) : m_archive(comm), m_value(value) {} in serialized_data()
[all …]
|
| D | point_to_point.hpp | 19 class communicator;
25 packed_archive_send(communicator const& comm, int dest, int tag,
36 packed_archive_isend(communicator const& comm, int dest, int tag,
43 packed_archive_isend(communicator const& comm, int dest, int tag,
48 packed_archive_recv(communicator const& comm, int source, int tag, packed_iarchive& ar,
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/ |
| D | server.cc | 41 [](const std::shared_ptr<ps::core::CommunicatorBase> &communicator) { in SignalHandler() argument
42 MS_ERROR_IF_NULL_WO_RET_VAL(communicator); in SignalHandler()
43 (void)communicator->Stop(); in SignalHandler()
107 [](const std::shared_ptr<ps::core::CommunicatorBase> &communicator) { in Run() argument
108 MS_EXCEPTION_IF_NULL(communicator); in Run()
109 communicator->Join(); in Run()
326 …r::RegisterExceptionEventCallback(const std::shared_ptr<ps::core::TcpCommunicator> &communicator) { in RegisterExceptionEventCallback() argument
327 MS_EXCEPTION_IF_NULL(communicator); in RegisterExceptionEventCallback()
328 communicator->RegisterEventCallback(ps::core::ClusterEvent::SCHEDULER_TIMEOUT, [&]() { in RegisterExceptionEventCallback()
332 [](const std::shared_ptr<ps::core::CommunicatorBase> &communicator) { in RegisterExceptionEventCallback() argument
[all …]
|
| /third_party/boost/libs/mpi/example/ |
| D | generate_collect_optional.cpp | 19 void generate_data(mpi::communicator local, mpi::communicator world) in generate_data()
54 void collect_data(mpi::communicator local, mpi::communicator world) in collect_data()
97 mpi::communicator world; in main()
108 mpi::communicator local = world.split(is_generator? 0 : 1); in main()
|