set status->_ucount correctly for collective read and write operations in the module
This commit was SVN r26916.
Этот коммит содержится в:
родитель
91c8577d9d
Коммит
1078f13ad2
@ -94,6 +94,10 @@ mca_fcoll_dynamic_file_read_all (mca_io_ompio_file_t *fh,
|
||||
max_data = count * datatype->super.size;
|
||||
}
|
||||
|
||||
if ( MPI_STATUS_IGNORE != status ) {
|
||||
status->_ucount = max_data;
|
||||
}
|
||||
|
||||
if (! (fh->f_flags & OMPIO_AGGREGATOR_IS_SET)) {
|
||||
ompi_io_ompio_set_aggregator_props (fh,
|
||||
mca_fcoll_dynamic_num_io_procs,
|
||||
|
@ -134,6 +134,10 @@ mca_fcoll_dynamic_file_write_all (mca_io_ompio_file_t *fh,
|
||||
max_data = count * datatype->super.size;
|
||||
}
|
||||
|
||||
if ( MPI_STATUS_IGNORE != status ) {
|
||||
status->_ucount = max_data;
|
||||
}
|
||||
|
||||
|
||||
if (! (fh->f_flags & OMPIO_AGGREGATOR_IS_SET)) {
|
||||
ret = ompi_io_ompio_set_aggregator_props (fh,
|
||||
|
@ -115,6 +115,11 @@ mca_fcoll_static_file_read_all (mca_io_ompio_file_t *fh,
|
||||
else {
|
||||
max_data = count * datatype->super.size;
|
||||
}
|
||||
|
||||
if ( MPI_STATUS_IGNORE != status ) {
|
||||
status->_ucount = max_data;
|
||||
}
|
||||
|
||||
|
||||
if (! (fh->f_flags & OMPIO_AGGREGATOR_IS_SET)) {
|
||||
ompi_io_ompio_set_aggregator_props (fh,
|
||||
|
@ -112,6 +112,11 @@ mca_fcoll_static_file_write_all (mca_io_ompio_file_t *fh,
|
||||
max_data = count * datatype->super.size;
|
||||
}
|
||||
|
||||
if ( MPI_STATUS_IGNORE != status ) {
|
||||
status->_ucount = max_data;
|
||||
}
|
||||
|
||||
|
||||
if (! (fh->f_flags & OMPIO_AGGREGATOR_IS_SET)) {
|
||||
ompi_io_ompio_set_aggregator_props (fh,
|
||||
mca_fcoll_static_num_io_procs,
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user