add a new field to the ompio data structure (stripe_count) and set it correctly on pvfs2 and lustre.
Этот коммит содержится в:
родитель
d282e94b67
Коммит
4bbb22bd0b
@ -139,8 +139,9 @@ mca_fs_lustre_file_open (struct ompi_communicator_t *comm,
|
|||||||
return OMPI_ERROR;
|
return OMPI_ERROR;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (mca_fs_lustre_stripe_size > 0) {
|
if (fs_lustre_stripe_size > 0 && fs_lustre_stripe_width>0) {
|
||||||
fh->f_stripe_size = mca_fs_lustre_stripe_size;
|
fh->f_stripe_size = fs_lustre_stripe_size;
|
||||||
|
fh->f_stripe_count = fs_lustre_stripe_width;
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
lump = alloc_lum();
|
lump = alloc_lum();
|
||||||
@ -154,6 +155,7 @@ mca_fs_lustre_file_open (struct ompi_communicator_t *comm,
|
|||||||
return OMPI_ERROR;
|
return OMPI_ERROR;
|
||||||
}
|
}
|
||||||
fh->f_stripe_size = lump->lmm_stripe_size;
|
fh->f_stripe_size = lump->lmm_stripe_size;
|
||||||
|
fh->f_stripe_count = lump->lmm_stripe_count;
|
||||||
|
|
||||||
// if ( NULL != lump ) {
|
// if ( NULL != lump ) {
|
||||||
// free ( lump );
|
// free ( lump );
|
||||||
|
@ -180,6 +180,7 @@ mca_fs_pvfs2_file_open (struct ompi_communicator_t *comm,
|
|||||||
|
|
||||||
if (fs_pvfs2_stripe_size > 0 && fs_pvfs2_stripe_width > 0) {
|
if (fs_pvfs2_stripe_size > 0 && fs_pvfs2_stripe_width > 0) {
|
||||||
fh->f_stripe_size = fs_pvfs2_stripe_size;
|
fh->f_stripe_size = fs_pvfs2_stripe_size;
|
||||||
|
fh->f_stripe_count = fs_pvfs2_stripe_width;
|
||||||
}
|
}
|
||||||
|
|
||||||
return OMPI_SUCCESS;
|
return OMPI_SUCCESS;
|
||||||
|
@ -306,6 +306,7 @@ struct mca_io_ompio_file_t {
|
|||||||
void *f_fs_ptr;
|
void *f_fs_ptr;
|
||||||
int f_atomicity;
|
int f_atomicity;
|
||||||
size_t f_stripe_size;
|
size_t f_stripe_size;
|
||||||
|
int f_stripe_count;
|
||||||
size_t f_cc_size;
|
size_t f_cc_size;
|
||||||
int f_bytes_per_agg;
|
int f_bytes_per_agg;
|
||||||
enum ompio_fs_type f_fstype;
|
enum ompio_fs_type f_fstype;
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user