aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_transport_api.c
diff options
context:
space:
mode:
authorNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
committerNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
commit75a33a1499cf60ea4364c9aa673816629a6c1413 (patch)
tree0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/transport/test_transport_api.c
parent7217c601ad30760872823193d62307e7a335d226 (diff)
downloadgnunet-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.c16
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
69static struct PeerContext p2; 69static struct PeerContext p2;
70 70
71static struct GNUNET_SCHEDULER_Handle *sched;
72
73static int ok; 71static int ok;
74 72
75static int is_tcp; 73static 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 &notify_receive, 290 &notify_receive,
294 &notify_connect, &notify_disconnect); 291 &notify_connect, &notify_disconnect);
@@ -341,15 +338,12 @@ exchange_hello (void *cls,
341 338
342static void 339static void
343run (void *cls, 340run (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)