* - management of global state
*/
/*
- * This file is part of adns, which is
- * Copyright (C) 1997-2000,2003,2006,2014 Ian Jackson
- * Copyright (C) 2014 Mark Wooding
- * Copyright (C) 1999-2000,2003,2006 Tony Finch
- * Copyright (C) 1991 Massachusetts Institute of Technology
- * (See the file INSTALL for full details.)
+ * This file is part of adns, which is Copyright Ian Jackson
+ * and contributors (see the file INSTALL for full details).
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
adns_rr_addr a;
char addrbuf[ADNS_ADDR2TEXT_BUFLEN];
int err;
+ socklen_t salen;
- a.len= sizeof(a.addr);
- err= adns_text2addr(buf,DNS_PORT, 0, &a.addr.sa,&a.len);
+ salen= sizeof(a.addr);
+ err= adns_text2addr(buf,DNS_PORT, 0, &a.addr.sa,&salen);
+ a.len= salen;
switch (err) {
case 0:
break;
}
adns__debug(ads,-1,0,"using nameserver %s",
adns__sockaddr_ntoa(&a.addr.sa, addrbuf));
- addserver(ads,&a.addr.sa,a.len);
+ addserver(ads,&a.addr.sa,salen);
}
static void ccf_search(adns_state ads, const char *fn,
tl= 0;
while (nextword(&bufp,&word,&l)) { count++; tl += l+1; }
- newptrs= malloc(sizeof(char*)*count);
- if (!newptrs) { saveerr(ads,errno); return; }
+ if (count) {
+ newptrs= malloc(sizeof(char*)*count);
+ if (!newptrs) { saveerr(ads,errno); return; }
- newchars= malloc(tl);
- if (!newchars) { saveerr(ads,errno); free(newptrs); return; }
+ newchars= malloc(tl);
+ if (!newchars) { saveerr(ads,errno); free(newptrs); return; }
+ } else {
+ assert(!tl);
+ newptrs= 0;
+ newchars= 0;
+ }
bufp= buf;
pp= newptrs;
static int gen_pton(const char *text, int want_af, adns_sockaddr *a) {
int err;
- int len;
+ socklen_t len;
len= sizeof(*a);
err= adns_text2addr(text,0, adns_qf_addrlit_scope_forbid,
}
} else {
maskwhat = "prefix length";
- initial= strtoul(slash,&ep,10);
- if (*ep || initial>adns__addr_width(sl->base.sa.sa_family)) {
+ unsigned long prefixlen = strtoul(slash,&ep,10);
+ if (*ep || prefixlen>adns__addr_width(sl->base.sa.sa_family)) {
configparseerr(ads,fn,lno,"mask length `%s' invalid",slash);
continue;
}
+ initial= prefixlen;
sl->mask.sa.sa_family= sl->base.sa.sa_family;
adns__prefix_mask(&sl->mask, initial);
}
if (!buf) return;
-#define OPTION__IS(s,op) ((endword-word) op (sizeof(s)-1) && \
+#define WORD__IS(s,op) ((endword-word) op (sizeof(s)-1) && \
!memcmp(word,s,(sizeof(s)-1)))
-#define OPTION_IS(s) (OPTION__IS(s,==))
-#define OPTION_STARTS(s) (OPTION__IS(s,>=) ? ((word+=sizeof(s)-1)) : 0)
+#define WORD_IS(s) (WORD__IS(s,==))
+#define WORD_STARTS(s) (WORD__IS(s,>=) ? ((word+=sizeof(s)-1)) : 0)
while (nextword(&buf,&word,&l)) {
opt=word;
endopt=endword=word+l;
- if (OPTION_IS("debug")) {
+ if (WORD_IS("debug")) {
ads->iflags |= adns_if_debug;
continue;
}
- if (OPTION_STARTS("ndots:")) {
+ if (WORD_STARTS("ndots:")) {
v= strtoul(word,&ep,10);
if (ep==word || ep != endword || v > INT_MAX) {
configparseerr(ads,fn,lno,"option `%.*s' malformed"
ads->searchndots= v;
continue;
}
- if (OPTION_STARTS("adns_checkc:")) {
- if (OPTION_IS("none")) {
+ if (WORD_STARTS("adns_checkc:")) {
+ if (WORD_IS("none")) {
ads->iflags &= ~adns_if_checkc_freq;
ads->iflags |= adns_if_checkc_entex;
- } else if (OPTION_IS("entex")) {
+ } else if (WORD_IS("entex")) {
ads->iflags &= ~adns_if_checkc_freq;
ads->iflags |= adns_if_checkc_entex;
- } else if (OPTION_IS("freq")) {
+ } else if (WORD_IS("freq")) {
ads->iflags |= adns_if_checkc_freq;
} else {
configparseerr(ads,fn,lno, "option adns_checkc has bad value `%s' "
}
continue;
}
- if (OPTION_STARTS("adns_af:")) {
+ if (WORD_STARTS("adns_af:")) {
ads->iflags &= ~adns_if_afmask;
- if (!OPTION_IS("any")) for (;;) {
+ if (!WORD_IS("any")) for (;;) {
const char *comma= memchr(word,',',endopt-word);
endword=comma?comma:endopt;
- if (OPTION_IS("ipv4"))
+ if (WORD_IS("ipv4"))
ads->iflags |= adns_if_permit_ipv4;
- else if (OPTION_IS("ipv6"))
+ else if (WORD_IS("ipv6"))
ads->iflags |= adns_if_permit_ipv6;
else {
- configparseerr(ads,fn,lno, "option adns_af has bad value `%.*s' "
- "(must be `any' or list {`ipv4',`ipv6'},...)",
- (int)(endword-word), word);
+ if (ads->config_report_unknown)
+ adns__diag(ads,-1,0,"%s:%d: "
+ "option adns_af has bad value or entry `%.*s' "
+ "(option must be `any', or list of `ipv4',`ipv6')",
+ fn,lno, (int)(endword-word),word);
break;
}
if (!comma) break;
}
continue;
}
- if (OPTION_IS("adns_ignoreunkcfg")) {
+ if (WORD_IS("adns_ignoreunkcfg")) {
ads->config_report_unknown=0;
continue;
}
if (/* adns's query strategy is not configurable */
- OPTION_STARTS("timeout:") ||
- OPTION_STARTS("attempts:") ||
- OPTION_IS("rotate") ||
+ WORD_STARTS("timeout:") ||
+ WORD_STARTS("attempts:") ||
+ WORD_IS("rotate") ||
/* adns provides the application with knob for this */
- OPTION_IS("no-check-names") ||
+ WORD_IS("no-check-names") ||
/* adns normally does IPv6 if the application wants it; control
* this with the adns_af: option if you like */
- OPTION_IS("inet6") ||
+ WORD_IS("inet6") ||
+ /* adns trusts the resolver anyway */
+ WORD_IS("trust-ad") ||
/* adns does not do edns0 and this is not a problem */
- OPTION_IS("edns0"))
+ WORD_IS("edns0"))
continue;
if (ads->config_report_unknown)
adns__diag(ads,-1,0,"%s:%d: unknown option `%.*s'", fn,lno, l,opt);
}
-#undef OPTION__IS
-#undef OPTION_IS
-#undef OPTION_STARTS
+#undef WORD__IS
+#undef WORD_IS
+#undef WORD_STARTS
}
static void ccf_clearnss(adns_state ads, const char *fn,
r= init_finish(ads);
if (r) return r;
- adns__consistency(ads,0,cc_entex);
+ adns__consistency(ads,0,cc_exit);
*ads_r= ads;
return 0;
}
}
r= init_finish(ads); if (r) return r;
- adns__consistency(ads,0,cc_entex);
+ adns__consistency(ads,0,cc_exit);
*ads_r= ads;
return 0;
}
return init_files(newstate_r, flags, logfn, logfndata);
}
+static void cancel_all(adns_query qu) {
+ if (!qu->parent) adns__cancel(qu);
+ else cancel_all(qu->parent);
+}
+
void adns_finish(adns_state ads) {
int i;
- adns__consistency(ads,0,cc_entex);
+ adns__consistency(ads,0,cc_enter);
for (;;) {
- if (ads->udpw.head) adns__cancel(ads->udpw.head);
- else if (ads->tcpw.head) adns__cancel(ads->tcpw.head);
- else if (ads->childw.head) adns__cancel(ads->childw.head);
- else if (ads->output.head) adns__cancel(ads->output.head);
- else if (ads->intdone.head) adns__cancel(ads->output.head);
+ if (ads->udpw.head) cancel_all(ads->udpw.head);
+ else if (ads->tcpw.head) cancel_all(ads->tcpw.head);
+ else if (ads->childw.head) cancel_all(ads->childw.head);
+ else if (ads->output.head) cancel_all(ads->output.head);
+ else if (ads->intdone.head) cancel_all(ads->output.head);
else break;
}
for (i=0; i<ads->nudpsockets; i++) close(ads->udpsockets[i].fd);
}
void adns_forallqueries_begin(adns_state ads) {
- adns__consistency(ads,0,cc_entex);
+ adns__consistency(ads,0,cc_enter);
ads->forallnext=
ads->udpw.head ? ads->udpw.head :
ads->tcpw.head ? ads->tcpw.head :
adns_query adns_forallqueries_next(adns_state ads, void **context_r) {
adns_query qu, nqu;
- adns__consistency(ads,0,cc_entex);
+ adns__consistency(ads,0,cc_enter);
nqu= ads->forallnext;
for (;;) {
qu= nqu;
~ianmdlvl / adns.git / blobdiff