*/
static struct DatastoreRequestQueue *drq_tail;
-/**
- * Our connection to the datastore.
- */
-static struct GNUNET_DATASTORE_Handle *dsh;
/**
* Pointer to the currently actively running request,
"DRQ shutdown initiated\n");
#endif
GNUNET_assert (NULL != dsh);
- GNUNET_DATASTORE_disconnect (dsh,
- GNUNET_NO);
- dsh = NULL;
while (NULL != (drq = drq_head))
{
drq_head = drq->next;
rc->cont (rc->cont_cls,
success,
msg);
- GNUNET_DATASTORE_disconnect (rc->rmdsh, GNUNET_NO);
GNUNET_free (rc);
}
struct GNUNET_DATASTORE_Handle *rmdsh;
struct RemoveContext *rc;
- rmdsh = GNUNET_DATASTORE_connect (cfg,
- sched);
if (rmdsh == NULL)
{
GNUNET_break (0);