This source file includes following definitions.
- mca_fcoll_individual_component_init_query
- mca_fcoll_individual_component_file_query
- mca_fcoll_individual_component_file_unquery
- mca_fcoll_individual_module_init
- mca_fcoll_individual_module_finalize
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 #include "ompi_config.h"
23 #include "fcoll_individual.h"
24
25 #include <stdio.h>
26
27 #include "mpi.h"
28 #include "ompi/mca/fcoll/fcoll.h"
29 #include "ompi/mca/fcoll/base/base.h"
30
31
32
33
34
35
36
37 static mca_fcoll_base_module_1_0_0_t individual = {
38 mca_fcoll_individual_module_init,
39 mca_fcoll_individual_module_finalize,
40 mca_fcoll_individual_file_read_all,
41 NULL,
42 mca_fcoll_individual_file_write_all,
43 NULL,
44 NULL,
45 NULL
46 };
47
48 int
49 mca_fcoll_individual_component_init_query(bool enable_progress_threads,
50 bool enable_mpi_threads)
51 {
52
53
54 return OMPI_SUCCESS;
55 }
56
57 mca_fcoll_base_module_1_0_0_t *
58 mca_fcoll_individual_component_file_query (ompio_file_t *fh, int *priority)
59 {
60 *priority = mca_fcoll_individual_priority;
61 if (0 >= mca_fcoll_individual_priority) {
62 return NULL;
63 }
64
65 if (mca_fcoll_base_query_table (fh, "individual")) {
66 if (*priority < 30) {
67 *priority = 30;
68 }
69 if ( 2 >= fh->f_size ) {
70 *priority = 100;
71 }
72 }
73
74 return &individual;
75 }
76
77 int mca_fcoll_individual_component_file_unquery (ompio_file_t *file)
78 {
79
80
81
82
83 return OMPI_SUCCESS;
84 }
85
86 int mca_fcoll_individual_module_init (ompio_file_t *file)
87 {
88 return OMPI_SUCCESS;
89 }
90
91
92 int mca_fcoll_individual_module_finalize (ompio_file_t *file)
93 {
94 return OMPI_SUCCESS;
95 }