diff options
author | Sree Harsha Totakura <totakura@in.tum.de> | 2012-12-08 11:13:47 +0000 |
---|---|---|
committer | Sree Harsha Totakura <totakura@in.tum.de> | 2012-12-08 11:13:47 +0000 |
commit | 3b44ddf34ee8b813c3dc14ce5c73fd789803ad14 (patch) | |
tree | ded0c967a21725c5bbae576c7ac1cb98718668b9 /src/testbed/gnunet_mpi_test.c | |
parent | 13864cde0bea742601077cdbf8201599dc9e0afd (diff) | |
download | gnunet-3b44ddf34ee8b813c3dc14ce5c73fd789803ad14.tar.gz gnunet-3b44ddf34ee8b813c3dc14ce5c73fd789803ad14.zip |
- reverting to include MPI code
Diffstat (limited to 'src/testbed/gnunet_mpi_test.c')
-rw-r--r-- | src/testbed/gnunet_mpi_test.c | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/src/testbed/gnunet_mpi_test.c b/src/testbed/gnunet_mpi_test.c index 9229675ce..1e1608228 100644 --- a/src/testbed/gnunet_mpi_test.c +++ b/src/testbed/gnunet_mpi_test.c | |||
@@ -1,5 +1,6 @@ | |||
1 | #include "platform.h" | 1 | #include "platform.h" |
2 | #include "gnunet_util_lib.h" | 2 | #include "gnunet_util_lib.h" |
3 | #include <mpi.h> | ||
3 | 4 | ||
4 | /** | 5 | /** |
5 | * Generic logging shorthand | 6 | * Generic logging shorthand |
@@ -13,15 +14,21 @@ int main (int argc, char *argv[]) | |||
13 | char *filename; | 14 | char *filename; |
14 | pid_t pid; | 15 | pid_t pid; |
15 | pid_t ppid; | 16 | pid_t ppid; |
17 | int ntasks; | ||
16 | int rank; | 18 | int rank; |
17 | int msg_size; | 19 | int msg_size; |
18 | int ret; | 20 | int ret; |
19 | 21 | ||
20 | ret = GNUNET_SYSERR; | 22 | ret = GNUNET_SYSERR; |
21 | rank = 0; | 23 | if (MPI_SUCCESS != MPI_Init (&argc, &argv)) |
24 | return 1; | ||
25 | if (MPI_SUCCESS != MPI_Comm_size (MPI_COMM_WORLD, &ntasks)) | ||
26 | goto finalize; | ||
27 | if (MPI_SUCCESS != MPI_Comm_rank (MPI_COMM_WORLD, &rank)) | ||
28 | goto finalize; | ||
22 | pid = getpid(); | 29 | pid = getpid(); |
23 | (void) GNUNET_asprintf (&filename, "%d-%d.mpiout", (int) pid, rank); | 30 | (void) GNUNET_asprintf (&filename, "%d-%d.mpiout", (int) pid, rank); |
24 | msg_size = GNUNET_asprintf (&msg, "My pid is: %d\n", pid); | 31 | msg_size = GNUNET_asprintf (&msg, "My rank is: %d\n", rank); |
25 | printf ("%s", msg); | 32 | printf ("%s", msg); |
26 | if (msg_size == GNUNET_DISK_fn_write (filename, | 33 | if (msg_size == GNUNET_DISK_fn_write (filename, |
27 | msg, msg_size, | 34 | msg, msg_size, |
@@ -84,5 +91,6 @@ int main (int argc, char *argv[]) | |||
84 | ret = GNUNET_OK; | 91 | ret = GNUNET_OK; |
85 | 92 | ||
86 | finalize: | 93 | finalize: |
94 | (void) MPI_Finalize (); | ||
87 | return (GNUNET_OK == ret) ? 0 : 1; | 95 | return (GNUNET_OK == ret) ? 0 : 1; |
88 | } | 96 | } |