aboutsummaryrefslogtreecommitdiff
path: root/src/datastore/datastore_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r--src/datastore/datastore_api.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c
index 624d0cad7..350c35638 100644
--- a/src/datastore/datastore_api.c
+++ b/src/datastore/datastore_api.c
@@ -315,6 +315,11 @@ GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h,
315{ 315{
316 struct GNUNET_DATASTORE_QueueEntry *qe; 316 struct GNUNET_DATASTORE_QueueEntry *qe;
317 317
318 if (NULL != h->th)
319 {
320 GNUNET_CLIENT_notify_transmit_ready_cancel (h->th);
321 h->th = NULL;
322 }
318 if (h->client != NULL) 323 if (h->client != NULL)
319 { 324 {
320 GNUNET_CLIENT_disconnect (h->client, GNUNET_NO); 325 GNUNET_CLIENT_disconnect (h->client, GNUNET_NO);
@@ -325,11 +330,6 @@ GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h,
325 GNUNET_SCHEDULER_cancel (h->reconnect_task); 330 GNUNET_SCHEDULER_cancel (h->reconnect_task);
326 h->reconnect_task = GNUNET_SCHEDULER_NO_TASK; 331 h->reconnect_task = GNUNET_SCHEDULER_NO_TASK;
327 } 332 }
328 if (NULL != h->th)
329 {
330 GNUNET_CLIENT_notify_transmit_ready_cancel (h->th);
331 h->th = NULL;
332 }
333 while (NULL != (qe = h->queue_head)) 333 while (NULL != (qe = h->queue_head))
334 { 334 {
335 GNUNET_assert (NULL != qe->response_proc); 335 GNUNET_assert (NULL != qe->response_proc);