mirror/netcdf-c
2
0
Fork 0
mirror of https://github.com/Unidata/netcdf-c.git synced 2025-02-17 16:50:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

nc_create_par() and nc_open_par() implies parallel I/O, so

Browse Source 
using NC_MPIIO or NC_MPIPOSIX explicitly is not necessary.
These 2 subroutines call NC_create() and NC_open() with argument
useparallel set to 1, which should be used to tell which I/O
driver to use underneath.
This commit is contained in:
Wei-keng Liao 2018-09-16 18:15:15 -05:00
parent 329a44f911
commit a537312895
1 changed files with 22 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
libdispatch/dparallel.c
View File

@ -31,7 +31,7 @@ errors, it simply stops their display to the user through stderr.
NC_NOCLOBBER (do not overwrite existing file),
NC_NETCDF4 (create netCDF-4/HDF5 file),
NC_CLASSIC_MODEL (enforce netCDF classic mode on netCDF-4/HDF5 files),
NC_PNETCDF.
NC_PNETCDF (alias of NC_MPIIO, to create CDF-1, 2, or 5 file).
\param comm the MPI communicator to be used.
@ -42,6 +42,7 @@ stored.
\returns ::NC_NOERR No error.
\returns ::NC_ENOPAR Library was not built with parallel I/O features.
\returns ::NC_ENOTBUILT Library was not built with NETCDF4 or PnetCDF.
\returns ::NC_EINVAL Invalid input parameters.
\returns ::NC_ENOMEM System out of memory.
\returns ::NC_ENOTNC Binary format could not be determined.
@ -66,8 +67,7 @@ parallel I/O.
MPI_Comm_rank(MPI_COMM_WORLD, &mpi_rank);
sprintf(file_name, "%s/%s", TEMP_LARGE, FILE);
if ((res = nc_create_par(file_name, NC_NETCDF4|NC_MPIIO, comm,
info, &ncid))) ERR;
if ((res = nc_create_par(file_name, NC_NETCDF4, comm, info, &ncid))) ERR;
if (nc_def_dim(ncid, "d1", DIMSIZE, dimids)) ERR;
if (nc_def_dim(ncid, "d2", DIMSIZE, &dimids[1])) ERR;
@ -87,21 +87,26 @@ parallel I/O.
int nc_create_par(const char *path, int cmode, MPI_Comm comm,
MPI_Info info, int *ncidp)
{
NC_MPI_INFO data;
#ifndef USE_PARALLEL
return NC_ENOPAR;
#else
NC_MPI_INFO data;
#endif
/* One of these two parallel IO modes must be chosen by the user,
* or else pnetcdf must be in use. */
if (!(cmode & NC_MPIIO || cmode & NC_MPIPOSIX) &&
!(cmode & NC_PNETCDF))
return NC_EINVAL;
#ifndef USE_PNETCDF
/* PnetCDF is disabled but user wants to create classic file in parallel */
if ((cmode & NC_PNETCDF) && !(cmode & NC_NETCDF4))
return NC_ENOTBUILT;
#endif
#ifndef USE_NETCDF4
/* NETCDF4 is disabled but user wants to create NETCDF4 file in parallel */
if (cmode & NC_NETCDF4)
return NC_ENOTBUILT;
#endif
data.comm = comm;
data.info = info;
return NC_create(path, cmode, 0, 0, NULL, 1, &data, ncidp);
#endif /* USE_PARALLEL */
}
/**
@ -148,6 +153,8 @@ occurred. Otherwise, the returned status indicates an error. Possible
causes of errors include:
\returns ::NC_NOERR No error.
\returns ::NC_ENOPAR Library was not built with parallel I/O features.
\returns ::NC_ENOTBUILT Library was not built with NETCDF4 or PnetCDF.
\returns ::NC_EINVAL Invalid parameters.
\returns ::NC_ENOTNC Not a netCDF file.
\returns ::NC_ENOMEM Out of memory.
@ -167,35 +174,25 @@ Here is an example using nc_open_par() from examples/C/parallel_vara.c.
int ncid, omode;
char filename[128];
...
omode = NC_PNETCDF | NC_NOWRITE;
omode = NC_NOWRITE;
err = nc_open_par(filename, omode, MPI_COMM_WORLD, MPI_INFO_NULL, &ncid); FATAL_ERR
\endcode
\author Ed Hartnett, Dennis Heimbigner
\ingroup datasets
*/
int
nc_open_par(const char *path, int mode, MPI_Comm comm,
nc_open_par(const char *path, int omode, MPI_Comm comm,
MPI_Info info, int *ncidp)
{
#ifndef USE_PARALLEL
return NC_ENOPAR;
#else
#endif
NC_MPI_INFO mpi_data;
/* One of these two parallel IO modes must be chosen by the user,
* or else pnetcdf must be in use. */
if ((mode & NC_MPIIO) || (mode & NC_MPIPOSIX)) {
/* ok */
} else if(mode & NC_PNETCDF) {
/* ok */
} else
return NC_EINVAL;
mpi_data.comm = comm;
mpi_data.info = info;
return NC_open(path, mode, 0, NULL, 1, &mpi_data, ncidp);
#endif /* USE_PARALLEL */
return NC_open(path, omode, 0, NULL, 1, &mpi_data, ncidp);
}
/**