diff options
| author | Christian Grothoff <christian@grothoff.org> | 2017-03-10 17:28:03 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2017-03-10 17:28:03 +0100 |
| commit | 6329bd3a348d51927b8188a04a1723c6e2edae1f (patch) | |
| tree | b7b199c516261f23972bf2b43cdb33938093cb32 /src/datastore | |
| parent | 71fb288ad23fc6247642094bcc5bb42da2fe108d (diff) | |
properly handle error on empty queue
Diffstat (limited to 'src/datastore')
| -rw-r--r-- | src/datastore/datastore_api.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index cf7c7bb1a7..ef7cd7532b 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c @@ -323,14 +323,14 @@ mq_error_handler (void *cls, "MQ error, reconnecting to DATASTORE\n"); do_disconnect (h); qe = h->queue_head; + if (NULL == qe) + return; if (NULL != qe->delay_warn_task) { GNUNET_SCHEDULER_cancel (qe->delay_warn_task); qe->delay_warn_task = NULL; } - - if ( (NULL != qe) && - (NULL == qe->env) ) + if (NULL == qe->env) { union QueueContext qc = qe->qc; uint16_t rt = qe->response_type; |