diff options
Diffstat (limited to 'src/transport/test_quota_compliance.c')
-rw-r--r-- | src/transport/test_quota_compliance.c | 49 |
1 files changed, 25 insertions, 24 deletions
diff --git a/src/transport/test_quota_compliance.c b/src/transport/test_quota_compliance.c index e64260969..59dbd45e0 100644 --- a/src/transport/test_quota_compliance.c +++ b/src/transport/test_quota_compliance.c | |||
@@ -51,13 +51,13 @@ static struct GNUNET_SCHEDULER_Task * die_task; | |||
51 | 51 | ||
52 | static struct GNUNET_SCHEDULER_Task * measure_task; | 52 | static struct GNUNET_SCHEDULER_Task * measure_task; |
53 | 53 | ||
54 | struct PeerContext *p1; | 54 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p1; |
55 | 55 | ||
56 | struct PeerContext *p2; | 56 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p2; |
57 | 57 | ||
58 | struct PeerContext *sender; | 58 | struct GNUNET_TRANSPORT_TESTING_PeerContext *sender; |
59 | 59 | ||
60 | struct PeerContext *receiver; | 60 | struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver; |
61 | 61 | ||
62 | struct GNUNET_TRANSPORT_TransmitHandle *th; | 62 | struct GNUNET_TRANSPORT_TransmitHandle *th; |
63 | 63 | ||
@@ -71,7 +71,7 @@ char *gen_cfg_p1; | |||
71 | unsigned long long quota_in_p2; | 71 | unsigned long long quota_in_p2; |
72 | unsigned long long quota_out_p2; | 72 | unsigned long long quota_out_p2; |
73 | 73 | ||
74 | struct GNUNET_TRANSPORT_TESTING_handle *tth; | 74 | struct GNUNET_TRANSPORT_TESTING_Handle *tth; |
75 | 75 | ||
76 | static struct GNUNET_TRANSPORT_TESTING_ConnectRequest * cc; | 76 | static struct GNUNET_TRANSPORT_TESTING_ConnectRequest * cc; |
77 | 77 | ||
@@ -161,10 +161,10 @@ end () | |||
161 | th = NULL; | 161 | th = NULL; |
162 | 162 | ||
163 | if (cc != NULL) | 163 | if (cc != NULL) |
164 | GNUNET_TRANSPORT_TESTING_connect_peers_cancel (tth, cc); | 164 | GNUNET_TRANSPORT_TESTING_connect_peers_cancel (cc); |
165 | 165 | ||
166 | GNUNET_TRANSPORT_TESTING_stop_peer (tth, p1); | 166 | GNUNET_TRANSPORT_TESTING_stop_peer (p1); |
167 | GNUNET_TRANSPORT_TESTING_stop_peer (tth, p2); | 167 | GNUNET_TRANSPORT_TESTING_stop_peer (p2); |
168 | 168 | ||
169 | } | 169 | } |
170 | 170 | ||
@@ -187,12 +187,12 @@ end_badly () | |||
187 | th = NULL; | 187 | th = NULL; |
188 | 188 | ||
189 | if (cc != NULL) | 189 | if (cc != NULL) |
190 | GNUNET_TRANSPORT_TESTING_connect_peers_cancel (tth, cc); | 190 | GNUNET_TRANSPORT_TESTING_connect_peers_cancel (cc); |
191 | 191 | ||
192 | if (p1 != NULL) | 192 | if (p1 != NULL) |
193 | GNUNET_TRANSPORT_TESTING_stop_peer (tth, p1); | 193 | GNUNET_TRANSPORT_TESTING_stop_peer (p1); |
194 | if (p2 != NULL) | 194 | if (p2 != NULL) |
195 | GNUNET_TRANSPORT_TESTING_stop_peer (tth, p2); | 195 | GNUNET_TRANSPORT_TESTING_stop_peer (p2); |
196 | 196 | ||
197 | test_failed = GNUNET_YES; | 197 | test_failed = GNUNET_YES; |
198 | } | 198 | } |
@@ -214,7 +214,7 @@ notify_receive (void *cls, | |||
214 | const struct GNUNET_MessageHeader *message) | 214 | const struct GNUNET_MessageHeader *message) |
215 | { | 215 | { |
216 | const struct TestMessage *hdr; | 216 | const struct TestMessage *hdr; |
217 | struct PeerContext *p = cls; | 217 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls; |
218 | 218 | ||
219 | hdr = (const struct TestMessage *) message; | 219 | hdr = (const struct TestMessage *) message; |
220 | if (MTYPE != ntohs (message->type)) | 220 | if (MTYPE != ntohs (message->type)) |
@@ -319,7 +319,7 @@ static void | |||
319 | notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) | 319 | notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) |
320 | { | 320 | { |
321 | 321 | ||
322 | struct PeerContext *p = cls; | 322 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls; |
323 | 323 | ||
324 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 324 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
325 | "Peer %u (`%4s') connected to us!\n", | 325 | "Peer %u (`%4s') connected to us!\n", |
@@ -331,7 +331,7 @@ notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
331 | static void | 331 | static void |
332 | notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | 332 | notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) |
333 | { | 333 | { |
334 | struct PeerContext *p = cls; | 334 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls; |
335 | 335 | ||
336 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 336 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
337 | "Peer %u (`%4s') disconnected!\n", | 337 | "Peer %u (`%4s') disconnected!\n", |
@@ -376,7 +376,7 @@ measure (void *cls) | |||
376 | 376 | ||
377 | 377 | ||
378 | static void | 378 | static void |
379 | testing_connect_cb (struct PeerContext *p1, struct PeerContext *p2, void *cls) | 379 | testing_connect_cb (void *cls) |
380 | { | 380 | { |
381 | char *p1_c = GNUNET_strdup (GNUNET_i2s (&p1->id)); | 381 | char *p1_c = GNUNET_strdup (GNUNET_i2s (&p1->id)); |
382 | 382 | ||
@@ -393,8 +393,9 @@ testing_connect_cb (struct PeerContext *p1, struct PeerContext *p2, void *cls) | |||
393 | 393 | ||
394 | } | 394 | } |
395 | 395 | ||
396 | void | 396 | |
397 | start_cb (struct PeerContext *p, void *cls) | 397 | static void |
398 | start_cb (struct GNUNET_TRANSPORT_TESTING_PeerContext *p, void *cls) | ||
398 | { | 399 | { |
399 | static int started; | 400 | static int started; |
400 | 401 | ||
@@ -416,7 +417,7 @@ start_cb (struct PeerContext *p, void *cls) | |||
416 | "Test tries to send from %u (%s) -> peer %u (%s)\n", sender->no, | 417 | "Test tries to send from %u (%s) -> peer %u (%s)\n", sender->no, |
417 | sender_c, receiver->no, GNUNET_i2s (&receiver->id)); | 418 | sender_c, receiver->no, GNUNET_i2s (&receiver->id)); |
418 | GNUNET_free (sender_c); | 419 | GNUNET_free (sender_c); |
419 | cc = GNUNET_TRANSPORT_TESTING_connect_peers (tth, p1, p2, &testing_connect_cb, | 420 | cc = GNUNET_TRANSPORT_TESTING_connect_peers (p1, p2, &testing_connect_cb, |
420 | NULL); | 421 | NULL); |
421 | 422 | ||
422 | } | 423 | } |
@@ -492,6 +493,7 @@ run_measurement (unsigned long long p1_quota_in, | |||
492 | } | 493 | } |
493 | } | 494 | } |
494 | 495 | ||
496 | |||
495 | static void | 497 | static void |
496 | run (void *cls, char *const *args, const char *cfgfile, | 498 | run (void *cls, char *const *args, const char *cfgfile, |
497 | const struct GNUNET_CONFIGURATION_Handle *cfg) | 499 | const struct GNUNET_CONFIGURATION_Handle *cfg) |
@@ -538,20 +540,19 @@ check () | |||
538 | int | 540 | int |
539 | main (int argc, char *argv[]) | 541 | main (int argc, char *argv[]) |
540 | { | 542 | { |
541 | GNUNET_TRANSPORT_TESTING_get_test_name (argv[0], &test_name); | 543 | test_name = GNUNET_TRANSPORT_TESTING_get_test_name (argv[0]); |
542 | 544 | ||
543 | GNUNET_log_setup (test_name, | 545 | GNUNET_log_setup (test_name, |
544 | "WARNING", | 546 | "WARNING", |
545 | NULL); | 547 | NULL); |
546 | 548 | ||
547 | GNUNET_TRANSPORT_TESTING_get_test_source_name (__FILE__, &test_source); | 549 | test_source = GNUNET_TRANSPORT_TESTING_get_test_source_name (__FILE__); |
548 | GNUNET_TRANSPORT_TESTING_get_test_plugin_name (argv[0], test_source, | 550 | test_plugin = GNUNET_TRANSPORT_TESTING_get_test_plugin_name (argv[0], test_source); |
549 | &test_plugin); | ||
550 | 551 | ||
551 | tth = GNUNET_TRANSPORT_TESTING_init (); | 552 | tth = GNUNET_TRANSPORT_TESTING_init (); |
552 | 553 | ||
553 | GNUNET_TRANSPORT_TESTING_get_config_name (argv[0], &cfg_file_p1, 1); | 554 | cfg_file_p1 = GNUNET_TRANSPORT_TESTING_get_config_name (argv[0], 1); |
554 | GNUNET_TRANSPORT_TESTING_get_config_name (argv[0], &cfg_file_p2, 2); | 555 | cfg_file_p2 = GNUNET_TRANSPORT_TESTING_get_config_name (argv[0], 2); |
555 | 556 | ||
556 | check (); | 557 | check (); |
557 | 558 | ||