From c14b2dc0cb0c501851b8e0091b5114701df34089 Mon Sep 17 00:00:00 2001
From: Christian Grothoff <christian@grothoff.org>
Date: Mon, 30 May 2011 13:27:24 +0000
Subject: proper shutdown

---
 src/datastore/datastore_api.c | 10 ++++++++++
 1 file changed, 10 insertions(+)

(limited to 'src/datastore')

diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c
index 33b5cc232..07e48931e 100644
--- a/src/datastore/datastore_api.c
+++ b/src/datastore/datastore_api.c
@@ -325,6 +325,11 @@ GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h,
       GNUNET_SCHEDULER_cancel (h->reconnect_task);
       h->reconnect_task = GNUNET_SCHEDULER_NO_TASK;
     }
+  if (NULL != h->th)
+    {
+      GNUNET_CLIENT_notify_transmit_ready_cancel (h->th);
+      h->th = NULL;
+    }
   while (NULL != (qe = h->queue_head))
     {
       GNUNET_assert (NULL != qe->response_proc);
@@ -344,11 +349,13 @@ GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h,
 						   h))
 	    return;
 	  GNUNET_CLIENT_disconnect (h->client, GNUNET_NO);
+	  h->client = NULL;
 	}
       GNUNET_break (0);
     }
   GNUNET_STATISTICS_destroy (h->stats,
 			     GNUNET_NO);
+  h->stats = NULL;
   GNUNET_free (h);
 }
 
@@ -603,6 +610,7 @@ transmit_request (void *cls,
   qe->was_transmitted = GNUNET_YES;
   GNUNET_SCHEDULER_cancel (qe->task);
   qe->task = GNUNET_SCHEDULER_NO_TASK;
+  GNUNET_assert (GNUNET_NO == h->in_receive);
   h->in_receive = GNUNET_YES;
   GNUNET_CLIENT_receive (h->client,
 			 qe->response_proc,
@@ -675,6 +683,8 @@ process_queue (struct GNUNET_DATASTORE_Handle *h)
 					       GNUNET_YES,
 					       &transmit_request,
 					       h);
+  GNUNET_assert (GNUNET_NO == h->in_receive);
+  GNUNET_break (NULL != h->th);
 }
 
 
-- 
cgit v1.2.3