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