diff options
Diffstat (limited to 'src/transport/gnunet-service-transport_manipulation.c')
-rw-r--r-- | src/transport/gnunet-service-transport_manipulation.c | 20 |
1 files changed, 9 insertions, 11 deletions
diff --git a/src/transport/gnunet-service-transport_manipulation.c b/src/transport/gnunet-service-transport_manipulation.c index f198d6e49..e68753583 100644 --- a/src/transport/gnunet-service-transport_manipulation.c +++ b/src/transport/gnunet-service-transport_manipulation.c | |||
@@ -219,7 +219,6 @@ send_delayed (void *cls) | |||
219 | struct DelayQueueEntry *dqe = cls; | 219 | struct DelayQueueEntry *dqe = cls; |
220 | struct DelayQueueEntry *next; | 220 | struct DelayQueueEntry *next; |
221 | struct TM_Peer *tmp = dqe->tmp; | 221 | struct TM_Peer *tmp = dqe->tmp; |
222 | struct GNUNET_TIME_Relative delay; | ||
223 | 222 | ||
224 | GNUNET_break (GNUNET_YES == | 223 | GNUNET_break (GNUNET_YES == |
225 | GST_neighbours_test_connected (&dqe->id)); | 224 | GST_neighbours_test_connected (&dqe->id)); |
@@ -233,9 +232,9 @@ send_delayed (void *cls) | |||
233 | if (NULL != next) | 232 | if (NULL != next) |
234 | { | 233 | { |
235 | /* More delayed messages */ | 234 | /* More delayed messages */ |
236 | delay = GNUNET_TIME_absolute_get_remaining(next->sent_at); | 235 | tmp->send_delay_task = GNUNET_SCHEDULER_add_at (next->sent_at, |
237 | tmp->send_delay_task = GNUNET_SCHEDULER_add_delayed(delay, | 236 | &send_delayed, |
238 | &send_delayed, next); | 237 | next); |
239 | } | 238 | } |
240 | } | 239 | } |
241 | else | 240 | else |
@@ -249,10 +248,9 @@ send_delayed (void *cls) | |||
249 | if (NULL != next) | 248 | if (NULL != next) |
250 | { | 249 | { |
251 | /* More delayed messages */ | 250 | /* More delayed messages */ |
252 | delay = GNUNET_TIME_absolute_get_remaining(next->sent_at); | 251 | generic_send_delay_task = GNUNET_SCHEDULER_add_at (next->sent_at, |
253 | generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, | 252 | &send_delayed, |
254 | &send_delayed, | 253 | next); |
255 | next); | ||
256 | } | 254 | } |
257 | } | 255 | } |
258 | GST_neighbours_send (&dqe->id, | 256 | GST_neighbours_send (&dqe->id, |
@@ -503,9 +501,9 @@ GST_manipulation_peer_disconnect (const struct GNUNET_PeerIdentity *peer) | |||
503 | generic_send_delay_task = NULL; | 501 | generic_send_delay_task = NULL; |
504 | if (NULL != generic_dqe_head) | 502 | if (NULL != generic_dqe_head) |
505 | generic_send_delay_task | 503 | generic_send_delay_task |
506 | = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_absolute_get_remaining(generic_dqe_head->sent_at), | 504 | = GNUNET_SCHEDULER_add_at (generic_dqe_head->sent_at, |
507 | &send_delayed, | 505 | &send_delayed, |
508 | generic_dqe_head); | 506 | generic_dqe_head); |
509 | } | 507 | } |
510 | } | 508 | } |
511 | 509 | ||