Go to the source code of this file.
Functions | |
static void | Usage (int line) |
static void | fatal_error (int mpi_ret, MPI_Status *mpi_stat, char *msg) |
static void | print_hints (int rank, MPI_File *mfh) |
static void | fill_buffer (char *buffer, int bufsize, int rank, MPI_Offset offset) |
static MPI_Offset | get_offset (int rank, int num_objs, int obj_size, int which_obj) |
static void | write_file (char *target, int rank, MPI_Info *info) |
static int | reduce_corruptions (int corrupt_blocks) |
static void | read_file (char *target, int rank, MPI_Info *info, int *corrupt_blocks) |
static void | set_hints (MPI_Info *info) |
int | main (int argc, char *argv[]) |
Variables | |
char * | optarg |
int | optind |
int | opterr |
int | optopt |
char * | prog = NULL |
int | debug = 0 |
static void Usage | ( | int | line | ) | [static] |
Definition at line 27 of file aggregation1.c.
References MPI_Comm_rank, prog, and rank.
Referenced by main().
static void fatal_error | ( | int | mpi_ret, | |
MPI_Status * | mpi_stat, | |||
char * | msg | |||
) | [static] |
Definition at line 41 of file aggregation1.c.
References MPI_Abort.
Referenced by main(), read_file(), reduce_corruptions(), and write_file().
Definition at line 47 of file aggregation1.c.
References info, key, MPI_Barrier, MPI_File_get_info, MPI_Info_free(), MPI_Info_get, MPI_Info_get_nkeys, MPI_Info_get_nthkey(), and value.
Referenced by write_file().
static void fill_buffer | ( | char * | buffer, | |
int | bufsize, | |||
int | rank, | |||
MPI_Offset | offset | |||
) | [static] |
Definition at line 72 of file aggregation1.c.
References snprintf().
Referenced by read_file(), and write_file().
static MPI_Offset get_offset | ( | int | rank, | |
int | num_objs, | |||
int | obj_size, | |||
int | which_obj | |||
) | [static] |
Definition at line 78 of file aggregation1.c.
References offset.
Referenced by read_file(), and write_file().
Definition at line 85 of file aggregation1.c.
References debug, fatal_error(), fill_buffer(), get_offset(), MPI_File_close, MPI_File_open(), MPI_File_write_at_all, MPI_MODE_WRONLY, offset, and print_hints().
Referenced by main().
Definition at line 121 of file aggregation1.c.
References fatal_error(), and MPI_Reduce.
Referenced by main().
Definition at line 133 of file aggregation1.c.
References debug, fatal_error(), fill_buffer(), free(), get_offset(), malloc(), MPI_File_close, MPI_File_open(), MPI_File_read_at_all, MPI_MODE_RDONLY, and offset.
Referenced by main().
static void set_hints | ( | MPI_Info * | info | ) | [static] |
Definition at line 178 of file aggregation1.c.
References MPI_Info_set.
Referenced by main().
Definition at line 206 of file aggregation1.c.
References c, debug, fatal_error(), free(), info, MPI_Comm_rank, MPI_Finalize, MPI_Info_create(), MPI_Info_free(), MPI_Init, optarg, prog, rank, read_file(), reduce_corruptions(), set_hints(), strdup(), Usage(), and write_file().
char* prog = NULL |
Definition at line 24 of file aggregation1.c.
Referenced by main(), read_file(), SendMsgBuf(), and write_file().