diff options
Diffstat (limited to 'src/dht/gnunet-service-xdht_clients.c')
-rw-r--r-- | src/dht/gnunet-service-xdht_clients.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/dht/gnunet-service-xdht_clients.c b/src/dht/gnunet-service-xdht_clients.c index 3ddb62be1..1c6b5d1bd 100644 --- a/src/dht/gnunet-service-xdht_clients.c +++ b/src/dht/gnunet-service-xdht_clients.c | |||
@@ -268,7 +268,7 @@ static struct GNUNET_CONTAINER_Heap *retry_heap; | |||
268 | /** | 268 | /** |
269 | * Task that re-transmits requests (using retry_heap). | 269 | * Task that re-transmits requests (using retry_heap). |
270 | */ | 270 | */ |
271 | static GNUNET_SCHEDULER_TaskIdentifier retry_task; | 271 | static struct GNUNET_SCHEDULER_Task * retry_task; |
272 | 272 | ||
273 | 273 | ||
274 | /** | 274 | /** |
@@ -875,7 +875,7 @@ transmit_next_request_task (void *cls, | |||
875 | struct ClientQueryRecord *cqr; | 875 | struct ClientQueryRecord *cqr; |
876 | struct GNUNET_TIME_Relative delay; | 876 | struct GNUNET_TIME_Relative delay; |
877 | 877 | ||
878 | retry_task = GNUNET_SCHEDULER_NO_TASK; | 878 | retry_task = NULL; |
879 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 879 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) |
880 | return; | 880 | return; |
881 | while (NULL != (cqr = GNUNET_CONTAINER_heap_remove_root (retry_heap))) | 881 | while (NULL != (cqr = GNUNET_CONTAINER_heap_remove_root (retry_heap))) |
@@ -1028,7 +1028,7 @@ handle_dht_local_get (void *cls, struct GNUNET_SERVER_Client *client, | |||
1028 | &my_identity, | 1028 | &my_identity, |
1029 | &get->key); | 1029 | &get->key); |
1030 | /* start remote requests */ | 1030 | /* start remote requests */ |
1031 | if (GNUNET_SCHEDULER_NO_TASK != retry_task) | 1031 | if (NULL != retry_task) |
1032 | GNUNET_SCHEDULER_cancel (retry_task); | 1032 | GNUNET_SCHEDULER_cancel (retry_task); |
1033 | retry_task = GNUNET_SCHEDULER_add_now (&transmit_next_request_task, NULL); | 1033 | retry_task = GNUNET_SCHEDULER_add_now (&transmit_next_request_task, NULL); |
1034 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 1034 | GNUNET_SERVER_receive_done (client, GNUNET_OK); |
@@ -1422,10 +1422,10 @@ GDS_CLIENTS_done () | |||
1422 | { | 1422 | { |
1423 | GNUNET_assert (client_head == NULL); | 1423 | GNUNET_assert (client_head == NULL); |
1424 | GNUNET_assert (client_tail == NULL); | 1424 | GNUNET_assert (client_tail == NULL); |
1425 | if (GNUNET_SCHEDULER_NO_TASK != retry_task) | 1425 | if (NULL != retry_task) |
1426 | { | 1426 | { |
1427 | GNUNET_SCHEDULER_cancel (retry_task); | 1427 | GNUNET_SCHEDULER_cancel (retry_task); |
1428 | retry_task = GNUNET_SCHEDULER_NO_TASK; | 1428 | retry_task = NULL; |
1429 | } | 1429 | } |
1430 | if (NULL != retry_heap) | 1430 | if (NULL != retry_heap) |
1431 | { | 1431 | { |