int i;
for (i = 0; i < global.nbthread; i++) {
- if (idle_conns[i].cleanup_task)
- task_destroy(idle_conns[i].cleanup_task);
+ task_destroy(idle_conns[i].cleanup_task);
}
}
REGISTER_POST_DEINIT(deinit_idle_conns);
{
pool_free(dns_msg_buf, ds->rx_msg.area);
pool_free(dns_msg_buf, ds->tx_ring_area);
- if (ds->task_exp)
- task_destroy(ds->task_exp);
+ task_destroy(ds->task_exp);
dns_queries_flush(ds);
return ds;
error:
- if (ds->task_exp)
- task_destroy(ds->task_exp);
+ task_destroy(ds->task_exp);
pool_free(dns_msg_buf, ds->rx_msg.area);
pool_free(dns_msg_buf, ds->tx_ring_area);
mem_error:
if (hlua_sub) {
- if (hlua_sub->task)
- task_destroy(hlua_sub->task);
+ task_destroy(hlua_sub->task);
if (hlua_sub->hlua)
hlua_ctx_destroy(hlua_sub->hlua);
pool_free(pool_head_hlua_event_sub, hlua_sub);
/* disable this peer section so that it kills itself */
if (curpeers->sighandler)
signal_unregister_handler(curpeers->sighandler);
- if (curpeers->sync_task)
- task_destroy(curpeers->sync_task);
+ task_destroy(curpeers->sync_task);
curpeers->sync_task = NULL;
curpeers->peers_fe = NULL;
}
if (ns->stream) {
if (ns->stream->ring_req)
ring_free(ns->stream->ring_req);
- if (ns->stream->task_req)
- task_destroy(ns->stream->task_req);
- if (ns->stream->task_rsp)
- task_destroy(ns->stream->task_rsp);
+ task_destroy(ns->stream->task_req);
+ task_destroy(ns->stream->task_rsp);
free(ns->stream);
}
LIST_DEL_INIT(&ns->list);