ompi_partest.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 OMPI_PARTEST_H_
#define OMPI_PARTEST_H_
 
/* Enable or disable the checksum */
#define CHECKSUM
#define FNAMELEN 255
#define MB *1024*1024
#define MAXPE 28*64*1024
#define MAXCHARLEN 256
 
#define WAKEUP   102
#define COLPRINT 103
 
#include "partest_opts.h"
 
struct _test_communicators_struct {
  MPI_Comm all;             /* all tasks in mpi program */
  MPI_Comm work;            /* all working tasks, e.g. if bluegene_np is used */
  MPI_Comm workread;        /* all working tasks, shifted by read_task_offset, e.g. if bluegene_np is used */
  MPI_Comm local;           /* tasks which should work on the same file */
  int all_size, all_rank, work_size, work_rank, workread_size, workread_rank, local_size, local_rank;
  int file_number, ionode_number;
};
 
typedef struct _test_communicators_struct _test_communicators;
 
#ifdef SION_OMPI
int test_paropen_multi_ompi (char *filename,
                char *localbuffer,
                            _test_communicators *communicators,
                _test_options *options
);
#endif /* SION_OMPI */
#ifdef SION_OMP
int test_paropen_omp (char *filename,
                char *localbuffer,
                            _test_communicators *communicators,
                _test_options *options
);
#endif /* SION_OMPI */
 
 
int barrier_after_start (MPI_Comm comm);
int barrier_after_malloc(MPI_Comm comm);
int barrier_after_open  (MPI_Comm comm);
int barrier_after_write (MPI_Comm comm);
int barrier_after_read  (MPI_Comm comm);
int barrier_after_close (MPI_Comm comm);
int barrier_before_unlink (MPI_Comm comm);
int barrier_after_unlink (MPI_Comm comm);
 
int collective_print_gather ( char* cbuffer, MPI_Comm comm);
 
 
/* Arguments for dtype in reduce_omp*/
#define _PARTEST_SION_INT32     10
#define _PARTEST_SION_INT64     11
#define _PARTEST_DOUBLE    12
void reduce_omp(void *syncdata, void * out, MPI_Op op, int dtype);
 
 
 
#endif /* PARTEST_H_ */