diff options
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); |