diff options
Diffstat (limited to 'src/testbed/test_testbed_api_testbed_run.c')
-rw-r--r-- | src/testbed/test_testbed_api_testbed_run.c | 148 |
1 files changed, 74 insertions, 74 deletions
diff --git a/src/testbed/test_testbed_api_testbed_run.c b/src/testbed/test_testbed_api_testbed_run.c index a3bd415dd..66f857222 100644 --- a/src/testbed/test_testbed_api_testbed_run.c +++ b/src/testbed/test_testbed_api_testbed_run.c | |||
@@ -46,7 +46,7 @@ static struct GNUNET_TESTBED_Operation *op; | |||
46 | /** | 46 | /** |
47 | * Abort task identifier | 47 | * Abort task identifier |
48 | */ | 48 | */ |
49 | static struct GNUNET_SCHEDULER_Task * abort_task; | 49 | static struct GNUNET_SCHEDULER_Task *abort_task; |
50 | 50 | ||
51 | /** | 51 | /** |
52 | * Current peer id | 52 | * Current peer id |
@@ -70,11 +70,11 @@ static int wait_forever; | |||
70 | * @param cls NULL | 70 | * @param cls NULL |
71 | */ | 71 | */ |
72 | static void | 72 | static void |
73 | do_shutdown(void *cls) | 73 | do_shutdown (void *cls) |
74 | { | 74 | { |
75 | if (NULL != abort_task) | 75 | if (NULL != abort_task) |
76 | GNUNET_SCHEDULER_cancel(abort_task); | 76 | GNUNET_SCHEDULER_cancel (abort_task); |
77 | GNUNET_SCHEDULER_shutdown(); /* Stop scheduler to shutdown testbed run */ | 77 | GNUNET_SCHEDULER_shutdown (); /* Stop scheduler to shutdown testbed run */ |
78 | } | 78 | } |
79 | 79 | ||
80 | 80 | ||
@@ -84,12 +84,12 @@ do_shutdown(void *cls) | |||
84 | * @param cls NULL | 84 | * @param cls NULL |
85 | */ | 85 | */ |
86 | static void | 86 | static void |
87 | do_abort(void *cls) | 87 | do_abort (void *cls) |
88 | { | 88 | { |
89 | abort_task = NULL; | 89 | abort_task = NULL; |
90 | GNUNET_log(GNUNET_ERROR_TYPE_WARNING, | 90 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, |
91 | "Test timed out -- Aborting\n"); | 91 | "Test timed out -- Aborting\n"); |
92 | GNUNET_SCHEDULER_add_now(&do_shutdown, NULL); | 92 | GNUNET_SCHEDULER_add_now (&do_shutdown, NULL); |
93 | } | 93 | } |
94 | 94 | ||
95 | 95 | ||
@@ -106,26 +106,26 @@ do_abort(void *cls) | |||
106 | * failed | 106 | * failed |
107 | */ | 107 | */ |
108 | static void | 108 | static void |
109 | test_master(void *cls, | 109 | test_master (void *cls, |
110 | struct GNUNET_TESTBED_RunHandle *h, | 110 | struct GNUNET_TESTBED_RunHandle *h, |
111 | unsigned int num_peers, | 111 | unsigned int num_peers, |
112 | struct GNUNET_TESTBED_Peer **peers_, | 112 | struct GNUNET_TESTBED_Peer **peers_, |
113 | unsigned int links_succeeded, | 113 | unsigned int links_succeeded, |
114 | unsigned int links_failed) | 114 | unsigned int links_failed) |
115 | { | 115 | { |
116 | result = GNUNET_OK; | 116 | result = GNUNET_OK; |
117 | if (GNUNET_YES == wait_forever) | 117 | if (GNUNET_YES == wait_forever) |
118 | { | 118 | { |
119 | if (NULL == abort_task) | 119 | if (NULL == abort_task) |
120 | return; /* abort already scheduled */ | 120 | return; /* abort already scheduled */ |
121 | GNUNET_SCHEDULER_cancel(abort_task); | 121 | GNUNET_SCHEDULER_cancel (abort_task); |
122 | abort_task = NULL; | 122 | abort_task = NULL; |
123 | GNUNET_SCHEDULER_add_shutdown(&do_shutdown, NULL); | 123 | GNUNET_SCHEDULER_add_shutdown (&do_shutdown, NULL); |
124 | return; | 124 | return; |
125 | } | 125 | } |
126 | GNUNET_assert(NULL != peers[0]); | 126 | GNUNET_assert (NULL != peers[0]); |
127 | op = GNUNET_TESTBED_peer_stop(NULL, peers[0], NULL, NULL); | 127 | op = GNUNET_TESTBED_peer_stop (NULL, peers[0], NULL, NULL); |
128 | GNUNET_assert(NULL != op); | 128 | GNUNET_assert (NULL != op); |
129 | } | 129 | } |
130 | 130 | ||
131 | 131 | ||
@@ -136,27 +136,27 @@ test_master(void *cls, | |||
136 | * @param event the controller event | 136 | * @param event the controller event |
137 | */ | 137 | */ |
138 | static void | 138 | static void |
139 | controller_event_cb(void *cls, | 139 | controller_event_cb (void *cls, |
140 | const struct GNUNET_TESTBED_EventInformation *event) | 140 | const struct GNUNET_TESTBED_EventInformation *event) |
141 | { | 141 | { |
142 | switch (event->type) | 142 | switch (event->type) |
143 | { | 143 | { |
144 | case GNUNET_TESTBED_ET_PEER_START: | 144 | case GNUNET_TESTBED_ET_PEER_START: |
145 | GNUNET_assert(NULL == peers[peer_id]); | 145 | GNUNET_assert (NULL == peers[peer_id]); |
146 | GNUNET_assert(NULL != event->details.peer_start.peer); | 146 | GNUNET_assert (NULL != event->details.peer_start.peer); |
147 | peers[peer_id++] = event->details.peer_start.peer; | 147 | peers[peer_id++] = event->details.peer_start.peer; |
148 | break; | 148 | break; |
149 | 149 | ||
150 | case GNUNET_TESTBED_ET_PEER_STOP: | 150 | case GNUNET_TESTBED_ET_PEER_STOP: |
151 | GNUNET_assert(NULL != op); | 151 | GNUNET_assert (NULL != op); |
152 | GNUNET_TESTBED_operation_done(op); | 152 | GNUNET_TESTBED_operation_done (op); |
153 | GNUNET_assert(peers[0] == event->details.peer_stop.peer); | 153 | GNUNET_assert (peers[0] == event->details.peer_stop.peer); |
154 | GNUNET_SCHEDULER_add_now(&do_shutdown, NULL); | 154 | GNUNET_SCHEDULER_add_now (&do_shutdown, NULL); |
155 | break; | 155 | break; |
156 | 156 | ||
157 | default: | 157 | default: |
158 | GNUNET_assert(0); | 158 | GNUNET_assert (0); |
159 | } | 159 | } |
160 | } | 160 | } |
161 | 161 | ||
162 | 162 | ||
@@ -169,24 +169,24 @@ controller_event_cb(void *cls, | |||
169 | * @param cfg the configuration file handle | 169 | * @param cfg the configuration file handle |
170 | */ | 170 | */ |
171 | static void | 171 | static void |
172 | run(void *cls, | 172 | run (void *cls, |
173 | char *const *args, | 173 | char *const *args, |
174 | const char *cfgfile, | 174 | const char *cfgfile, |
175 | const struct GNUNET_CONFIGURATION_Handle *config) | 175 | const struct GNUNET_CONFIGURATION_Handle *config) |
176 | { | 176 | { |
177 | uint64_t event_mask; | 177 | uint64_t event_mask; |
178 | 178 | ||
179 | event_mask = 0; | 179 | event_mask = 0; |
180 | event_mask |= (1LL << GNUNET_TESTBED_ET_PEER_START); | 180 | event_mask |= (1LL << GNUNET_TESTBED_ET_PEER_START); |
181 | event_mask |= (1LL << GNUNET_TESTBED_ET_PEER_STOP); | 181 | event_mask |= (1LL << GNUNET_TESTBED_ET_PEER_STOP); |
182 | GNUNET_TESTBED_run(NULL, config, NUM_PEERS, event_mask, | 182 | GNUNET_TESTBED_run (NULL, config, NUM_PEERS, event_mask, |
183 | &controller_event_cb, NULL, | 183 | &controller_event_cb, NULL, |
184 | &test_master, NULL); | 184 | &test_master, NULL); |
185 | abort_task = | 185 | abort_task = |
186 | GNUNET_SCHEDULER_add_delayed(GNUNET_TIME_relative_multiply | 186 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply |
187 | (GNUNET_TIME_UNIT_SECONDS, 300), | 187 | (GNUNET_TIME_UNIT_SECONDS, 300), |
188 | &do_abort, | 188 | &do_abort, |
189 | NULL); | 189 | NULL); |
190 | } | 190 | } |
191 | 191 | ||
192 | 192 | ||
@@ -194,7 +194,7 @@ run(void *cls, | |||
194 | * Main function | 194 | * Main function |
195 | */ | 195 | */ |
196 | int | 196 | int |
197 | main(int argc, char **argv) | 197 | main (int argc, char **argv) |
198 | { | 198 | { |
199 | char *argv2[] = { | 199 | char *argv2[] = { |
200 | "test_testbed_api_testbed_run", | 200 | "test_testbed_api_testbed_run", |
@@ -208,31 +208,31 @@ main(int argc, char **argv) | |||
208 | char *config_filename; | 208 | char *config_filename; |
209 | int ret; | 209 | int ret; |
210 | 210 | ||
211 | if (NULL == (testname = strrchr(argv[0], (int)'_'))) | 211 | if (NULL == (testname = strrchr (argv[0], (int) '_'))) |
212 | { | 212 | { |
213 | GNUNET_break(0); | 213 | GNUNET_break (0); |
214 | return 1; | 214 | return 1; |
215 | } | 215 | } |
216 | testname++; | 216 | testname++; |
217 | testname = GNUNET_strdup(testname); | 217 | testname = GNUNET_strdup (testname); |
218 | 218 | ||
219 | if (0 == strcmp("waitforever", testname)) | 219 | if (0 == strcmp ("waitforever", testname)) |
220 | wait_forever = GNUNET_YES; | 220 | wait_forever = GNUNET_YES; |
221 | if ((GNUNET_YES != wait_forever) && (0 != strcmp("run", testname))) | 221 | if ((GNUNET_YES != wait_forever) && (0 != strcmp ("run", testname))) |
222 | { | 222 | { |
223 | GNUNET_asprintf(&config_filename, "test_testbed_api_testbed_run_%s.conf", | 223 | GNUNET_asprintf (&config_filename, "test_testbed_api_testbed_run_%s.conf", |
224 | testname); | 224 | testname); |
225 | } | 225 | } |
226 | else | 226 | else |
227 | config_filename = GNUNET_strdup("test_testbed_api.conf"); | 227 | config_filename = GNUNET_strdup ("test_testbed_api.conf"); |
228 | GNUNET_free(testname); | 228 | GNUNET_free (testname); |
229 | argv2[2] = config_filename; | 229 | argv2[2] = config_filename; |
230 | result = GNUNET_SYSERR; | 230 | result = GNUNET_SYSERR; |
231 | ret = | 231 | ret = |
232 | GNUNET_PROGRAM_run((sizeof(argv2) / sizeof(char *)) - 1, argv2, | 232 | GNUNET_PROGRAM_run ((sizeof(argv2) / sizeof(char *)) - 1, argv2, |
233 | "test_testbed_api_testbed_run", "nohelp", options, | 233 | "test_testbed_api_testbed_run", "nohelp", options, |
234 | &run, NULL); | 234 | &run, NULL); |
235 | GNUNET_free(config_filename); | 235 | GNUNET_free (config_filename); |
236 | if ((GNUNET_OK != ret) || (GNUNET_OK != result)) | 236 | if ((GNUNET_OK != ret) || (GNUNET_OK != result)) |
237 | return 1; | 237 | return 1; |
238 | return 0; | 238 | return 0; |