diff options
Diffstat (limited to 'src/testbed/gnunet_mpi_test.c')
-rw-r--r-- | src/testbed/gnunet_mpi_test.c | 120 |
1 files changed, 60 insertions, 60 deletions
diff --git a/src/testbed/gnunet_mpi_test.c b/src/testbed/gnunet_mpi_test.c index 1c2696048..e0caf9676 100644 --- a/src/testbed/gnunet_mpi_test.c +++ b/src/testbed/gnunet_mpi_test.c | |||
@@ -6,10 +6,10 @@ | |||
6 | * Generic logging shorthand | 6 | * Generic logging shorthand |
7 | */ | 7 | */ |
8 | #define LOG(kind, ...) \ | 8 | #define LOG(kind, ...) \ |
9 | GNUNET_log_from(kind, "gnunet-mpi-test", __VA_ARGS__) | 9 | GNUNET_log_from (kind, "gnunet-mpi-test", __VA_ARGS__) |
10 | 10 | ||
11 | int | 11 | int |
12 | main(int argc, char *argv[]) | 12 | main (int argc, char *argv[]) |
13 | { | 13 | { |
14 | char *msg; | 14 | char *msg; |
15 | char *filename; | 15 | char *filename; |
@@ -26,82 +26,82 @@ main(int argc, char *argv[]) | |||
26 | 26 | ||
27 | ret = GNUNET_SYSERR; | 27 | ret = GNUNET_SYSERR; |
28 | if (argc < 2) | 28 | if (argc < 2) |
29 | { | 29 | { |
30 | printf("Need arguments: gnunet-mpi-test <cmd> <cmd_args>"); | 30 | printf ("Need arguments: gnunet-mpi-test <cmd> <cmd_args>"); |
31 | return 1; | 31 | return 1; |
32 | } | 32 | } |
33 | if (MPI_SUCCESS != MPI_Init(&argc, &argv)) | 33 | if (MPI_SUCCESS != MPI_Init (&argc, &argv)) |
34 | { | 34 | { |
35 | GNUNET_break(0); | 35 | GNUNET_break (0); |
36 | return 1; | 36 | return 1; |
37 | } | 37 | } |
38 | if (MPI_SUCCESS != MPI_Comm_size(MPI_COMM_WORLD, &ntasks)) | 38 | if (MPI_SUCCESS != MPI_Comm_size (MPI_COMM_WORLD, &ntasks)) |
39 | { | 39 | { |
40 | GNUNET_break(0); | 40 | GNUNET_break (0); |
41 | goto finalize; | 41 | goto finalize; |
42 | } | 42 | } |
43 | if (MPI_SUCCESS != MPI_Comm_rank(MPI_COMM_WORLD, &rank)) | 43 | if (MPI_SUCCESS != MPI_Comm_rank (MPI_COMM_WORLD, &rank)) |
44 | { | 44 | { |
45 | GNUNET_break(0); | 45 | GNUNET_break (0); |
46 | goto finalize; | 46 | goto finalize; |
47 | } | 47 | } |
48 | pid = getpid(); | 48 | pid = getpid (); |
49 | (void)GNUNET_asprintf(&filename, "%d-%d.mpiout", (int)pid, rank); | 49 | (void) GNUNET_asprintf (&filename, "%d-%d.mpiout", (int) pid, rank); |
50 | msg_size = GNUNET_asprintf(&msg, "My rank is: %d\n", rank); | 50 | msg_size = GNUNET_asprintf (&msg, "My rank is: %d\n", rank); |
51 | printf("%s", msg); | 51 | printf ("%s", msg); |
52 | if (msg_size == | 52 | if (msg_size == |
53 | GNUNET_DISK_fn_write(filename, msg, msg_size, | 53 | GNUNET_DISK_fn_write (filename, msg, msg_size, |
54 | GNUNET_DISK_PERM_USER_READ | | 54 | GNUNET_DISK_PERM_USER_READ |
55 | GNUNET_DISK_PERM_GROUP_READ | | 55 | | GNUNET_DISK_PERM_GROUP_READ |
56 | GNUNET_DISK_PERM_USER_WRITE | | 56 | | GNUNET_DISK_PERM_USER_WRITE |
57 | GNUNET_DISK_PERM_GROUP_WRITE)) | 57 | | GNUNET_DISK_PERM_GROUP_WRITE)) |
58 | ret = GNUNET_OK; | 58 | ret = GNUNET_OK; |
59 | GNUNET_free(filename); | 59 | GNUNET_free (filename); |
60 | GNUNET_free(msg); | 60 | GNUNET_free (msg); |
61 | if (GNUNET_OK != ret) | 61 | if (GNUNET_OK != ret) |
62 | { | 62 | { |
63 | GNUNET_break(0); | 63 | GNUNET_break (0); |
64 | goto finalize; | 64 | goto finalize; |
65 | } | 65 | } |
66 | 66 | ||
67 | ret = GNUNET_SYSERR; | 67 | ret = GNUNET_SYSERR; |
68 | argv2 = GNUNET_malloc(sizeof(char *) * (argc)); | 68 | argv2 = GNUNET_malloc (sizeof(char *) * (argc)); |
69 | for (cnt = 1; cnt < argc; cnt++) | 69 | for (cnt = 1; cnt < argc; cnt++) |
70 | argv2[cnt - 1] = argv[cnt]; | 70 | argv2[cnt - 1] = argv[cnt]; |
71 | proc = | 71 | proc = |
72 | GNUNET_OS_start_process_vap(GNUNET_NO, GNUNET_OS_INHERIT_STD_ALL, NULL, | 72 | GNUNET_OS_start_process_vap (GNUNET_NO, GNUNET_OS_INHERIT_STD_ALL, NULL, |
73 | NULL, NULL, argv2[0], argv2); | 73 | NULL, NULL, argv2[0], argv2); |
74 | if (NULL == proc) | 74 | if (NULL == proc) |
75 | { | 75 | { |
76 | printf("Cannot exec\n"); | 76 | printf ("Cannot exec\n"); |
77 | GNUNET_free(argv2); | 77 | GNUNET_free (argv2); |
78 | goto finalize; | 78 | goto finalize; |
79 | } | 79 | } |
80 | do | 80 | do |
81 | { | 81 | { |
82 | (void)sleep(1); | 82 | (void) sleep (1); |
83 | ret = GNUNET_OS_process_status(proc, &proc_status, &code); | 83 | ret = GNUNET_OS_process_status (proc, &proc_status, &code); |
84 | } | 84 | } |
85 | while (GNUNET_NO == ret); | 85 | while (GNUNET_NO == ret); |
86 | GNUNET_free(argv2); | 86 | GNUNET_free (argv2); |
87 | GNUNET_assert(GNUNET_NO != ret); | 87 | GNUNET_assert (GNUNET_NO != ret); |
88 | if (GNUNET_OK == ret) | 88 | if (GNUNET_OK == ret) |
89 | { | ||
90 | if (0 != code) | ||
89 | { | 91 | { |
90 | if (0 != code) | 92 | LOG (GNUNET_ERROR_TYPE_WARNING, "Child terminated abnormally\n"); |
91 | { | 93 | ret = GNUNET_SYSERR; |
92 | LOG(GNUNET_ERROR_TYPE_WARNING, "Child terminated abnormally\n"); | 94 | GNUNET_break (0); |
93 | ret = GNUNET_SYSERR; | 95 | goto finalize; |
94 | GNUNET_break(0); | ||
95 | goto finalize; | ||
96 | } | ||
97 | } | 96 | } |
97 | } | ||
98 | else | 98 | else |
99 | GNUNET_break(0); | 99 | GNUNET_break (0); |
100 | 100 | ||
101 | finalize: | 101 | finalize: |
102 | (void)MPI_Finalize(); | 102 | (void) MPI_Finalize (); |
103 | if (GNUNET_OK == ret) | 103 | if (GNUNET_OK == ret) |
104 | return 0; | 104 | return 0; |
105 | printf("Something went wrong\n"); | 105 | printf ("Something went wrong\n"); |
106 | return 1; | 106 | return 1; |
107 | } | 107 | } |