diff options
| author | MuQun Yang <ymuqun@hdfgroup.org> | 2005-07-13 19:52:46 (GMT) |
|---|---|---|
| committer | MuQun Yang <ymuqun@hdfgroup.org> | 2005-07-13 19:52:46 (GMT) |
| commit | 273d9ed93e2ba3d58cccfb246d9227207a1e2082 (patch) | |
| tree | 98880c2bb22148f9372acf6c0597b287643158e6 | |
| parent | 48e977e9c8f556fbc5fc20f0aa4dafcc1511c59c (diff) | |
| download | hdf5-273d9ed93e2ba3d58cccfb246d9227207a1e2082.zip hdf5-273d9ed93e2ba3d58cccfb246d9227207a1e2082.tar.gz hdf5-273d9ed93e2ba3d58cccfb246d9227207a1e2082.tar.bz2 | |
[svn-r11070]
Purpose:
Make collective IO tests work with mpiposix
Description:
Although internally HDF5 is using independent IO for mpiposix driver,
it is still a good test to see whether HDF5 APIs can allow collective IO calls to pass
into mpiposix driver.
Previous tests ignore this test; now add it.
Solution:
Platforms tested:
AIX (copper), too minor to need to test with three platforms.
Misc. update:
| -rw-r--r-- | testpar/t_span_tree.c | 21 |
1 files changed, 19 insertions, 2 deletions
diff --git a/testpar/t_span_tree.c b/testpar/t_span_tree.c index 26f25bf..e316ecc 100644 --- a/testpar/t_span_tree.c +++ b/testpar/t_span_tree.c @@ -205,6 +205,7 @@ void coll_write_test(int chunk_factor) const char *filename; hid_t acc_plist,xfer_plist; + hbool_t use_gpfs = FALSE; hid_t file, datasetc,dataseti; /* File and dataset identifiers */ hid_t mspaceid1, mspaceid, fspaceid,fspaceid1; /* Dataspace identifiers */ hid_t plist; /* Dataset property list identifier */ @@ -252,12 +253,18 @@ void coll_write_test(int chunk_factor) */ vector[0] = vector[MSPACE1_DIM - 1] = -1; for (i = 1; i < MSPACE1_DIM - 1; i++) vector[i] = i; + printf("sizeof(int) %d\n",sizeof(int)); +#if 0 acc_plist = H5Pcreate(H5P_FILE_ACCESS); VRFY((acc_plist >= 0),""); ret = H5Pset_fapl_mpio(acc_plist,comm,info); VRFY((ret >= 0),"MPIO creation property list succeeded"); +#endif + + acc_plist = create_faccess_plist(comm, info, facc_type, use_gpfs); + VRFY((acc_plist >= 0),""); /* * Create a file. @@ -360,8 +367,8 @@ void coll_write_test(int chunk_factor) VRFY((ret >= 0),"MPIO data transfer property list succeed"); - ret = H5Dwrite(datasetc, H5T_NATIVE_INT, mspaceid1, fspaceid, xfer_plist, vector); - /*ret = H5Dwrite(datasetc, H5T_NATIVE_INT, mspaceid1, fspaceid, H5P_DEFAULT, vector);*/ + ret = H5Dwrite(datasetc, H5T_NATIVE_INT, mspaceid1, fspaceid, xfer_plist, vector); +/* ret = H5Dwrite(datasetc, H5T_NATIVE_INT, mspaceid1, fspaceid, H5P_DEFAULT, vector);*/ VRFY((ret >= 0),"dataset collective write succeed"); ret = H5Sclose(mspaceid1); @@ -400,11 +407,15 @@ void coll_write_test(int chunk_factor) /*** For testing collective hyperslab selection write ***/ +#if 0 acc_plist = H5Pcreate(H5P_FILE_ACCESS); VRFY((acc_plist >= 0),""); ret = H5Pset_fapl_mpio(acc_plist,comm,info); VRFY((ret >= 0),"MPIO creation property list succeeded"); +#endif + acc_plist = create_faccess_plist(comm, info, facc_type, use_gpfs); + VRFY((acc_plist >= 0),""); file = H5Fopen(filename, H5F_ACC_RDONLY, acc_plist); VRFY((file >= 0),"H5Fopen succeeded"); @@ -568,6 +579,7 @@ void coll_read_test(int chunk_factor) hid_t acc_plist,xfer_plist; hid_t file, dataseti; /* File and dataset identifiers */ hid_t mspaceid, fspaceid1; /* Dataspace identifiers */ + hbool_t use_gpfs; /* Dimension sizes of the dataset (on disk) */ hsize_t mdim[] = {MSPACE_DIM1, MSPACE_DIM2}; /* Dimension sizes of the @@ -610,12 +622,17 @@ void coll_read_test(int chunk_factor) /*** For testing collective hyperslab selection read ***/ +#if 0 acc_plist = H5Pcreate(H5P_FILE_ACCESS); VRFY((acc_plist >= 0),""); ret = H5Pset_fapl_mpio(acc_plist,comm,info); VRFY((ret >= 0),"MPIO creation property list succeeded"); +#endif + acc_plist = create_faccess_plist(comm, info, facc_type, use_gpfs); + VRFY((acc_plist >= 0),""); + file = H5Fopen(filename, H5F_ACC_RDONLY, acc_plist); VRFY((file >= 0),"H5Fopen succeeded"); |