This source file includes following definitions.
- mca_coll_sync_reduce
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 #include "ompi_config.h"
20
21 #include "coll_sync.h"
22
23
24
25
26
27
28
29
30
31 int mca_coll_sync_reduce(const void *sbuf, void *rbuf, int count,
32 struct ompi_datatype_t *dtype,
33 struct ompi_op_t *op,
34 int root, struct ompi_communicator_t *comm,
35 mca_coll_base_module_t *module)
36 {
37 mca_coll_sync_module_t *s = (mca_coll_sync_module_t*) module;
38
39 if (s->in_operation) {
40 return s->c_coll.coll_reduce(sbuf, rbuf, count, dtype, op, root, comm,
41 s->c_coll.coll_reduce_module);
42 }
43 COLL_SYNC(s, s->c_coll.coll_reduce(sbuf, rbuf, count, dtype,
44 op, root, comm,
45 s->c_coll.coll_reduce_module));
46 }