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