aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/datastore/datastore_api.c6
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;