aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-05-31 15:24:34 +0000
committerChristian Grothoff <christian@grothoff.org>2011-05-31 15:24:34 +0000
commita1d67fd731c7fdf4af682e551d87b1c7cf6064c2 (patch)
treec113200392db0113c1aaa87a8efd3b47c5574d35 /src/datastore
parent7131d326db99ed34b52cdb1e665f6f7994c877d2 (diff)
downloadgnunet-a1d67fd731c7fdf4af682e551d87b1c7cf6064c2.tar.gz
gnunet-a1d67fd731c7fdf4af682e551d87b1c7cf6064c2.zip
fix
Diffstat (limited to 'src/datastore')
-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);