Home
last modified time | relevance | path

Searched defs:comm (Results 1 – 25 of 67) sorted by relevance

123

/third_party/boost/libs/mpi/src/
Dbroadcast.cpp20 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()
Dgraph_communicator.cpp15 out_edges(int vertex, const graph_communicator& comm) in out_edges()
26 int out_degree(int vertex, const graph_communicator& comm) in out_degree()
36 adjacent_vertices(int vertex, const graph_communicator& comm) in adjacent_vertices()
51 edges(const graph_communicator& comm) in edges()
66 int num_edges(const graph_communicator& comm) in num_edges()
Dpoint_to_point.cpp31 packed_archive_send(communicator const& comm, int dest, int tag, in packed_archive_send()
57 packed_archive_isend(communicator const& comm, int dest, int tag, in packed_archive_isend()
65 packed_archive_isend(communicator const& comm, int dest, int tag, in packed_archive_isend()
73 packed_archive_recv(communicator const& comm, int source, int tag, packed_iarchive& ar, in packed_archive_recv()
Drequest.cpp30 request::make_bottom_send(communicator const& comm, int dest, int tag, MPI_Datatype tp) { in make_bottom_send()
39 request::make_empty_send(communicator const& comm, int dest, int tag) { in make_empty_send()
48 request::make_bottom_recv(communicator const& comm, int dest, int tag, MPI_Datatype tp) { in make_bottom_recv()
57 request::make_empty_recv(communicator const& comm, int dest, int tag) { in make_empty_recv()
66 request::make_packed_send(communicator const& comm, int dest, int tag, void const* buffer, std::siz… in make_packed_send()
/third_party/boost/boost/mpi/collectives/
Dall_gatherv.hpp35 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()
Dall_reduce.hpp32 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()
Dscatterv.hpp28 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 …]
Dscatter.hpp30 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 …]
Dgatherv.hpp31 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()
Dgather.hpp33 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()
Dreduce.hpp48 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 …]
Dall_gather.hpp33 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()
Dscan.hpp49 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()
Dall_to_all.hpp30 all_to_all_impl(const communicator& comm, const T* in_values, int n, in all_to_all_impl()
44 all_to_all_impl(const communicator& comm, const T* in_values, int n, in all_to_all_impl()
117 all_to_all(const communicator& comm, const T* in_values, T* out_values) in all_to_all()
124 all_to_all(const communicator& comm, const std::vector<T>& in_values, in all_to_all()
134 all_to_all(const communicator& comm, const T* in_values, int n, T* out_values) in all_to_all()
141 all_to_all(const communicator& comm, const std::vector<T>& in_values, int n, in all_to_all()
Dbroadcast.hpp93 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()
139 void broadcast(const communicator& comm, T& value, int root) in broadcast()
145 void broadcast(const communicator& comm, T* values, int n, int root) in broadcast()
/third_party/boost/libs/mpi/src/python/
Dcollectives.cpp32 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()
Dpy_communicator.cpp40 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()
78 class_<communicator> comm("Communicator", communicator_docstring); in export_communicator() local
Dskeleton_and_content.cpp94 communicator_send_content(const communicator& comm, int dest, int tag, in communicator_send_content()
103 communicator_recv_content(const communicator& comm, int source, int tag, in communicator_recv_content()
119 communicator_irecv_content(const communicator& comm, int source, int tag, in communicator_irecv_content()
135 void export_skeleton_and_content(class_<communicator>& comm) in export_skeleton_and_content()
/third_party/gstreamer/gstplugins_bad/sys/ipcpipeline/
Dgstipcpipelinecomm.c90 comm_request_wait (GstIpcPipelineComm * comm, CommRequest * req, in comm_request_wait()
195 gst_ipc_pipeline_comm_sync_fd (GstIpcPipelineComm * comm, guint32 id, in gst_ipc_pipeline_comm_sync_fd()
216 write_to_fd_raw (GstIpcPipelineComm * comm, const void *data, size_t size) in write_to_fd_raw()
243 write_byte_writer_to_fd (GstIpcPipelineComm * comm, GstByteWriter * bw) in write_byte_writer_to_fd()
259 gst_ipc_pipeline_comm_write_ack_to_fd (GstIpcPipelineComm * comm, guint32 id, in gst_ipc_pipeline_comm_write_ack_to_fd()
296 gst_ipc_pipeline_comm_write_flow_ack_to_fd (GstIpcPipelineComm * comm, in gst_ipc_pipeline_comm_write_flow_ack_to_fd()
304 gst_ipc_pipeline_comm_write_boolean_ack_to_fd (GstIpcPipelineComm * comm, in gst_ipc_pipeline_comm_write_boolean_ack_to_fd()
312 gst_ipc_pipeline_comm_write_state_change_ack_to_fd (GstIpcPipelineComm * comm, in gst_ipc_pipeline_comm_write_state_change_ack_to_fd()
320 gst_ipc_pipeline_comm_write_query_result_to_fd (GstIpcPipelineComm * comm, in gst_ipc_pipeline_comm_write_query_result_to_fd()
382 gst_ipc_pipeline_comm_read_query_result (GstIpcPipelineComm * comm, in gst_ipc_pipeline_comm_read_query_result()
[all …]
/third_party/boost/libs/mpi/test/
Dbroadcast_stl_test.cpp29 broadcast_test(const mpi::communicator& comm, const T& bc_value, in broadcast_test()
55 broadcast_test(const mpi::communicator& comm, const T& bc_value, in broadcast_test()
67 mpi::communicator comm; in BOOST_AUTO_TEST_CASE() local
Dbroadcast_test.cpp29 broadcast_test(const communicator& comm, const T& bc_value, in broadcast_test()
55 test_skeleton_and_content(const communicator& comm, int root = 0) in test_skeleton_and_content()
141 communicator comm; in BOOST_AUTO_TEST_CASE() local
Dring_test.cpp27 ring_test(const communicator& comm, const T& pass_value, const char* kind, in ring_test()
54 ring_array_test(const communicator& comm, const T* pass_values, in ring_array_test()
93 communicator comm; in BOOST_AUTO_TEST_CASE() local
Dversion_test.cpp19 test_version(mpi::communicator const& comm) { in test_version()
42 report_features(mpi::communicator const& comm) { in report_features()
Ddebugger.cpp18 void wait_for_debugger(std::vector<int> const& processes, boost::mpi::communicator const& comm) in wait_for_debugger()
40 void wait_for_debugger(boost::mpi::communicator const& comm) in wait_for_debugger()
/third_party/boost/boost/mpi/detail/
Dbroadcast_sc.hpp18 broadcast(const communicator& comm, const skeleton_proxy<T>& proxy, int root) in broadcast()
33 broadcast(const communicator& comm, skeleton_proxy<T>& proxy, int root) in broadcast()

123