aboutsummaryrefslogtreecommitdiff
path: root/src/dht/gnunet-service-dht_clients.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2017-01-22 00:46:03 +0100
committerChristian Grothoff <christian@grothoff.org>2017-01-22 00:46:03 +0100
commit7e9e4e320d6eee5bf6afd876b282609712cb72db (patch)
treeeda9315b99a026c9033d2db0ed7993d4e524700d /src/dht/gnunet-service-dht_clients.c
parent542bf871c6eebdc645884960559e15ce400939e6 (diff)
downloadgnunet-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.c15
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}