X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?a=blobdiff_plain;f=resolver.c;h=3a6ea20561714426a6e490d5b418be4acd7bcf71;hb=6ec6ff78fc906177a1f5ef6f432ed1d61409e995;hp=f2023fa0589289eb67d2ee192aa086c152f943c1;hpb=82aed9f7c5ddcfef58a20e326cbcfa2932e88ebf;p=secnet.git diff --git a/resolver.c b/resolver.c index f2023fa..3a6ea20 100644 --- a/resolver.c +++ b/resolver.c @@ -20,6 +20,7 @@ struct adns { struct query { void *cst; + const char *name; int port; struct comm_if *comm; resolve_answer_fn *answer; @@ -34,8 +35,13 @@ static bool_t resolve_request(void *sst, cstring_t name, struct adns *st=sst; struct query *q; int rv; - const int maxlitlen=50; - + const int maxlitlen= +#ifdef CONFIG_IPV6 + ADNS_ADDR2TEXT_BUFLEN*2 +#else + 50 +#endif + ; ssize_t l=strlen(name); if (name[0]=='[' && l2 && name[l-1]==']') { char trimmed[maxlitlen+1]; @@ -45,12 +51,28 @@ static bool_t resolve_request(void *sst, cstring_t name, FILLZERO(ca); ca.comm=comm; ca.ix=-1; +#ifdef CONFIG_IPV6 + socklen_t salen=sizeof(ca.ia); + rv=adns_text2addr(trimmed, port, adns_qf_addrlit_ipv4_quadonly, + &ca.ia.sa, &salen); + assert(rv!=ENOSPC); + if (rv) { + char msg[250]; + snprintf(msg,sizeof(msg),"invalid address literal: %s", + strerror(rv)); + msg[sizeof(msg)-1]=0; + cb(cst,0,0,name,msg); + } else { + cb(cst,&ca,1,name,0); + } +#else ca.ia.sin.sin_family=AF_INET; ca.ia.sin.sin_port=htons(port); if (inet_aton(trimmed,&ca.ia.sin.sin_addr)) - cb(cst,&ca,1,0); + cb(cst,&ca,1,name,0); else - cb(cst,0,0,"invalid IP address"); + cb(cst,0,0,name,"invalid IP address"); +#endif return True; } @@ -58,6 +80,7 @@ static bool_t resolve_request(void *sst, cstring_t name, q->cst=cst; q->comm=comm; q->port=port; + q->name=name; q->answer=cb; rv=adns_submit(st->ast, name, adns_r_addr, 0, q, &q->query); @@ -96,7 +119,7 @@ static void resolver_afterpoll(void *sst, struct pollfd *fds, int nfds) if (rv==0) { q=qp; if (ans->status!=adns_s_ok) { - q->answer(q->cst,NULL,0,adns_strerror(ans->status)); + q->answer(q->cst,NULL,0,q->name,adns_strerror(ans->status)); free(q); free(ans); } else { @@ -132,7 +155,7 @@ static void resolver_afterpoll(void *sst, struct pollfd *fds, int nfds) break; } } - q->answer(q->cst,ca_buf,wslot,0); + q->answer(q->cst,ca_buf,wslot,q->name,0); free(q); free(ans); } @@ -182,7 +205,7 @@ static list_t *adnsresolver_apply(closure_t *self, struct cloc loc, } register_for_poll(st, resolver_beforepoll, resolver_afterpoll, - ADNS_POLLFDS_RECOMMENDED+5,"resolver"); + "resolver"); return new_closure(&st->cl); }