
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().
1.5.5