redset.h

Go to the documentation of this file.

#ifndef REDSET_H
#define REDSET_H
 
#include "mpi.h"
 
/* enable C++ codes to include this header directly */
#ifdef __cplusplus
extern "C" {
#endif
 
#define REDSET_SUCCESS (0)
 
#define REDSET_VERSION "0.1.0"
 
#define REDSET_COPY_NULL    (0)
#define REDSET_COPY_SINGLE  (1)
#define REDSET_COPY_PARTNER (2)
#define REDSET_COPY_XOR     (3)
#define REDSET_COPY_RS      (4)
 
/* names of user settable config parameters */
#define REDSET_KEY_CONFIG_SET_SIZE  "SETSIZE"
#define REDSET_KEY_CONFIG_MPI_BUF_SIZE "MPI_BUF_SIZE"
#define REDSET_KEY_CONFIG_DEBUG "DEBUG"
 
/********************************************************/
typedef void* redset;
typedef void* redset_filelist;
 
/********************************************************/
 
int redset_init(void);
 
int redset_finalize(void);
 
/* needs to be above doxygen comment to get association right */
typedef struct kvtree_struct kvtree;
 
kvtree* redset_config(
  const kvtree *config 
);
 
int redset_create(
  int type,          
  MPI_Comm comm,     
  const char* group, 
  redset* d          
);
 
int redset_create_single(
  MPI_Comm comm,     
  const char* group, 
  redset* d          
);
 
int redset_create_partner(
  MPI_Comm comm,     
  const char* group, 
  int size,          
  int replicas,      
  redset* d          
);
 
int redset_create_xor(
  MPI_Comm comm,     
  const char* group, 
  int size,          
  redset* d          
);
 
int redset_create_rs(
  MPI_Comm comm,     
  const char* group, 
  int size,          
  int k,             
  redset* d          
);
 
int redset_delete(
  redset* d 
);
 
int redset_apply(
  int numfiles,       
  const char** files, 
  const char* name,   
  const redset d      
);
 
int redset_recover(
  MPI_Comm comm,    
  const char* name, 
  redset* d         
);
 
int redset_unapply(
  const char* name, 
  const redset d    
);
 
redset_filelist redset_filelist_get(
  const char* name, 
  const redset d    
);
 
int redset_filelist_release(
  redset_filelist* plist 
);
 
int redset_filelist_count(
  redset_filelist list 
);
 
const char* redset_filelist_file(
  redset_filelist list, 
  int index             
);
 
/************************
 * The interfaces below are temporary.
 ***********************/
 
redset_filelist redset_filelist_get_data_partner(
  int num,
  const char** files,
  int* groupsize,
  int** groupranks
);
 
int redset_rebuild_partner(
  int num,
  const char** files,
  const char* prefix,
  const kvtree* map
);
 
redset_filelist redset_filelist_get_data_xor(
  int num,
  const char** files,
  int* groupsize,
  int** groupranks
);
 
int redset_rebuild_xor(
  int num,
  const char** files,
  const char* prefix,
  const kvtree* map
);
 
redset_filelist redset_filelist_get_data_rs(
  int num,
  const char** files,
  int* groupsize,
  int** groupranks
);
 
int redset_rebuild_rs(
  int num,
  const char** files,
  const char* prefix,
  const kvtree* map
);
 
/* enable C++ codes to include this header directly */
#ifdef __cplusplus
} /* extern "C" */
#endif
 
#endif /* REDSET_H */