@@ -90,14 +90,14 @@ int ompi_coll_tuned_read_rules_config_file (char *fname, ompi_coll_alg_rule_t**
90
90
91
91
fptr = fopen (fname , "r" );
92
92
if (!fptr ) {
93
- OPAL_OUTPUT ((ompi_coll_tuned_stream ,"cannot read rules file [%s]\n" , fname ));
93
+ OPAL_OUTPUT ((ompi_coll_tuned_stream ,"Cannot read rules file [%s]\n" , fname ));
94
94
goto on_file_error ;
95
95
}
96
96
97
97
/* make space and init the algorithm rules for each of the n_collectives MPI collectives */
98
98
alg_rules = ompi_coll_tuned_mk_alg_rules (n_collectives );
99
99
if (NULL == alg_rules ) {
100
- OPAL_OUTPUT ((ompi_coll_tuned_stream ,"cannot cannot allocate rules for file [%s]\n" , fname ));
100
+ OPAL_OUTPUT ((ompi_coll_tuned_stream ,"Cannot allocate rules for file [%s]\n" , fname ));
101
101
goto on_file_error ;
102
102
}
103
103
@@ -142,6 +142,10 @@ int ompi_coll_tuned_read_rules_config_file (char *fname, ompi_coll_alg_rule_t**
142
142
OPAL_OUTPUT ((ompi_coll_tuned_stream , "Read communicator count %d for dynamic rule for collective ID %d\n" , NCS , CI ));
143
143
alg_p -> n_com_sizes = NCS ;
144
144
alg_p -> com_rules = ompi_coll_tuned_mk_com_rules (NCS , CI );
145
+ if (NULL == alg_p -> com_rules ) {
146
+ OPAL_OUTPUT ((ompi_coll_tuned_stream ,"Cannot allocate com rules for file [%s]\n" , fname ));
147
+ goto on_file_error ;
148
+ }
145
149
146
150
for (ncs = 0 ;ncs < NCS ;ncs ++ ) { /* for each comm size */
147
151
@@ -164,6 +168,10 @@ int ompi_coll_tuned_read_rules_config_file (char *fname, ompi_coll_alg_rule_t**
164
168
NMS , CI , CS ));
165
169
com_p -> n_msg_sizes = NMS ;
166
170
com_p -> msg_rules = ompi_coll_tuned_mk_msg_rules (NMS , CI , ncs , CS );
171
+ if (NULL == com_p -> msg_rules ) {
172
+ OPAL_OUTPUT ((ompi_coll_tuned_stream ,"Cannot allocate msg rules for file [%s]\n" , fname ));
173
+ goto on_file_error ;
174
+ }
167
175
168
176
msg_p = com_p -> msg_rules ;
169
177
0 commit comments