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.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.c')
-rw-r--r-- | src/transport/test_transport_api.c | 16 |
1 files changed, 5 insertions, 11 deletions
diff --git a/src/transport/test_transport_api.c b/src/transport/test_transport_api.c index cee1da25b..e429ad7a7 100644 --- a/src/transport/test_transport_api.c +++ b/src/transport/test_transport_api.c | |||
@@ -68,8 +68,6 @@ static struct PeerContext p1; | |||
68 | 68 | ||
69 | static struct PeerContext p2; | 69 | static struct PeerContext p2; |
70 | 70 | ||
71 | static struct GNUNET_SCHEDULER_Handle *sched; | ||
72 | |||
73 | static int ok; | 71 | static int ok; |
74 | 72 | ||
75 | static int is_tcp; | 73 | static int is_tcp; |
@@ -104,7 +102,7 @@ end () | |||
104 | { | 102 | { |
105 | /* do work here */ | 103 | /* do work here */ |
106 | GNUNET_assert (ok == 6); | 104 | GNUNET_assert (ok == 6); |
107 | GNUNET_SCHEDULER_cancel (sched, die_task); | 105 | GNUNET_SCHEDULER_cancel (die_task); |
108 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from transports!\n"); | 106 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from transports!\n"); |
109 | GNUNET_TRANSPORT_disconnect (p1.th); | 107 | GNUNET_TRANSPORT_disconnect (p1.th); |
110 | GNUNET_TRANSPORT_disconnect (p2.th); | 108 | GNUNET_TRANSPORT_disconnect (p2.th); |
@@ -193,9 +191,8 @@ notify_connect (void *cls, | |||
193 | { | 191 | { |
194 | if (cls == &p1) | 192 | if (cls == &p1) |
195 | { | 193 | { |
196 | GNUNET_SCHEDULER_cancel (sched, die_task); | 194 | GNUNET_SCHEDULER_cancel (die_task); |
197 | die_task = GNUNET_SCHEDULER_add_delayed (sched, | 195 | die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT_TRANSMIT, |
198 | TIMEOUT_TRANSMIT, | ||
199 | &end_badly, NULL); | 196 | &end_badly, NULL); |
200 | 197 | ||
201 | GNUNET_TRANSPORT_notify_transmit_ready (p1.th, | 198 | GNUNET_TRANSPORT_notify_transmit_ready (p1.th, |
@@ -288,7 +285,7 @@ setup_peer (struct PeerContext *p, const char *cfgname) | |||
288 | } | 285 | } |
289 | } | 286 | } |
290 | 287 | ||
291 | p->th = GNUNET_TRANSPORT_connect (sched, p->cfg, | 288 | p->th = GNUNET_TRANSPORT_connect (p->cfg, |
292 | NULL, p, | 289 | NULL, p, |
293 | ¬ify_receive, | 290 | ¬ify_receive, |
294 | ¬ify_connect, ¬ify_disconnect); | 291 | ¬ify_connect, ¬ify_disconnect); |
@@ -341,15 +338,12 @@ exchange_hello (void *cls, | |||
341 | 338 | ||
342 | static void | 339 | static void |
343 | run (void *cls, | 340 | run (void *cls, |
344 | struct GNUNET_SCHEDULER_Handle *s, | ||
345 | char *const *args, | 341 | char *const *args, |
346 | const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg) | 342 | const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg) |
347 | { | 343 | { |
348 | GNUNET_assert (ok == 1); | 344 | GNUNET_assert (ok == 1); |
349 | OKPP; | 345 | OKPP; |
350 | sched = s; | 346 | die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, |
351 | die_task = GNUNET_SCHEDULER_add_delayed (sched, | ||
352 | TIMEOUT, | ||
353 | &end_badly, NULL); | 347 | &end_badly, NULL); |
354 | 348 | ||
355 | if (is_udp) | 349 | if (is_udp) |