sion_generic.h

/****************************************************************************
**  SIONLIB     http://www.fz-juelich.de/jsc/sionlib                       **
*****************************************************************************
**  Copyright (c) 2008-2021                                                **
**  Forschungszentrum Juelich, Juelich Supercomputing Centre               **
**                                                                         **
**  See the file COPYRIGHT in the package base directory for details       **
****************************************************************************/
 
#ifndef SION_SION_GENERIC_H
#define SION_SION_GENERIC_H
 
#include <stdbool.h>
#include <stdint.h>
#include <stdio.h>
 
#include "sion_enums.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef int (*sion_create_lcg_cb)(
  void **local_commgroup, void *global_commgroup, int grank, int gsize, int lrank, int lsize, int filenumber, int numfiles);
 
typedef int (*sion_free_lcg_cb)(void *local_commgroup);
 
typedef int (*sion_barrier_cb)(void *commgroup);
 
typedef int (*sion_bcastr_cb)(void *data, void *commgroup, int datatype, int nelem, int root);
 
typedef int (*sion_gatherr_cb)(void *indata, void *outdata, void *commgroup, int datatype, int nelem, int root);
 
typedef int (*sion_gathervr_cb)(void *indata, void *outdata, void *commdata, int datatype, int *count, int nelem, int root);
 
typedef int (*sion_scatterr_cb)(void *indata, void *outdata, void *commgroup, int datatype, int nelem, int root);
 
typedef int (*sion_scattervr_cb)(void *indata, void *outdata, void *commgroup, int datatype, int *count, int nelem, int root);
 
typedef char *(*sion_get_multi_filename_cb)(const char *, int);
 
typedef int64_t (*sion_gather_execute_cb)(const void *, int64_t, void *, int, int, int, int,
  int64_t process_cb(const void *, int64_t *, int), void *, bool spec_iterator_cb(void *, int64_t *));
 
typedef int64_t (*sion_execute_scatter_cb)(void *, int64_t, void *, int, int, int, int,
  int64_t process_cb(void *, int64_t *, int), void *, bool spec_iterator_cb(void *, int64_t *));
 
typedef int (*sion_get_capability_cb)(void *);
 
int sion_generic_create_api(char *name);
 
int sion_generic_free_api(int aip);
 
int sion_generic_register_create_local_commgroup_cb(int aid, sion_create_lcg_cb cb);
 
int sion_generic_register_free_local_commgroup_cb(int aid, sion_free_lcg_cb cb);
 
int sion_generic_register_barrier_cb(int aid, sion_barrier_cb cb);
 
int sion_generic_register_bcastr_cb(int aid, sion_bcastr_cb cb);
 
int sion_generic_register_gatherr_cb(int aid, sion_gatherr_cb cb);
 
int sion_generic_register_gathervr_cb(int aid, sion_gathervr_cb cb);
 
int sion_generic_register_scatterr_cb(int aid, sion_scatterr_cb cb);
 
int sion_generic_register_scattervr_cb(int aid, sion_scattervr_cb cb);
 
int sion_generic_register_get_multi_filename_cb(int aid, sion_get_multi_filename_cb cb);
 
int sion_generic_register_gather_and_execute_cb(int aid, sion_gather_execute_cb cb);
 
int sion_generic_register_execute_and_scatter_cb(int aid, sion_execute_scatter_cb cb);
 
int sion_generic_register_get_capability_cb(int aid, sion_get_capability_cb cb);
 
typedef struct sion_generic_options sion_generic_options;
 
int sion_generic_paropen(int aid, const char *filename, sion_open_mode mode, void *gcommgroup, int grank, int gsize,
  int filenumber, int numfiles, int lrank, int lsize, const sion_generic_options *options);
 
int sion_generic_parclose(int sid);
 
typedef struct sion_generic_mapped_options sion_generic_mapped_options;
 
int sion_generic_paropen_mapped(int aid, char *fname, const char *file_mode, int *numFiles, void *gcommgroup, int grank,
  int gsize, int *nlocaltasks, int **globalranks, int64_t **chunksizes, int **mapping_filenrs, int **mapping_lranks,
  int32_t *fsblksize, FILE **fileptr);
 
int sion_generic_paropen_mapped_with_options(int aid, const char *fname, sion_open_mode mode, int numfiles, void *gcommgroup,
  int grank, int gsize, int ntasks, const int *globalranks, const int *filenumbers, const int *localranks,
  const sion_generic_mapped_options *options_);
 
int sion_generic_parclose_mapped(int sid);
 
int sion_generic_parreinit(int sid, int64_t chunksize);
 
sion_generic_options *sion_generic_options_new();
 
void sion_generic_options_delete(sion_generic_options *options);
 
void sion_generic_options_set_chunksize(sion_generic_options *options, int64_t chunksize);
 
void sion_generic_options_set_fsblksize(sion_generic_options *options, int32_t fsblksize);
 
void sion_generic_options_set_keyval_mode(sion_generic_options *options, sion_keyval_mode keyval_mode);
 
void sion_generic_options_set_buddy(sion_generic_options *options);
 
void sion_generic_options_set_buddylevel(sion_generic_options *options, int32_t buddylevel);
 
void sion_generic_options_set_collective(sion_generic_options *options);
 
void sion_generic_options_set_collective_size(sion_generic_options *options, int32_t size);
 
void sion_generic_options_set_collective_merge(sion_generic_options *options);
 
void sion_generic_options_set_lowlevel_api(sion_generic_options *options, sion_lowlevel_api lowlevel_api);
 
void sion_generic_options_set_endianness(sion_generic_options *options, sion_endianness endianness);
 
sion_generic_mapped_options *sion_generic_mapped_options_new();
 
void sion_generic_mapped_options_delete(sion_generic_mapped_options *options);
 
void sion_generic_mapped_options_set_chunksizes(sion_generic_mapped_options *options, int64_t *chunksizes);
 
void sion_generic_mapped_options_set_fsblksize(sion_generic_mapped_options *options, int32_t fsblksize);
 
void sion_generic_mapped_options_set_keyval_mode(sion_generic_mapped_options *options, sion_keyval_mode keyval_mode);
 
void sion_generic_mapped_options_set_lowlevel_api(sion_generic_mapped_options *options, sion_lowlevel_api lowlevel_api);
 
void sion_generic_mapped_options_set_endianness(sion_generic_mapped_options *options, sion_endianness endianness);
 
size_t sion_coll_write(const void *data, size_t size, size_t nitems, int sid);
 
size_t sion_coll_fwrite(const void *data, size_t size, size_t nitems, int sid);
 
size_t sion_coll_read(void *data, size_t size, size_t nitems, int sid);
 
size_t sion_coll_fread(void *data, size_t size, size_t nitems, int sid);
 
 
#ifdef __cplusplus
}
#endif
 
 
#endif