Коммит
edfdcb6e82
@ -650,14 +650,17 @@ int mca_common_ompio_create_groups(ompio_file_t *fh,
|
||||
opal_output(1,"mca_common_ompio_create_groups: could not allocate memory\n");
|
||||
goto exit;
|
||||
}
|
||||
|
||||
|
||||
int found;
|
||||
for ( i=0, j=0; i<fh->f_num_aggrs; i++ ) {
|
||||
for ( ; j<fh->f_size; j++ ) {
|
||||
found = 0;
|
||||
do {
|
||||
if ( 1 == tmp_final_aggrs[j] ) {
|
||||
break;
|
||||
fh->f_aggr_list[i] = j;
|
||||
found=1;
|
||||
}
|
||||
fh->f_aggr_list[i] = tmp_final_aggrs[j];
|
||||
}
|
||||
j++;
|
||||
} while ( !found && j < fh->f_size);
|
||||
}
|
||||
|
||||
exit:
|
||||
|
@ -268,6 +268,11 @@ int mca_fcoll_base_query_table (struct ompio_file_t *file, char *name)
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
if (!strcmp (name, "vulcan")) {
|
||||
if ( (LUSTRE != file->f_fstype)) {
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
if (!strcmp (name, "dynamic")) {
|
||||
if ((int)file->f_cc_size < file->f_bytes_per_agg &&
|
||||
file->f_cc_size >= file->f_stripe_size) {
|
||||
|
@ -63,8 +63,8 @@ mca_fcoll_two_phase_component_file_query (ompio_file_t *fh, int *priority)
|
||||
}
|
||||
|
||||
if (mca_fcoll_base_query_table (fh, "two_phase")) {
|
||||
if (*priority < 50) {
|
||||
*priority = 50;
|
||||
if (*priority < 35) {
|
||||
*priority = 35;
|
||||
}
|
||||
}
|
||||
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user