aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_quota_compliance.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/test_quota_compliance.c')
-rw-r--r--src/transport/test_quota_compliance.c49
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
52static struct GNUNET_SCHEDULER_Task * measure_task; 52static struct GNUNET_SCHEDULER_Task * measure_task;
53 53
54struct PeerContext *p1; 54struct GNUNET_TRANSPORT_TESTING_PeerContext *p1;
55 55
56struct PeerContext *p2; 56struct GNUNET_TRANSPORT_TESTING_PeerContext *p2;
57 57
58struct PeerContext *sender; 58struct GNUNET_TRANSPORT_TESTING_PeerContext *sender;
59 59
60struct PeerContext *receiver; 60struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver;
61 61
62struct GNUNET_TRANSPORT_TransmitHandle *th; 62struct GNUNET_TRANSPORT_TransmitHandle *th;
63 63
@@ -71,7 +71,7 @@ char *gen_cfg_p1;
71unsigned long long quota_in_p2; 71unsigned long long quota_in_p2;
72unsigned long long quota_out_p2; 72unsigned long long quota_out_p2;
73 73
74struct GNUNET_TRANSPORT_TESTING_handle *tth; 74struct GNUNET_TRANSPORT_TESTING_Handle *tth;
75 75
76static struct GNUNET_TRANSPORT_TESTING_ConnectRequest * cc; 76static 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
319notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) 319notify_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)
331static void 331static void
332notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) 332notify_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
378static void 378static void
379testing_connect_cb (struct PeerContext *p1, struct PeerContext *p2, void *cls) 379testing_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
396void 396
397start_cb (struct PeerContext *p, void *cls) 397static void
398start_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
495static void 497static void
496run (void *cls, char *const *args, const char *cfgfile, 498run (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 ()
538int 540int
539main (int argc, char *argv[]) 541main (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