sion_generic.h

/****************************************************************************
**  SIONLIB     http://www.fz-juelich.de/jsc/sionlib                       **
*****************************************************************************
**  Copyright (c) 2008-2019                                                **
**  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);

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_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);

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