diff options
author | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
---|---|---|
committer | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
commit | 75a33a1499cf60ea4364c9aa673816629a6c1413 (patch) | |
tree | 0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/transport/test_transport_api_reliability.c | |
parent | 7217c601ad30760872823193d62307e7a335d226 (diff) | |
download | gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.tar.gz gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.zip |
big scheduler refactoring, expect some issues
Diffstat (limited to 'src/transport/test_transport_api_reliability.c')
-rw-r--r-- | src/transport/test_transport_api_reliability.c | 28 |
1 files changed, 11 insertions, 17 deletions
diff --git a/src/transport/test_transport_api_reliability.c b/src/transport/test_transport_api_reliability.c index a8633e089..ce031af7f 100644 --- a/src/transport/test_transport_api_reliability.c +++ b/src/transport/test_transport_api_reliability.c | |||
@@ -70,8 +70,6 @@ static struct PeerContext p1; | |||
70 | 70 | ||
71 | static struct PeerContext p2; | 71 | static struct PeerContext p2; |
72 | 72 | ||
73 | static struct GNUNET_SCHEDULER_Handle *sched; | ||
74 | |||
75 | static int ok; | 73 | static int ok; |
76 | 74 | ||
77 | static int is_tcp; | 75 | static int is_tcp; |
@@ -116,7 +114,7 @@ end () | |||
116 | { | 114 | { |
117 | unsigned long long delta; | 115 | unsigned long long delta; |
118 | 116 | ||
119 | GNUNET_SCHEDULER_cancel (sched, die_task); | 117 | GNUNET_SCHEDULER_cancel (die_task); |
120 | die_task = GNUNET_SCHEDULER_NO_TASK; | 118 | die_task = GNUNET_SCHEDULER_NO_TASK; |
121 | #if VERBOSE | 119 | #if VERBOSE |
122 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from transports!\n"); | 120 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from transports!\n"); |
@@ -208,8 +206,8 @@ notify_receive (void *cls, | |||
208 | n, s, | 206 | n, s, |
209 | ntohs (message->size), | 207 | ntohs (message->size), |
210 | ntohl (hdr->num)); | 208 | ntohl (hdr->num)); |
211 | GNUNET_SCHEDULER_cancel (sched, die_task); | 209 | GNUNET_SCHEDULER_cancel (die_task); |
212 | die_task = GNUNET_SCHEDULER_add_now (sched, &end_badly, NULL); | 210 | die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); |
213 | return; | 211 | return; |
214 | } | 212 | } |
215 | if (ntohl (hdr->num) != n) | 213 | if (ntohl (hdr->num) != n) |
@@ -219,8 +217,8 @@ notify_receive (void *cls, | |||
219 | n, s, | 217 | n, s, |
220 | ntohs (message->size), | 218 | ntohs (message->size), |
221 | ntohl (hdr->num)); | 219 | ntohl (hdr->num)); |
222 | GNUNET_SCHEDULER_cancel (sched, die_task); | 220 | GNUNET_SCHEDULER_cancel (die_task); |
223 | die_task = GNUNET_SCHEDULER_add_now (sched, &end_badly, NULL); | 221 | die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); |
224 | return; | 222 | return; |
225 | } | 223 | } |
226 | memset (cbuf, n, s - sizeof (struct TestMessage)); | 224 | memset (cbuf, n, s - sizeof (struct TestMessage)); |
@@ -231,8 +229,8 @@ notify_receive (void *cls, | |||
231 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 229 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, |
232 | "Expected message %u with bits %u, but body did not match\n", | 230 | "Expected message %u with bits %u, but body did not match\n", |
233 | n, (unsigned char) n); | 231 | n, (unsigned char) n); |
234 | GNUNET_SCHEDULER_cancel (sched, die_task); | 232 | GNUNET_SCHEDULER_cancel (die_task); |
235 | die_task = GNUNET_SCHEDULER_add_now (sched, &end_badly, NULL); | 233 | die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); |
236 | return; | 234 | return; |
237 | } | 235 | } |
238 | #if VERBOSE | 236 | #if VERBOSE |
@@ -248,9 +246,8 @@ notify_receive (void *cls, | |||
248 | if (0 == (n % (TOTAL_MSGS/100))) | 246 | if (0 == (n % (TOTAL_MSGS/100))) |
249 | { | 247 | { |
250 | fprintf (stderr, "."); | 248 | fprintf (stderr, "."); |
251 | GNUNET_SCHEDULER_cancel (sched, die_task); | 249 | GNUNET_SCHEDULER_cancel (die_task); |
252 | die_task = GNUNET_SCHEDULER_add_delayed (sched, | 250 | die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, |
253 | TIMEOUT, | ||
254 | &end_badly, | 251 | &end_badly, |
255 | NULL); | 252 | NULL); |
256 | } | 253 | } |
@@ -450,7 +447,7 @@ setup_peer (struct PeerContext *p, const char *cfgname) | |||
450 | } | 447 | } |
451 | } | 448 | } |
452 | 449 | ||
453 | p->th = GNUNET_TRANSPORT_connect (sched, p->cfg, NULL, | 450 | p->th = GNUNET_TRANSPORT_connect (p->cfg, NULL, |
454 | p, | 451 | p, |
455 | ¬ify_receive, | 452 | ¬ify_receive, |
456 | ¬ify_connect, | 453 | ¬ify_connect, |
@@ -622,15 +619,12 @@ check_gnunet_nat_binary(char *binary) | |||
622 | 619 | ||
623 | static void | 620 | static void |
624 | run (void *cls, | 621 | run (void *cls, |
625 | struct GNUNET_SCHEDULER_Handle *s, | ||
626 | char *const *args, | 622 | char *const *args, |
627 | const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg) | 623 | const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg) |
628 | { | 624 | { |
629 | GNUNET_assert (ok == 1); | 625 | GNUNET_assert (ok == 1); |
630 | OKPP; | 626 | OKPP; |
631 | sched = s; | 627 | die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, |
632 | die_task = GNUNET_SCHEDULER_add_delayed (sched, | ||
633 | TIMEOUT, | ||
634 | &end_badly, | 628 | &end_badly, |
635 | NULL); | 629 | NULL); |
636 | if (is_tcp) | 630 | if (is_tcp) |