| /third_party/gstreamer/gstplugins_bad/sys/ipcpipeline/ |
| D | gstipcpipelinecomm.c | 97 comm_request_wait (GstIpcPipelineComm * comm, CommRequest * req, in comm_request_wait() argument
104 end_time = g_get_monotonic_time () + comm->ack_time; in comm_request_wait()
108 GST_TRACE_OBJECT (comm->element, "Waiting for ACK/NAK for request %u", in comm_request_wait()
112 if (!g_cond_wait_until (&req->cond, &comm->mutex, end_time)) in comm_request_wait()
115 g_cond_wait (&req->cond, &comm->mutex); in comm_request_wait()
120 GST_TRACE_OBJECT (comm->element, "Got reply for request %u: %d (%s)", in comm_request_wait()
124 GST_ERROR_OBJECT (comm->element, "Timeout waiting for reply for request %u", in comm_request_wait()
202 gst_ipc_pipeline_comm_sync_fd (GstIpcPipelineComm * comm, guint32 id, in gst_ipc_pipeline_comm_sync_fd() argument
213 waiting_ids = g_hash_table_ref (comm->waiting_ids); in gst_ipc_pipeline_comm_sync_fd()
215 *ret = comm_request_wait (comm, req, ack_type); in gst_ipc_pipeline_comm_sync_fd()
[all …]
|
| /third_party/boost/libs/mpi/test/ |
| D | scatter_test.cpp | 26 scatter_test(const communicator& comm, Generator generator, in scatter_test() argument
32 for (root = 0; root < comm.size(); ++root) in scatter_test()
33 scatter_test(comm, generator, kind, root); in scatter_test()
39 if (comm.rank() == root) { in scatter_test()
42 for (int p = 0; p < comm.size(); ++p) in scatter_test()
48 scatter(comm, values, value, root); in scatter_test()
50 scatter(comm, value, root); in scatter_test()
53 BOOST_CHECK(value == generator(comm.rank())); in scatter_test()
56 comm.barrier(); in scatter_test()
118 scatterv_test(const communicator& comm, Generator generator, in scatterv_test() argument
[all …]
|
| D | ring_test.cpp | 27 ring_test(const communicator& comm, const T& pass_value, const char* kind, in ring_test() argument
32 int rank = comm.rank(); in ring_test()
33 int size = comm.size(); in ring_test()
38 comm.send((rank + 1) % size, 0, pass_value); in ring_test()
39 comm.recv((rank + size - 1) % size, 0, transferred_value); in ring_test()
43 comm.recv((rank + size - 1) % size, 0, transferred_value); in ring_test()
45 comm.send((rank + 1) % size, 0, transferred_value); in ring_test()
48 (comm.barrier)(); in ring_test()
54 ring_array_test(const communicator& comm, const T* pass_values, in ring_array_test() argument
58 int rank = comm.rank(); in ring_array_test()
[all …]
|
| D | skeleton_content_test.cpp | 27 test_skeleton_and_content(const communicator& comm, int root, in test_skeleton_and_content() argument
36 int list_size = comm.size() + 7; in test_skeleton_and_content()
37 if (comm.rank() == root) { in test_skeleton_and_content()
47 for (int p = 0; p < comm.size(); ++p) in test_skeleton_and_content()
48 if (p != root) comm.send(p, 0, skeleton(original_list)); in test_skeleton_and_content()
50 broadcast(comm, skeleton(original_list), root); in test_skeleton_and_content()
59 for (int p = 0; p < comm.size(); ++p) in test_skeleton_and_content()
60 if (p != root) comm.send(p, 1, c); in test_skeleton_and_content()
70 for (int p = 0; p < comm.size(); ++p) in test_skeleton_and_content()
71 if (p != root) comm.send(p, 2, c); in test_skeleton_and_content()
[all …]
|
| D | gather_test.cpp | 25 gather_test(const communicator& comm, Generator generator, in gather_test() argument
29 value_type value = generator(comm.rank()); in gather_test()
32 for (root = 0; root < comm.size(); ++root) in gather_test()
33 gather_test(comm, generator, kind, root); in gather_test()
38 if (comm.rank() == root) { in gather_test()
43 gather(comm, value, values, root); in gather_test()
45 if (comm.rank() == root) { in gather_test()
47 for (int p = 0; p < comm.size(); ++p) in gather_test()
55 (comm.barrier)(); in gather_test()
61 gatherv_test(const communicator& comm, Generator generator, in gatherv_test() argument
[all …]
|
| D | broadcast_test.cpp | 29 broadcast_test(const communicator& comm, const T& bc_value, in broadcast_test() argument
33 for (root = 0; root < comm.size(); ++root) in broadcast_test()
34 broadcast_test(comm, bc_value, kind, root); in broadcast_test()
39 if (comm.rank() == root) { in broadcast_test()
45 broadcast(comm, value, root); in broadcast_test()
47 if (comm.rank() == root && value == bc_value) in broadcast_test()
51 (comm.barrier)(); in broadcast_test()
55 test_skeleton_and_content(const communicator& comm, int root = 0) in test_skeleton_and_content() argument
62 int list_size = comm.size() + 7; in test_skeleton_and_content()
63 if (comm.rank() == root) { in test_skeleton_and_content()
[all …]
|
| D | all_gather_test.cpp | 29 all_gather_test(const mpi::communicator& comm, Generator generator, in all_gather_test() argument
33 value_type value = generator(comm.rank()); in all_gather_test()
36 if (comm.rank() == 0) { in all_gather_test()
41 mpi::all_gather(comm, value, values); in all_gather_test()
44 for (int p = 0; p < comm.size(); ++p) in all_gather_test()
47 if (comm.rank() == 0 && values == expected_values) in all_gather_test()
50 (comm.barrier)(); in all_gather_test()
55 all_gatherv_test(const mpi::communicator& comm, Generator generator, in all_gatherv_test() argument
63 for(int r = 0; r < comm.size(); ++r) { in all_gatherv_test()
68 if(comm.rank() == r) { in all_gatherv_test()
[all …]
|
| D | nonblocking_test.cpp | 49 nonblocking_tests( const communicator& comm, const T* values, int num_values, in nonblocking_tests() argument
52 nonblocking_test(comm, values, num_values, kind, mk_wait_any); in nonblocking_tests()
53 nonblocking_test(comm, values, num_values, kind, mk_test_any); in nonblocking_tests()
55 nonblocking_test(comm, values, num_values, kind, mk_wait_all); in nonblocking_tests()
56 nonblocking_test(comm, values, num_values, kind, mk_wait_all_keep); in nonblocking_tests()
58 nonblocking_test(comm, values, num_values, kind, mk_test_all); in nonblocking_tests()
59 nonblocking_test(comm, values, num_values, kind, mk_test_all_keep); in nonblocking_tests()
61 nonblocking_test(comm, values, num_values, kind, mk_wait_some); in nonblocking_tests()
62 nonblocking_test(comm, values, num_values, kind, mk_wait_some_keep); in nonblocking_tests()
63 nonblocking_test(comm, values, num_values, kind, mk_test_some); in nonblocking_tests()
[all …]
|
| /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 …]
|
| /third_party/boost/boost/mpi/collectives/ |
| D | all_gatherv.hpp | 35 all_gatherv_impl(const communicator& comm, const T* in_values, in all_gatherv_impl() argument
39 scoped_array<int> new_offsets_mem(make_offsets(comm, sizes, displs, -1)); in all_gatherv_impl()
43 (const_cast<T*>(in_values), sizes[comm.rank()], type, in all_gatherv_impl()
48 comm)); in all_gatherv_impl()
56 all_gatherv_impl(const communicator& comm, const T* in_values, in all_gatherv_impl() argument
61 scoped_array<int> skipped(make_skipped_slots(comm, sizes, displs)); in all_gatherv_impl()
62 all_gather_impl(comm, in_values, sizes[comm.rank()], out_values, in all_gatherv_impl()
69 all_gatherv(const communicator& comm, const T& in_value, T* out_values, in all_gatherv() argument
73 assert(sizes.size() == comm.size()); in all_gatherv()
74 assert(sizes[comm.rank()] == 1); in all_gatherv()
[all …]
|
| D | reduce.hpp | 48 reduce_impl(const communicator& comm, const T* in_values, int n, in reduce_impl() argument
55 (is_mpi_op<Op, T>::op()), root, comm)); in reduce_impl()
62 reduce_impl(const communicator& comm, const T* in_values, int n, Op /*op*/, in reduce_impl() argument
68 (is_mpi_op<Op, T>::op()), root, comm)); in reduce_impl()
80 reduce_impl(const communicator& comm, const T* in_values, int n, in reduce_impl() argument
88 mpi_op.get_mpi_op(), root, comm)); in reduce_impl()
96 reduce_impl(const communicator& comm, const T* in_values, int n, Op op, in reduce_impl() argument
103 mpi_op.get_mpi_op(), root, comm)); in reduce_impl()
113 tree_reduce_impl(const communicator& comm, const T* in_values, int n, in tree_reduce_impl() argument
119 int size = comm.size(); in tree_reduce_impl()
[all …]
|
| D | gather.hpp | 33 gather_impl(const communicator& comm, const T* in_values, int n, in gather_impl() argument
39 out_values, n, type, root, comm)); in gather_impl()
46 gather_impl(const communicator& comm, const T* in_values, int n, int root, in gather_impl() argument
49 assert(comm.rank() != root); in gather_impl()
50 gather_impl(comm, in_values, n, (T*)0, root, is_mpi_type); in gather_impl()
58 gather_impl(const communicator& comm, const T* in_values, int n, T* out_values, in gather_impl() argument
61 int nproc = comm.size(); in gather_impl()
64 packed_oarchive oa(comm); in gather_impl()
68 bool is_root = comm.rank() == root; in gather_impl()
74 root, MPI_Comm(comm))); in gather_impl()
[all …]
|
| D | scatterv.hpp | 28 scatterv_impl(const communicator& comm, const T* in_values, T* out_values, int out_size, in scatterv_impl() argument
31 assert(!sizes || out_size == sizes[comm.rank()]); in scatterv_impl()
34 scoped_array<int> new_offsets_mem(make_offsets(comm, sizes, displs, root)); in scatterv_impl()
40 out_values, out_size, type, root, comm)); in scatterv_impl()
47 scatterv_impl(const communicator& comm, T* out_values, int out_size, int root, in scatterv_impl() argument
50 scatterv_impl(comm, (T const*)0, out_values, out_size, in scatterv_impl()
62 scatterv_impl(const communicator& comm, const T* in_values, T* out_values, int out_size, in scatterv_impl() argument
66 bool is_root = comm.rank() == root; in scatterv_impl()
67 int nproc = comm.size(); in scatterv_impl()
70 assert(out_size == sizes[comm.rank()]); in scatterv_impl()
[all …]
|
| D | scatter.hpp | 30 scatter_impl(const communicator& comm, const T* in_values, T* out_values, in scatter_impl() argument
36 out_values, n, type, root, comm)); in scatter_impl()
43 scatter_impl(const communicator& comm, T* out_values, int n, int root, in scatter_impl() argument
50 root, comm)); in scatter_impl()
62 fill_scatter_sendbuf(const communicator& comm, T const* values, in fill_scatter_sendbuf() argument
65 int nproc = comm.size(); in fill_scatter_sendbuf()
72 packed_oarchive procarchive(comm); in fill_scatter_sendbuf()
96 dispatch_scatter_sendbuf(const communicator& comm, in dispatch_scatter_sendbuf() argument
104 &myarchsize, 1, MPI_INT, root, comm)); in dispatch_scatter_sendbuf()
106 if (root == comm.rank()) { in dispatch_scatter_sendbuf()
[all …]
|
| 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() argument
99 root, MPI_Comm(comm))); in broadcast_impl()
[all …]
|
| D | gatherv.hpp | 31 gatherv_impl(const communicator& comm, const T* in_values, int in_size, in gatherv_impl() argument
38 type, root, comm)); in gatherv_impl()
45 gatherv_impl(const communicator& comm, const T* in_values, int in_size, int root, in gatherv_impl() argument
51 0, 0, 0, type, root, comm)); in gatherv_impl()
61 gatherv_impl(const communicator& comm, const T* in_values, int in_size, in gatherv_impl() argument
65 scoped_array<int> skipped(make_skipped_slots(comm, sizes, displs, root)); in gatherv_impl()
66 gather_impl(comm, in_values, in_size, out_values, sizes, skipped.get(), root, mpl::false_()); in gatherv_impl()
74 gatherv_impl(const communicator& comm, const T* in_values, int in_size, int root, in gatherv_impl() argument
77 gather_impl(comm, in_values, in_size, (T*)0,(int const*)0,(int const*)0, root, in gatherv_impl()
84 gatherv(const communicator& comm, const T* in_values, int in_size, in gatherv() argument
[all …]
|
| D | all_gather.hpp | 33 all_gather_impl(const communicator& comm, const T* in_values, int n, in all_gather_impl() argument
39 out_values, n, type, comm)); in all_gather_impl()
47 all_gather_impl(const communicator& comm, const T* in_values, int n, in all_gather_impl() argument
50 int nproc = comm.size(); in all_gather_impl()
53 packed_oarchive oa(comm); in all_gather_impl()
62 MPI_Comm(comm))); in all_gather_impl()
73 MPI_Comm(comm))); in all_gather_impl()
78 if (src == comm.rank()) { // this is our local data in all_gather_impl()
83 packed_iarchive ia(comm, recv_buffer, boost::archive::no_header, offsets[src]); in all_gather_impl()
96 all_gather_impl(const communicator& comm, const T* in_values, int n, in all_gather_impl() argument
[all …]
|
| D | scan.hpp | 49 scan_impl(const communicator& comm, const T* in_values, int n, T* out_values, in scan_impl() argument
55 (is_mpi_op<Op, T>::op()), comm)); in scan_impl()
67 scan_impl(const communicator& comm, const T* in_values, int n, T* out_values, in scan_impl() argument
74 mpi_op.get_mpi_op(), comm)); in scan_impl()
83 upper_lower_scan(const communicator& comm, const T* in_values, int n, in upper_lower_scan() argument
87 int rank = comm.rank(); in upper_lower_scan()
96 upper_lower_scan(comm, in_values, n, out_values, op, lower, middle); in upper_lower_scan()
101 packed_oarchive oa(comm); in upper_lower_scan()
106 comm.send(p, tag, oa); in upper_lower_scan()
110 upper_lower_scan(comm, in_values, n, out_values, op, middle, upper); in upper_lower_scan()
[all …]
|
| D | all_to_all.hpp | 30 all_to_all_impl(const communicator& comm, const T* in_values, int n, in all_to_all_impl() argument
36 out_values, n, type, comm)); in all_to_all_impl()
44 all_to_all_impl(const communicator& comm, const T* in_values, int n, in all_to_all_impl() argument
47 int size = comm.size(); in all_to_all_impl()
48 int rank = comm.rank(); in all_to_all_impl()
66 packed_oarchive oa(comm, outgoing); in all_to_all_impl()
77 all_to_all(comm, send_sizes, recv_sizes); in all_to_all_impl()
98 comm)); in all_to_all_impl()
106 packed_iarchive ia(comm, incoming, boost::archive::no_header, in all_to_all_impl()
117 all_to_all(const communicator& comm, const T* in_values, T* out_values) in all_to_all() argument
[all …]
|
| D | all_reduce.hpp | 32 all_reduce_impl(const communicator& comm, const T* in_values, int n, in all_reduce_impl() argument
39 (is_mpi_op<Op, T>::op()), comm)); in all_reduce_impl()
50 all_reduce_impl(const communicator& comm, const T* in_values, int n, in all_reduce_impl() argument
58 mpi_op.get_mpi_op(), comm)); in all_reduce_impl()
69 all_reduce_impl(const communicator& comm, const T* in_values, int n, in all_reduce_impl() argument
80 reduce(comm, detail::c_data(tmp_in), n, out_values, op, 0); in all_reduce_impl()
82 reduce(comm, in_values, n, out_values, op, 0); in all_reduce_impl()
84 broadcast(comm, out_values, n, 0); in all_reduce_impl()
90 all_reduce(const communicator& comm, const T* in_values, int n, T* out_values, in all_reduce() argument
93 detail::all_reduce_impl(comm, in_values, n, out_values, op, in all_reduce()
[all …]
|
| /third_party/boost/libs/mpi/src/ |
| D | broadcast.cpp | 20 broadcast<const packed_oarchive>(const communicator& comm, in broadcast() argument
25 assert(comm.rank() == root); in broadcast()
27 int size = comm.size(); in broadcast()
38 *it++ = detail::packed_archive_isend(comm, dest, tag, oa); in broadcast()
46 broadcast<packed_oarchive>(const communicator& comm, packed_oarchive& oa, in broadcast() argument
49 broadcast(comm, const_cast<const packed_oarchive&>(oa), root); in broadcast()
54 broadcast<packed_iarchive>(const communicator& comm, packed_iarchive& ia, in broadcast() argument
57 int size = comm.size(); in broadcast()
64 if (comm.rank() != root) { in broadcast()
66 detail::packed_archive_recv(comm, root, tag, ia, status); in broadcast()
[all …]
|
| /third_party/boost/libs/mpi/src/python/ |
| D | collectives.cpp | 32 object all_gather(const communicator& comm, object value) in all_gather() argument
35 boost::mpi::all_gather(comm, value, values); in all_gather()
38 for (int i = 0; i < comm.size(); ++i) in all_gather()
43 object all_to_all(const communicator& comm, object in_values) in all_to_all() argument
46 std::vector<object> in_values_vec(comm.size()); in all_to_all()
48 for (int i = 0; i < comm.size(); ++i) in all_to_all()
51 std::vector<object> out_values_vec(comm.size()); in all_to_all()
52 boost::mpi::all_to_all(comm, in_values_vec, out_values_vec); in all_to_all()
55 for (int i = 0; i < comm.size(); ++i) in all_to_all()
60 object broadcast(const communicator& comm, object value, int root) in broadcast() argument
[all …]
|
| /third_party/boost/libs/mpi/test/python/ |
| D | skeleton_content_test.py | 13 def test_skeleton_and_content(comm, root, manual_broadcast = True): argument
17 list_size = comm.size + 7
22 if comm.rank == root:
26 for p in range(0,comm.size):
27 if p != comm.rank:
28 comm.send(p, 0, value = mpi.skeleton(original_list))
34 for p in range(0,comm.size):
35 if p != comm.rank:
36 comm.send(p, 0, value = mpi.get_content(original_list))
44 for p in range(0,comm.size):
[all …]
|
| D | ring_test.py | 12 def ring_test(comm, value, kind, root): argument
13 next_peer = (comm.rank + 1) % comm.size;
14 prior_peer = (comm.rank + comm.size - 1) % comm.size;
16 if comm.rank == root:
18 comm.send(next_peer, 0, value)
19 (other_value, stat) = comm.recv(return_status = True)
24 msg = comm.probe()
25 other_value = comm.recv(msg.source, msg.tag)
27 comm.send(next_peer, 0, other_value)
29 comm.barrier()
[all …]
|
| /third_party/boost/boost/mpi/detail/ |
| D | request_handlers.hpp | 25 serialized_irecv_data(const communicator& comm, T& value) in serialized_irecv_data()
26 : m_ia(comm), m_value(value) {} in serialized_irecv_data()
57 serialized_array_irecv_data(const communicator& comm, T* values, int n) in serialized_array_irecv_data()
58 : m_count(0), m_ia(comm), m_values(values), m_nb(n) {} in serialized_array_irecv_data()
100 serialized_irecv_data(const communicator& comm, skeleton_proxy<T> proxy) in serialized_irecv_data()
101 : m_isa(comm), m_ia(m_isa.get_skeleton()), m_proxy(proxy) { } in serialized_irecv_data()
121 serialized_irecv_data(const communicator& comm, const skeleton_proxy<T>& proxy) in serialized_irecv_data()
122 : inherited(comm, proxy) { } in serialized_irecv_data()
134 probe_handler(communicator const& comm, int source, int tag, I1& i1) in probe_handler() argument
135 : Data(comm, i1), in probe_handler()
[all …]
|