Internal Functions(parallel) More...

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include "sion.h"
#include "sion_debug.h"
#include "sion_error_handler.h"
#include "sion_file.h"
#include "sion_filedesc.h"
#include "sion_fd.h"
#include "sion_metadata.h"
#include "sion_internal.h"
#include "sion_printts.h"
#include "sion_keyvalue.h"
#include "sion_flags.h"
#include "sion_cache.h"
#include "sion_buffer.h"
#include "sion_hints.h"
#include "sion_generic_internal.h"
#include "sion_generic_collective.h"
#include "sion_generic_buddy.h"

Include dependency graph for sion_generic_internal.c:

Macros
#define	BGFLUSH

#define	DFUNCTION "_sion_generic_collect_mapping"
	collect mapping information on rank 0 of first file, mapping=NULL for all others More...

Functions
int	_sion_paropen_generic_one_file (int sid, char fname, _sion_flags_store flags_store, char prefix, int numFiles, int filenumber, sion_int64 chunksize, sion_int32 fsblksize, int rank, int ntasks, int globalrank, int flag, FILE *fileptr, _sion_generic_gendata sion_gendata, _sion_generic_buddy *buddy_data)
	Generic parallel open of one direct access file. More...

int	_sion_parclose_generic (int sid, int rank, int ntasks, int mapping_size, sion_int32 mapping, int flag, _sion_generic_gendata sion_gendata, _sion_generic_buddy *buddy_data)
	Internal function to close parallel opened SION file. More...

int	_sion_parreinit_generic (int sid, sion_int64 chunksize, int rank, int ntasks, _sion_generic_gendata *sion_gendata)
	change chunksize for an already opened SION file (write) More...

int	_sion_generic_collect_mapping (_sion_filedesc sion_filedesc, int mapping_size, sion_int32 **mapping)

Detailed Description

Internal Functions(parallel)

Date: Sep 2, 2008

Author: gstu0808

Definition in file sion_generic_internal.c.

Macro Definition Documentation

◆ DFUNCTION

#define DFUNCTION "_sion_generic_collect_mapping"

collect mapping information on rank 0 of first file, mapping=NULL for all others

Returns: 1 if successful

Definition at line 1001 of file sion_generic_internal.c.

Function Documentation

◆ _sion_parclose_generic()

int _sion_parclose_generic	(	int	sid,
		int	rank,
		int	ntasks,
		int	mapping_size,
		sion_int32 *	mapping,
		int	flag,
		_sion_generic_gendata *	sion_gendata,
		_sion_generic_buddy *	buddy_data
	)

Internal function to close parallel opened SION file.

Parameters

sid	reference to file description struct (_sion_filedesc)
rank	rank
ntasks	number of tasks
mapping_size	number of global tasks
mapping	mapping
flag	flag describing the role if the process in buddy checkpointing
sion_gendata	generic data struct
buddy_data	data describing the buddy checkpointing

Returns: SION_SUCCESS if successful

Definition at line 689 of file sion_generic_internal.c.

◆ _sion_paropen_generic_one_file()

int _sion_paropen_generic_one_file	(	int	sid,
		char *	fname,
		_sion_flags_store *	flags_store,
		char *	prefix,
		int *	numFiles,
		int *	filenumber,
		sion_int64 *	chunksize,
		sion_int32 *	fsblksize,
		int	rank,
		int	ntasks,
		int *	globalrank,
		int	flag,
		FILE **	fileptr,
		_sion_generic_gendata *	sion_gendata,
		_sion_generic_buddy *	buddy_data
	)

Generic parallel open of one direct access file.

Parameters

sid	sion file handle
fname	filename to use
flags_store	flags from already parsed file_mode (see also sion_internal.h)
prefix	prefix to be used in case of multiple files
numFiles	Number of files to open
filenumber	file number
chunksize	chunksize on this task
fsblksize	blocksize of filesystem (must be equal on all processors)
rank	rank of the current process
ntasks	number of processes
globalrank	any global unique id for this task, will be stored in sion file, usefull if comm is not MPI_COMM_WORLD typical: globalrank= rank in MPI_COMM_WORLD
flag	sion options flag
fileptr	filepointer for this task
sion_gendata	structure, containing references to commgroups and callbacks
buddy_data	data describing the buddy checkpointing

Returns: sion file handle -1 if error occured

Definition at line 65 of file sion_generic_internal.c.

◆ _sion_parreinit_generic()

int _sion_parreinit_generic	(	int	sid,
		sion_int64	chunksize,
		int	rank,
		int	ntasks,
		_sion_generic_gendata *	sion_gendata
	)

change chunksize for an already opened SION file (write)

Returns: 1 if successful

Definition at line 865 of file sion_generic_internal.c.

Macros