From 6b1872cb726e672b0e625c46075dab8ed41034d8 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sun, 11 Sep 2016 18:36:31 +0000 Subject: fix dht kill issue --- src/dht/gnunet-service-dht_clients.c | 28 +++++++++++++++++++++------- 1 file changed, 21 insertions(+), 7 deletions(-) (limited to 'src/dht/gnunet-service-dht_clients.c') diff --git a/src/dht/gnunet-service-dht_clients.c b/src/dht/gnunet-service-dht_clients.c index 2e8d309db..38dbb64e5 100644 --- a/src/dht/gnunet-service-dht_clients.c +++ b/src/dht/gnunet-service-dht_clients.c @@ -626,11 +626,17 @@ handle_dht_local_get (void *cls, struct GNUNET_SERVER_Client *client, /* start remote requests */ if (NULL != retry_task) GNUNET_SCHEDULER_cancel (retry_task); - retry_task = GNUNET_SCHEDULER_add_now (&transmit_next_request_task, NULL); + retry_task = GNUNET_SCHEDULER_add_now (&transmit_next_request_task, + NULL); /* perform local lookup */ - GDS_DATACACHE_handle_get (&get->key, cqr->type, cqr->xquery, xquery_size, - NULL, 0); - GNUNET_SERVER_receive_done (client, GNUNET_OK); + GDS_DATACACHE_handle_get (&get->key, + cqr->type, + cqr->xquery, + xquery_size, + NULL, + 0); + GNUNET_SERVER_receive_done (client, + GNUNET_OK); } @@ -1515,15 +1521,23 @@ GDS_CLIENTS_init () * Shutdown client subsystem. */ void -GDS_CLIENTS_done () +GDS_CLIENTS_stop () { - GNUNET_assert (client_head == NULL); - GNUNET_assert (client_tail == NULL); if (NULL != retry_task) { GNUNET_SCHEDULER_cancel (retry_task); retry_task = NULL; } +} + +/** + * Shutdown client subsystem. + */ +void +GDS_CLIENTS_done () +{ + GNUNET_assert (client_head == NULL); + GNUNET_assert (client_tail == NULL); if (NULL != retry_heap) { GNUNET_assert (0 == GNUNET_CONTAINER_heap_get_size (retry_heap)); -- cgit v1.2.3