chiark / gitweb /
New features:
[adns] / client / adnstest.c
CommitLineData
98db6da3 1/*
2 * dtest.c
3 * - simple test program, not part of the library
4 */
5/*
3ff64957 6 * This file is part of adns, which is Copyright (C) 1997-1999 Ian Jackson
98db6da3 7 *
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2, or (at your option)
11 * any later version.
12 *
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, write to the Free Software Foundation,
20 * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
21 */
e7afa27f 22
23#include <stdio.h>
2c7b101b 24#include <sys/time.h>
31d3a9d0 25#include <unistd.h>
1e9efa71 26#include <assert.h>
27#include <stdlib.h>
c2875680 28#include <string.h>
4f973eb5 29#include <errno.h>
4bc87817 30
31#include "adns.h"
32
33#include "config.h"
e7afa27f 34
4fb3d854 35#ifndef OUTPUTSTREAM
36# define OUTPUTSTREAM stdout
37#endif
38
4bc87817 39#ifndef HAVE_POLL
40#undef poll
41int poll(struct pollfd *ufds, int nfds, int timeout) {
42 fputs("poll(2) not supported on this system\n",stderr);
e516ee75 43 exit(5);
4bc87817 44}
45#define adns_beforepoll(a,b,c,d,e) 0
46#define adns_afterpoll(a,b,c,d) 0
47#endif
e7afa27f 48
e516ee75 49static void failure_status(const char *what, adns_status st) NONRETURNING;
c2875680 50static void failure_status(const char *what, adns_status st) {
1e9efa71 51 fprintf(stderr,"adns failure: %s: %s\n",what,adns_strerror(st));
52 exit(2);
53}
54
e516ee75 55static void failure_errno(const char *what, int errnoval) NONRETURNING;
c2875680 56static void failure_errno(const char *what, int errnoval) {
57 fprintf(stderr,"adns failure: %s: errno=%d\n",what,errnoval);
58 exit(2);
59}
60
e516ee75 61static void usageerr(const char *why) NONRETURNING;
62static void usageerr(const char *why) {
63 fprintf(stderr,
64 "bad usage: %s\n"
65 "usage: adnstest [-<initflagsnum>[,<owninitflags>]] [/<initstring>]\n"
66 " [ :<typenum>,... ]\n"
67 " [ [<queryflagsnum>[,<ownqueryflags>]/]<domain> ... ]\n"
68 "initflags: p use poll(2) instead of select(2)\n"
69 " s use adns_wait with specified query, instead of 0\n"
70 "queryflags: a print status abbrevs instead of strings\n"
71 "exit status: 0 ok (though some queries may have failed)\n"
72 " 1 used by test harness to indicate test failed\n"
73 " 2 unable to submit or init or some such\n"
74 " 3 unexpected failure\n"
75 " 4 usage error\n"
76 " 5 operation not supported on this system\n",
77 why);
78 exit(4);
79}
1e9efa71 80
cfdca685 81static const adns_rrtype defaulttypes[]= {
82 adns_r_a,
83 adns_r_ns_raw,
84 adns_r_cname,
61093792 85 adns_r_soa_raw,
cfdca685 86 adns_r_ptr_raw,
61093792 87 adns_r_hinfo,
f2ad23ee 88 adns_r_mx_raw,
d4c7b0b1 89 adns_r_txt,
26eb6bdc 90 adns_r_rp_raw,
61093792 91
cd363ffd 92 adns_r_addr,
26eb6bdc 93 adns_r_ns,
cd1bde2f 94 adns_r_ptr,
61093792 95 adns_r_mx,
96
97 adns_r_soa,
98 adns_r_rp,
99
cfdca685 100 adns_r_none
101};
102
f2ad23ee 103static void dumptype(adns_status ri, const char *rrtn, const char *fmtn) {
104 fprintf(stdout, "%s(%s)%s%s",
105 ri ? "?" : rrtn, ri ? "?" : fmtn ? fmtn : "-",
106 ri ? " " : "", ri ? adns_strerror(ri) : "");
107}
108
c2875680 109static void fdom_split(const char *fdom, const char **dom_r, int *qf_r,
110 char *ownflags, int ownflags_l) {
82a3a6be 111 int qf;
112 char *ep;
113
114 qf= strtoul(fdom,&ep,0);
c2875680 115 if (*ep == ',' && strchr(ep,'/')) {
116 ep++;
117 while (*ep != '/') {
118 if (--ownflags_l <= 0) { fputs("too many flags\n",stderr); exit(3); }
119 *ownflags++= *ep++;
120 }
121 }
82a3a6be 122 if (*ep != '/') { *dom_r= fdom; *qf_r= 0; }
123 else { *dom_r= ep+1; *qf_r= qf; }
c2875680 124 *ownflags= 0;
82a3a6be 125}
126
4f973eb5 127static int consistsof(const char *string, const char *accept) {
128 return strspn(string,accept) == strlen(string);
129}
130
f2ad23ee 131int main(int argc, char *const *argv) {
d6b05172 132 struct myctx {
133 adns_query qu;
0e02fa7a 134 int doneyet, found;
135 const char *fdom;
d6b05172 136 };
137
e7afa27f 138 adns_state ads;
d6b05172 139 adns_query qu;
0e02fa7a 140 struct myctx *mcs, *mc, *mcw;
d6b05172 141 void *mcr;
d05cc330 142 adns_answer *ans;
e3324da1 143 const char *initstring, *rrtn, *fmtn;
82a3a6be 144 const char *const *fdomlist, *domain;
f2ad23ee 145 char *show, *cp;
4f973eb5 146 int len, i, qc, qi, tc, ti, ch, qflags, initflagsnum, npollfds, npollfdsavail, timeout;
147 struct pollfd *pollfds;
125de2a9 148 adns_status ri;
149 int r;
cfdca685 150 const adns_rrtype *types;
2c7b101b 151 struct timeval now;
f2ad23ee 152 adns_rrtype *types_a;
c2875680 153 char ownflags[10];
4f973eb5 154 char *ep;
155 const char *initflags, *owninitflags;
1e9efa71 156
4f973eb5 157 if (argv[0] && argv[1] && argv[1][0] == '-') {
158 initflags= argv[1]+1;
159 argv++;
160 } else {
161 initflags= "";
162 }
e3324da1 163 if (argv[0] && argv[1] && argv[1][0] == '/') {
164 initstring= argv[1]+1;
165 argv++;
166 } else {
167 initstring= 0;
168 }
4f973eb5 169
170 initflagsnum= strtoul(initflags,&ep,0);
171 if (*ep == ',') {
172 owninitflags= ep+1;
e516ee75 173 if (!consistsof(owninitflags,"ps")) usageerr("unknown owninitflag");
4f973eb5 174 } else if (!*ep) {
175 owninitflags= "";
176 } else {
e516ee75 177 usageerr("bad <initflagsnum>[,<owninitflags>]");
4f973eb5 178 }
e3324da1 179
f2ad23ee 180 if (argv[0] && argv[1] && argv[1][0] == ':') {
181 for (cp= argv[1]+1, tc=1; (ch= *cp); cp++)
182 if (ch==',') tc++;
04be144e 183 types_a= malloc(sizeof(*types_a)*(tc+1));
f2ad23ee 184 if (!types_a) { perror("malloc types"); exit(3); }
185 for (cp= argv[1]+1, ti=0; ti<tc; ti++) {
186 types_a[ti]= strtoul(cp,&cp,10);
187 if ((ch= *cp)) {
e516ee75 188 if (ch != ',') usageerr("unexpected char (not comma) in or between types");
f2ad23ee 189 cp++;
190 }
191 }
04be144e 192 *cp++= adns_r_none;
f2ad23ee 193 types= types_a;
194 argv++;
195 } else {
196 types= defaulttypes;
197 }
198
e516ee75 199 if (!(argv[0] && argv[1])) usageerr("no query domains supplied");
200 fdomlist= (const char *const*)argv+1;
cfdca685 201
82a3a6be 202 for (qc=0; fdomlist[qc]; qc++);
cfdca685 203 for (tc=0; types[tc] != adns_r_none; tc++);
d6b05172 204 mcs= malloc(sizeof(*mcs)*qc*tc);
205 if (!mcs) { perror("malloc mcs"); exit(3); }
e7afa27f 206
e3324da1 207 if (initstring) {
4f973eb5 208 r= adns_init_strcfg(&ads,
209 (adns_if_debug|adns_if_noautosys)^initflagsnum,
210 stdout,initstring);
e3324da1 211 } else {
4f973eb5 212 r= adns_init(&ads,
213 (adns_if_debug|adns_if_noautosys)^initflagsnum,
214 0);
e3324da1 215 }
c2875680 216 if (r) failure_errno("init",r);
1e9efa71 217
4f973eb5 218 npollfdsavail= 0;
219 pollfds= 0;
220
1e9efa71 221 for (qi=0; qi<qc; qi++) {
c2875680 222 fdom_split(fdomlist[qi],&domain,&qflags,ownflags,sizeof(ownflags));
e516ee75 223 if (!consistsof(ownflags,"a")) usageerr("unknown ownqueryflag");
cfdca685 224 for (ti=0; ti<tc; ti++) {
d6b05172 225 mc= &mcs[qi*tc+ti];
226 mc->doneyet= 0;
0e02fa7a 227 mc->fdom= fdomlist[qi];
d6b05172 228
18dc94a5 229 fprintf(stdout,"%s flags %d type %d",domain,qflags,types[ti]);
d6b05172 230 r= adns_submit(ads,domain,types[ti],qflags,mc,&mc->qu);
125de2a9 231 if (r == ENOSYS) {
b8358304 232 fprintf(stdout," not implemented\n");
d6b05172 233 mc->qu= 0;
234 mc->doneyet= 1;
b8358304 235 } else if (r) {
c2875680 236 failure_errno("submit",r);
b8358304 237 } else {
f2ad23ee 238 ri= adns_rr_info(types[ti], &rrtn,&fmtn,0, 0,0);
4fb3d854 239 putc(' ',stdout);
f2ad23ee 240 dumptype(ri,rrtn,fmtn);
b8358304 241 fprintf(stdout," submitted\n");
242 }
cfdca685 243 }
1e9efa71 244 }
31d3a9d0 245
0e02fa7a 246 for (;;) {
247 for (qi=0; qi<qc; qi++) {
248 for (ti=0; ti<tc; ti++) {
249 mc= &mcs[qi*tc+ti];
250 mc->found= 0;
251 }
252 }
253 for (adns_forallqueries_begin(ads);
254 (qu= adns_forallqueries_next(ads,&mcr));
255 ) {
256 mc= mcr;
257 assert(qu == mc->qu);
258 assert(!mc->doneyet);
259 mc->found= 1;
260 }
261 mcw= 0;
262 for (qi=0; qi<qc; qi++) {
263 for (ti=0; ti<tc; ti++) {
264 mc= &mcs[qi*tc+ti];
265 if (mc->doneyet) continue;
266 assert(mc->found);
267 if (!mcw) mcw= mc;
268 }
269 }
270 if (!mcw) break;
d6b05172 271
8f2aa812 272 if (strchr(owninitflags,'s')) {
273 qu= mcw->qu;
274 mc= mcw;
275 } else {
276 qu= 0;
277 mc= 0;
278 }
4f973eb5 279
3ea0e5b9 280 if (strchr(owninitflags,'p')) {
281 for (;;) {
282 r= adns_check(ads,&qu,&ans,&mcr);
283 if (r != EWOULDBLOCK) break;
4f973eb5 284 for (;;) {
3ea0e5b9 285 npollfds= npollfdsavail;
286 timeout= -1;
287 r= adns_beforepoll(ads, pollfds, &npollfds, &timeout, 0);
288 if (r != ERANGE) break;
289 pollfds= realloc(pollfds,sizeof(*pollfds)*npollfds);
290 if (!pollfds) failure_errno("realloc pollfds",errno);
291 npollfdsavail= npollfds;
4f973eb5 292 }
3ea0e5b9 293 if (r) failure_errno("beforepoll",r);
294 r= poll(pollfds,npollfds,timeout);
295 if (r == -1) failure_errno("poll",errno);
296 adns_afterpoll(ads,pollfds, r?npollfds:0, 0);
4f973eb5 297 }
3ea0e5b9 298 } else {
299 r= adns_wait(ads,&qu,&ans,&mcr);
300 }
301 if (r) failure_errno("wait/check",r);
302
8f2aa812 303 if (mc) assert(mcr==mc);
304 else mc= mcr;
305 assert(qu==mc->qu);
306 assert(!mc->doneyet);
307
3ea0e5b9 308 fdom_split(mc->fdom,&domain,&qflags,ownflags,sizeof(ownflags));
d6b05172 309
3ea0e5b9 310 if (gettimeofday(&now,0)) { perror("gettimeofday"); exit(3); }
2c7b101b 311
3ea0e5b9 312 ri= adns_rr_info(ans->type, &rrtn,&fmtn,&len, 0,0);
313 fprintf(stdout, "%s flags %d type ",domain,qflags);
314 dumptype(ri,rrtn,fmtn);
315 fprintf(stdout, "%s%s: %s; nrrs=%d; cname=%s; owner=%s; ttl=%ld\n",
316 ownflags[0] ? " ownflags=" : "", ownflags,
317 strchr(ownflags,'a')
318 ? adns_errabbrev(ans->status)
319 : adns_strerror(ans->status),
320 ans->nrrs,
321 ans->cname ? ans->cname : "$",
322 ans->owner ? ans->owner : "$",
323 (long)ans->expires - (long)now.tv_sec);
324 if (ans->nrrs) {
325 assert(!ri);
326 for (i=0; i<ans->nrrs; i++) {
125de2a9 327 ri= adns_rr_info(ans->type, 0,0,0, ans->rrs.bytes + i*len, &show);
328 if (ri) failure_status("info",ri);
3ea0e5b9 329 fprintf(stdout," %s\n",show);
330 free(show);
1e9efa71 331 }
3ea0e5b9 332 }
333 free(ans);
0e02fa7a 334
3ea0e5b9 335 mc->doneyet= 1;
1e9efa71 336 }
d05cc330 337
d6b05172 338 free(mcs);
61093792 339 adns_finish(ads);
340
e7afa27f 341 exit(0);
342}