summaryrefslogtreecommitdiff
path: root/src/testbed/test_testbed_api_testbed_run.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/testbed/test_testbed_api_testbed_run.c')
-rw-r--r--src/testbed/test_testbed_api_testbed_run.c148
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 */
49static struct GNUNET_SCHEDULER_Task * abort_task; 49static 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 */
72static void 72static void
73do_shutdown(void *cls) 73do_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 */
86static void 86static void
87do_abort(void *cls) 87do_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 */
108static void 108static void
109test_master(void *cls, 109test_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 */
138static void 138static void
139controller_event_cb(void *cls, 139controller_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 */
171static void 171static void
172run(void *cls, 172run (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 */
196int 196int
197main(int argc, char **argv) 197main (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;