SIONlib
1.7.7
Scalable I/O library for parallel access to task-local files
|
#include <stdio.h>
#include "mpi.h"
#include "sion_const.h"
#include "sion_datatypes.h"
#include "sion_datatypes_mpi.h"
Go to the source code of this file.
Typedefs | |
typedef struct _sion_file_check_par_args_mpi_struct | sion_file_check_par_args_mpi |
Functions | |
int | sion_paropen_mpi (const char *fname, const char *file_mode, int *numFiles, MPI_Comm gComm, const MPI_Comm *lComm, sion_int64 *chunksize, sion_int32 *fsblksize, int *globalrank, FILE **fileptr, char **newfname) |
Open a sion file using MPI. More... | |
int | sion_parclose_mpi (int sid) |
Close a sion file using MPI. More... | |
int | sion_parreinit_mpi (int sid, sion_int64 chunksize) |
int | sion_paropen_mapped_mpi (char *fname, const char *file_mode, int *numFiles, MPI_Comm gComm, int *nlocaltasks, int **globalranks, sion_int64 **chunksizes, int **mapping_filenrs, int **mapping_lranks, sion_int32 *fsblksize, FILE **fileptr) |
int | sion_parclose_mapped_mpi (int sid) |
int | sion_startof_transaction_mpi (int sid) |
int | sion_endof_transaction_mpi (int sid) |
size_t | sion_coll_fwrite_mpi (const void *data, size_t size, size_t nitems, int sid) |
size_t | sion_coll_fread_mpi (void *data, size_t size, size_t nitems, int sid) |
int | sion_paropen_comms_mpi (char *fname, const char *file_mode, int *numFiles, MPI_Comm gComm, MPI_Comm lComm, sion_int64 *chunksize, sion_int32 *fsblksize, int *globalrank, FILE **fileptr, char *newfname) |
int | sion_paropen_multi_mpi (char *fname, const char *file_mode, int *numFiles, MPI_Comm gComm, MPI_Comm *lComm, sion_int64 *chunksize, sion_int32 *fsblksize, int *globalrank, FILE **fileptr, char *newfname) |
sion_file_check_par_args_mpi * | sion_file_check_par_args_init_mpi (const char *file_mode, MPI_Comm gComm, int numfiles, MPI_Comm lComm) |
int | sion_file_check_par_args_free_mpi (sion_file_check_par_args_mpi *args) |
int | sion_file_check_par_cb_mpi (char *fname, void *args) |
Definition in file sion_mpi.h.
int sion_parclose_mpi | ( | int | sid | ) |
Close a sion file using MPI.
For more description please see the description of sion_parclose_mpi.
[in] | sid | sion file handle |
success | value (SION_SUCCESS or SION_NOT_SUCCESS) |
Definition at line 230 of file sion_mpi_gen.c.
Referenced by fsion_parclose_mpi_c().
int sion_paropen_mpi | ( | const char * | fname, |
const char * | file_mode, | ||
int * | numFiles, | ||
MPI_Comm | gComm, | ||
const MPI_Comm * | lComm, | ||
sion_int64 * | chunksize, | ||
sion_int32 * | fsblksize, | ||
int * | globalrank, | ||
FILE ** | fileptr, | ||
char ** | newfname | ||
) |
Open a sion file using MPI.
This function opens a sion file using MPI. It processes the MPI specific parts and then passes its arguments on to sion_generic_paropen().
For more description please see the description of sion_paropen_mpi.
[in] | fname | name of file, should be equal on all tasks |
[in] | file_mode | like the type parameter of fopen. See file mode description for details |
[in,out] | numFiles | number of multi files to use (-1 for automatic choosing from local communicator) |
[in] | gComm | global MPI communicator (typically MPI_COMM_WORLD) |
[in] | lComm | local MPI communicator (= gComm if no adaption to I/O nodes is needed) lComm should be a partition of gComm, i.e. a disjoint cover |
[in,out] | chunksize | maximum size to be written with single write call |
[in,out] | fsblksize | file system block size. Must be equal on all processes (-1 for automatic) |
[in,out] | globalrank | global rank of process any globally unique id for current task. It will be stored in sion file. Useful if comm is not MPI_COMM_WORLD (typically: globalrank = rank in MPI_COMM_WORLD) |
[out] | fileptr | file pointer (NULL for not using an external which allows for more optimisation) |
[out] | newfname | return value for actual file name if using multi files. NULL does not return the name. If passed non NULL pointer the memory needs to be freed by the user. |
sid | sion file handle or -1 if error occurred |
Definition at line 85 of file sion_mpi_gen.c.
Referenced by fsion_paropen_mpi_c().