diff options
author | Christian Grothoff <christian@grothoff.org> | 2017-01-22 00:46:03 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2017-01-22 00:46:03 +0100 |
commit | 7e9e4e320d6eee5bf6afd876b282609712cb72db (patch) | |
tree | eda9315b99a026c9033d2db0ed7993d4e524700d /src/dht/gnunet-service-dht_clients.c | |
parent | 542bf871c6eebdc645884960559e15ce400939e6 (diff) | |
download | gnunet-7e9e4e320d6eee5bf6afd876b282609712cb72db.tar.gz gnunet-7e9e4e320d6eee5bf6afd876b282609712cb72db.zip |
use new SCHEDULER_add_at API where applicable
Diffstat (limited to 'src/dht/gnunet-service-dht_clients.c')
-rw-r--r-- | src/dht/gnunet-service-dht_clients.c | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/src/dht/gnunet-service-dht_clients.c b/src/dht/gnunet-service-dht_clients.c index df56c010a..5ba4e5820 100644 --- a/src/dht/gnunet-service-dht_clients.c +++ b/src/dht/gnunet-service-dht_clients.c | |||
@@ -426,19 +426,20 @@ transmit_next_request_task (void *cls) | |||
426 | delay = GNUNET_TIME_absolute_get_remaining (cqr->retry_time); | 426 | delay = GNUNET_TIME_absolute_get_remaining (cqr->retry_time); |
427 | if (delay.rel_value_us > 0) | 427 | if (delay.rel_value_us > 0) |
428 | { | 428 | { |
429 | cqr->hnode = | 429 | cqr->hnode |
430 | GNUNET_CONTAINER_heap_insert (retry_heap, | 430 | = GNUNET_CONTAINER_heap_insert (retry_heap, |
431 | cqr, | 431 | cqr, |
432 | cqr->retry_time.abs_value_us); | 432 | cqr->retry_time.abs_value_us); |
433 | retry_task = | 433 | retry_task |
434 | GNUNET_SCHEDULER_add_delayed (delay, | 434 | = GNUNET_SCHEDULER_add_at (cqr->retry_time, |
435 | &transmit_next_request_task, | 435 | &transmit_next_request_task, |
436 | NULL); | 436 | NULL); |
437 | return; | 437 | return; |
438 | } | 438 | } |
439 | transmit_request (cqr); | 439 | transmit_request (cqr); |
440 | cqr->hnode | 440 | cqr->hnode |
441 | = GNUNET_CONTAINER_heap_insert (retry_heap, cqr, | 441 | = GNUNET_CONTAINER_heap_insert (retry_heap, |
442 | cqr, | ||
442 | cqr->retry_time.abs_value_us); | 443 | cqr->retry_time.abs_value_us); |
443 | } | 444 | } |
444 | } | 445 | } |