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) | |
download | gnunet-6329bd3a348d51927b8188a04a1723c6e2edae1f.tar.gz gnunet-6329bd3a348d51927b8188a04a1723c6e2edae1f.zip |
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 cf7c7bb1a..ef7cd7532 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -323,14 +323,14 @@ mq_error_handler (void *cls, | |||
323 | "MQ error, reconnecting to DATASTORE\n"); | 323 | "MQ error, reconnecting to DATASTORE\n"); |
324 | do_disconnect (h); | 324 | do_disconnect (h); |
325 | qe = h->queue_head; | 325 | qe = h->queue_head; |
326 | if (NULL == qe) | ||
327 | return; | ||
326 | if (NULL != qe->delay_warn_task) | 328 | if (NULL != qe->delay_warn_task) |
327 | { | 329 | { |
328 | GNUNET_SCHEDULER_cancel (qe->delay_warn_task); | 330 | GNUNET_SCHEDULER_cancel (qe->delay_warn_task); |
329 | qe->delay_warn_task = NULL; | 331 | qe->delay_warn_task = NULL; |
330 | } | 332 | } |
331 | 333 | if (NULL == qe->env) | |
332 | if ( (NULL != qe) && | ||
333 | (NULL == qe->env) ) | ||
334 | { | 334 | { |
335 | union QueueContext qc = qe->qc; | 335 | union QueueContext qc = qe->qc; |
336 | uint16_t rt = qe->response_type; | 336 | uint16_t rt = qe->response_type; |