diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-05-31 15:24:34 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-05-31 15:24:34 +0000 |
commit | a1d67fd731c7fdf4af682e551d87b1c7cf6064c2 (patch) | |
tree | c113200392db0113c1aaa87a8efd3b47c5574d35 /src/datastore/datastore_api.c | |
parent | 7131d326db99ed34b52cdb1e665f6f7994c877d2 (diff) | |
download | gnunet-a1d67fd731c7fdf4af682e551d87b1c7cf6064c2.tar.gz gnunet-a1d67fd731c7fdf4af682e551d87b1c7cf6064c2.zip |
fix
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r-- | src/datastore/datastore_api.c | 10 |
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); |