diff --git a/src/dns.c b/src/dns.c index 14c811a10..ce7c9a28b 100644 --- a/src/dns.c +++ b/src/dns.c @@ -806,7 +806,7 @@ void dns_session_free(struct dns_session *ds) pool_free(dns_session_pool, ds); } -static struct appctx *dns_session_create(struct dns_session *ds); +static struct appctx *dns_session_create(struct dns_session *ds, int tempo); static int dns_session_init(struct appctx *appctx) { @@ -912,7 +912,7 @@ static void dns_session_release(struct appctx *appctx) /* Create a new appctx, We hope we can * create from the release callback! */ - ds->appctx = dns_session_create(ds); + ds->appctx = dns_session_create(ds, 1); if (!ds->appctx) { dns_session_free(ds); HA_SPIN_UNLOCK(DNS_LOCK, &dss->lock); @@ -937,8 +937,10 @@ static struct applet dns_session_applet = { /* * Function used to create an appctx for a DNS session * It sets its context into appctx->svcctx. + * if is set, then the session startup will be delayed by 1 + * second */ -static struct appctx *dns_session_create(struct dns_session *ds) +static struct appctx *dns_session_create(struct dns_session *ds, int tempo) { struct appctx *appctx; @@ -947,10 +949,14 @@ static struct appctx *dns_session_create(struct dns_session *ds) goto out_close; appctx->svcctx = (void *)ds; - if (appctx_init(appctx) == -1) { - ha_alert("out of memory in dns_session_create().\n"); - goto out_free_appctx; + if (!tempo) { + if (appctx_init(appctx) == -1) { + ha_alert("out of memory in dns_session_create().\n"); + goto out_free_appctx; + } } + else + appctx_schedule(appctx, tick_add(now_ms, MS_TO_TICKS(1000))); return appctx; @@ -1072,7 +1078,7 @@ struct dns_session *dns_session_new(struct dns_stream_server *dss) ds->task_exp->process = dns_process_query_exp; ds->task_exp->context = ds; - ds->appctx = dns_session_create(ds); + ds->appctx = dns_session_create(ds, 0); if (!ds->appctx) goto error;