X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Fsetup.c;h=99d1f088ebf3f7e12d838e5e92cb4af836ed6c96;hb=d855b532b689db96ca7f3b245ddf2b0bf149431d;hp=6393f0389d5921d3b8f87b22f6b1db6de685cdcc;hpb=78bcc1723e2e87c659bf63365e118245e53fd7e1;p=adns.git diff --git a/src/setup.c b/src/setup.c index 6393f03..99d1f08 100644 --- a/src/setup.c +++ b/src/setup.c @@ -29,6 +29,8 @@ #include #include +#include +#include #include #include "internal.h" @@ -130,7 +132,6 @@ static void ccf_search(adns_state ads, const char *fn, int lno, const char *buf) free(ads->searchlist); ads->nsearchlist= count; ads->searchlist= newptrs; - /* fixme: actually pay attention */ } static void ccf_sortlist(adns_state ads, const char *fn, int lno, const char *buf) { @@ -440,18 +441,20 @@ static int init_begin(adns_state *ads_r, adns_initflags flags, FILE *diagfile) { ads->iflags= flags; ads->diagfile= diagfile; + ads->configerrno= 0; LIST_INIT(ads->timew); LIST_INIT(ads->childw); LIST_INIT(ads->output); + ads->forallnext= 0; ads->nextid= 0x311f; ads->udpsocket= ads->tcpsocket= -1; adns__vbuf_init(&ads->tcpsend); adns__vbuf_init(&ads->tcprecv); ads->nservers= ads->nsortlist= ads->nsearchlist= ads->tcpserver= 0; - ads->tcpstate= server_disconnected; - ads->searchlist= 0; ads->searchndots= 1; + ads->tcpstate= server_disconnected; timerclear(&ads->tcptimeout); + ads->searchlist= 0; *ads_r= ads; return 0; @@ -564,3 +567,29 @@ void adns_finish(adns_state ads) { adns__vbuf_free(&ads->tcprecv); free(ads); } + +void adns_forallqueries_begin(adns_state ads) { + ads->forallnext= + ads->timew.head ? ads->timew.head : + ads->childw.head ? ads->childw.head : + ads->output.head; +} + +adns_query adns_forallqueries_next(adns_state ads, void **context_r) { + adns_query qu, nqu; + + nqu= ads->forallnext; + for (;;) { + qu= nqu; + if (!qu) return 0; + nqu= + qu->next ? qu->next : + qu == ads->timew.tail ? (ads->childw.head ? ads->childw.head : ads->output.head) : + qu == ads->childw.tail ? ads->output.head : + 0; + if (!qu->parent) break; + } + ads->forallnext= nqu; + if (context_r) *context_r= qu->ctx.ext; + return qu; +}