SIONlib
1.7.7
Scalable I/O library for parallel access to task-local files
|
Go to the source code of this file.
Data Structures | |
struct | _sion_key_stat_struct |
struct | _sion_io_stat_struct |
Macros | |
#define | SION_SERIAL_MASTER |
#define | SION_MAX_FSBLOCKSIZE 32*1024*1024 |
#define | SION_DEFAULT_FSBLOCKSIZE 2*1024*1024 |
#define | SION_FILENAME_LENGTH 1024 |
#define | MAXCHUNKS 100 |
#define | WFLARGEMETABLOCK_none /* for BENCHMARKING only */ |
#define | _sion_stat_file _sion_file_stat_file |
#define | DPRINTF(A) |
#define | DPRINTFP(A) |
#define | DPRINTTS(A, B) |
#define | DPRINTFTS2(A, B) |
Typedefs | |
typedef struct _sion_key_stat_struct | sion_key_stat_t |
typedef struct _sion_io_stat_struct | sion_io_stat_t |
Functions | |
int | _sion_close_sid (int sid) |
size_t | sion_fwrite (const void *data, size_t size, size_t nitems, int sid) |
Write data to sion file. More... | |
size_t | sion_fread (void *data, size_t size, size_t nitems, int sid) |
Read data from sion file. More... | |
size_t | sion_fwrite_key (const void *data, uint64_t key, size_t size, size_t nitems, int sid) |
Writes data for key. More... | |
size_t | sion_fread_key (void *data, uint64_t key, size_t size, size_t nitems, int sid) |
Read data for key. More... | |
int | sion_fread_key_iterator_reset (int sid) |
Resets key iterator. More... | |
int | sion_fread_key_iterator_next (int sid, uint64_t *key, size_t *size) |
Forward to next key. More... | |
int | sion_seek_key (int sid, uint64_t key, int entrynum, sion_int64 posinentry) |
Seek to position in key. More... | |
int | sion_key_full_scan (int sid) |
Performs a full scan of all meta data in current file. More... | |
int | sion_key_list_iterator_reset (int sid) |
Resets key iterator. More... | |
int | sion_key_list_iterator_next (int sid, uint64_t *keyptr) |
Forward to next key. More... | |
int | sion_key_get_stat (int sid, uint64_t key, sion_key_stat_t *stat) |
get statistics about key More... | |
int | sion_feof (int sid) |
Function that indicates whether the end of file is reached for this task. More... | |
int | sion_ensure_free_space (int sid, sion_int64 bytes) |
Funtion to ensure that enough space is available for writing. More... | |
int | sion_flush (int sid) |
Flushed sion file. More... | |
int | sion_get_sizeof (int sid, int *numbytes, int *numfds) |
Function returns size of internal data structure for sid. More... | |
int | sion_dup (int sid, int mode, int rank, uint64_t key) |
Function which duplicates a sion file descriptor. More... | |
int | sion_dedup (int sid) |
Function which destroy a duplicated sion file descriptor. More... | |
int | sion_set_fp_closed (int sid) |
int | sion_set_second_fp (int sid, FILE *fp) |
int | sion_unset_second_fp (int sid) |
FILE * | sion_get_fp (int sid) |
int | sion_get_fd (int sid) |
int | sion_optimize_fp_buffer (int sid) |
int | sion_get_file_endianness (int sid) |
Returns edianness of data in file sid. More... | |
int | sion_endianness_swap_needed (int sid) |
Returns whether or not byte swapping is needed for sid. More... | |
sion_int64 | sion_get_bytes_written (int sid) |
sion_int64 | sion_get_bytes_read (int sid) |
sion_int64 | sion_bytes_avail_in_block (int sid) |
Return the number of bytes available in the current chunk. More... | |
sion_int64 | sion_bytes_avail_in_chunk (int sid) |
Function that returns the number of bytes available in the current chunk. More... | |
sion_int64 | sion_get_position (int sid) |
Function that returns the current file position. More... | |
int | sion_get_mapping (int sid, int *mapping_size, sion_int32 **mapping, int *numfiles) |
Returns pointers to the internal field mapping. More... | |
int | sion_get_locations (int sid, int *ntasks, int *maxblocks, sion_int64 *globalskip, sion_int64 *start_of_varheader, sion_int64 **sion_chunksizes, sion_int64 **sion_globalranks, sion_int64 **sion_blockcount, sion_int64 **sion_blocksizes) |
Returns pointers to internal fields. More... | |
int | sion_get_current_location (int sid, int *currentblock, sion_int64 *currentpos, int *maxchunks, sion_int64 **chunksizes) |
Returns current position in file and pointer fiels containing chunk sizes. More... | |
int | sion_get_current_locations (int sid, int *ntasks, sion_int64 **sion_currentpos, sion_int64 **sion_currentblocknr) |
Returns current position in file and pointer fiels containing chunk sizes. More... | |
int | sion_get_number_of_files (int sid) |
int | sion_get_filenumber (int sid) |
int | sion_is_serial_opened (int sid) |
int | sion_using_hints (int sid) |
int | sion_get_endianness (void) |
Return endianness. More... | |
int | sion_is_thread_safe (void) |
int | sion_get_keyval_mode (int sid) |
Return selected mode for key value. More... | |
char * | sion_keyval_type_to_str (int type) |
Returns key value mode as string. More... | |
int | sion_get_version (int *main_version, int *sub_version, int *patch_level, int *fileformat_version) |
Return version numbers. More... | |
sion_io_stat_t * | sion_get_io_info (int sid) |
sion_io_stat_t * | sion_get_io_info_by_spec (int sid, int roles, int flag) |
int | sion_free_io_info (sion_io_stat_t *info) |
int | sion_seek (int sid, int rank, int currentblocknr, sion_int64 posinblk) |
Function to set the file pointer to a new position. More... | |
int | sion_seek_fp (int sid, int rank, int currentblocknr, sion_int64 posinblk, FILE **fileptr) |
Deprecated. Use sion_seek() instead. More... | |
int | sion_lock_register_lock_callbacks (int lock(void *), int unlock(void *), void *lock_data) |
Function which registers callback funtions for lock and unlock internal access to shared data structures. More... | |
int | sion_lock_user_callbacks_defined (void) |
Function which return flag, if user callback for locking are registered. More... | |
void | sion_swap (void *target, void *source, int size, int n, int do_swap) |
int | _sion_file_stat_file (const char *fname) |
Check if file exists (LARGE_FILE support on BlueGene) More... | |
Common SIONlib functions
Definition in file sion_common.h.
#define MAXCHUNKS 100 |
Initial maximum number of chunks in a sion file
Definition at line 35 of file sion_common.h.
int _sion_file_stat_file | ( | const char * | fname | ) |
Check if file exists (LARGE_FILE support on BlueGene)
*fname | filename to use |
0
or 1
Definition at line 318 of file sion_file.c.
References _sion_file_stat_file2(), and SION_FILE_FLAG_POSIX.
sion_int64 sion_bytes_avail_in_block | ( | int | sid | ) |
Return the number of bytes available in the current chunk.
See sion_bytes_avail_in_block_description.
[in] | sid | sion file handle |
Definition at line 879 of file sion_common.c.
References sion_bytes_avail_in_chunk().
Referenced by fsion_bytes_avail_in_block_c().
sion_int64 sion_bytes_avail_in_chunk | ( | int | sid | ) |
Function that returns the number of bytes available in the current chunk.
This function returns the number of bytes remaining in the current chunk (bytes not read). It is a local function, which can be called independently from other MPI tasks.
[in] | sid | sion file handle |
Definition at line 894 of file sion_common.c.
Referenced by sion_bytes_avail_in_block().
int sion_dedup | ( | int | sid | ) |
Function which destroy a duplicated sion file descriptor.
[in] | sid | sion file handle |
Definition at line 1195 of file sion_common.c.
int sion_dup | ( | int | sid, |
int | mode, | ||
int | rank, | ||
uint64_t | key | ||
) |
Function which duplicates a sion file descriptor.
Restrictions:
[in] | sid | sion file handle |
[in] | mode | one of SION_DUP_ALL, SION_DUP_RANK, SION_DUP_RANK_KEY |
[in] | rank | dup only those part of the internal data struture which are needed to read rank rank from file |
[in] | key | dup only those part of the internal data struture which are needed to read on the rank rank data for key key from file |
Definition at line 1161 of file sion_common.c.
int sion_ensure_free_space | ( | int | sid, |
sion_int64 | bytes | ||
) |
Funtion to ensure that enough space is available for writing.
See sion_ensure_free_space_description
[in] | sid | sion file handle |
[in] | bytes | number of bytes requested for the next write operation |
Definition at line 1053 of file sion_common.c.
Referenced by fsion_ensure_free_space_c().
int sion_feof | ( | int | sid | ) |
Function that indicates whether the end of file is reached for this task.
[in] | sid | sion file handle (in) |
Definition at line 809 of file sion_common.c.
Referenced by fsion_feof_c().
int sion_flush | ( | int | sid | ) |
Flushed sion file.
[in] | sid | sion file handle |
Definition at line 1030 of file sion_common.c.
Referenced by fsion_flush_c().
int sion_get_endianness | ( | void | ) |
Return endianness.
Definition at line 32 of file sion_tools.c.
Referenced by fsion_get_endianness_c().
sion_int64 sion_get_position | ( | int | sid | ) |
Function that returns the current file position.
This function returns an sion_int64 containing the current file possition.
[in] | sid | sion file handle (in) |
Definition at line 930 of file sion_common.c.
References _sion_vcdtovcon(), _sion_vcdtype(), and SION_FILEDESCRIPTOR.
Referenced by fsion_get_position_c().
int sion_get_sizeof | ( | int | sid, |
int * | numbytes, | ||
int * | numfds | ||
) |
Function returns size of internal data structure for sid.
[in] | sid | sion file handle |
[out] | numbytes | number of bytes used |
[out] | numfds | number of file descriptors used |
Definition at line 1123 of file sion_common.c.
int sion_get_version | ( | int * | main_version, |
int * | sub_version, | ||
int * | patch_level, | ||
int * | fileformat_version | ||
) |
int sion_lock_register_lock_callbacks | ( | int | lockvoid *, |
int | unlockvoid *, | ||
void * | lock_data | ||
) |
Function which registers callback funtions for lock and unlock internal access to shared data structures.
[in] | lock() | lock function |
[in] | unlock() | unlock function |
[in] | lock_data() | unlock function |
Definition at line 1220 of file sion_common.c.
int sion_lock_user_callbacks_defined | ( | void | ) |
Function which return flag, if user callback for locking are registered.
Definition at line 1239 of file sion_common.c.
int sion_seek | ( | int | sid, |
int | rank, | ||
int | currentblocknr, | ||
sion_int64 | posinblk | ||
) |
Function to set the file pointer to a new position.
See sion_seek_description .
[in] | sid | sion file handle |
[in] | rank | rank number of the process (SION_CURRENT_RANK to select the current rank) |
[in] | currentblocknr | block number (SION_CURRENT_BLK to select the current block) (SION_ABSOLUTE_POS gives an absolute position; SION_END_POS seeks relative to the end of the file) |
[in] | posinblk | position in the block (SION_CURRENT_POS to select the current position) |
SION_SUCCESS | if file pointer can be moved to new position |
Definition at line 698 of file sion_common.c.
References sion_seek_fp().
int sion_seek_fp | ( | int | sid, |
int | rank, | ||
int | currentblocknr, | ||
sion_int64 | posinblk, | ||
FILE ** | fileptr | ||
) |
Deprecated. Use sion_seek() instead.
See sion_seek_fp_description .
[in] | sid | sion file handle |
[in] | rank | rank number of the process (SION_CURRENT_RANK to select the current rank) |
[in] | currentblocknr | block number (SION_CURRENT_BLK to select the current block) |
[in] | posinblk | position in the block (SION_CURRENT_POS to select the current position) |
[out] | **fileptr | file pointer to corresponding file of a multi-file set |
SION_SUCCESS | if file pointer can be moved to new position |
Definition at line 721 of file sion_common.c.
Referenced by sion_seek().
void sion_swap | ( | void * | target, |
void * | source, | ||
int | size, | ||
int | n, | ||
int | do_swap | ||
) |
@ brief Perform byte-order swapping for arrays
n
elements of size
bytes each are swapped if do_swap
is true
. In-place swapping (target == source
) is allowed. If target != source
, the buffers must not overlap.
[out] | target | the byte-swapped data is written starting at this address |
[in] | source | the data to be byte-swapped is read starting at this address |
[in] | size | the size (in bytes) of a single element |
[in] | n | the number of elements to be byte-swapped |
[in] | do_swap | byte-swapping is only performed if this argument is true |
Definition at line 44 of file sion_convert.c.
Referenced by fsion_swap_c().