chiark / gitweb /
src/query.c: New function `adns__free_interim' for releasing memory.
[adns.git] / src / types.c
1 /*
2  * types.c
3  * - RR-type-specific code, and the machinery to call it
4  */
5 /*
6  *  This file is part of adns, which is
7  *    Copyright (C) 1997-2000,2003,2006  Ian Jackson
8  *    Copyright (C) 1999-2000,2003,2006  Tony Finch
9  *    Copyright (C) 1991 Massachusetts Institute of Technology
10  *  (See the file INSTALL for full details.)
11  *  
12  *  This program is free software; you can redistribute it and/or modify
13  *  it under the terms of the GNU General Public License as published by
14  *  the Free Software Foundation; either version 2, or (at your option)
15  *  any later version.
16  *  
17  *  This program is distributed in the hope that it will be useful,
18  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
19  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
20  *  GNU General Public License for more details.
21  *  
22  *  You should have received a copy of the GNU General Public License
23  *  along with this program; if not, write to the Free Software Foundation,
24  *  Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. 
25  */
26
27 #include <stdlib.h>
28
29 #include <sys/types.h>
30 #include <sys/socket.h>
31 #include <netinet/in.h>
32 #include <arpa/inet.h>
33
34 #include "internal.h"
35
36 #define R_NOMEM       return adns_s_nomemory
37 #define CSP_ADDSTR(s) do {                      \
38     if (!adns__vbuf_appendstr(vb,(s))) R_NOMEM; \
39   } while (0)
40
41 /*
42  * order of sections:
43  *
44  * _string                    (pap)
45  * _textdata, _qstring        (csp)
46  * _str                       (mf,cs)
47  * _intstr                    (mf,csp,cs)
48  * _manyistr                  (mf,cs)
49  * _txt                       (pa)
50  * _inaddr                    (pa,di,cs
51  *                              +search_sortlist, dip_genaddr, csp_genaddr)
52  * _in6addr                   (pa,di,cs)
53  * _addr                      (pa,di,div,csp,cs,gsz
54  *                              +search_sortlist_sa, dip_sockaddr)
55  * _domain                    (pap,csp,cs)
56  * _dom_raw                   (pa)
57  * _host_raw                  (pa)
58  * _hostaddr                  (pap,pa,dip,di,mfp,mf,csp,cs
59  *                              +pap_findaddrs, icb_hostaddr)
60  * _mx_raw                    (pa,di)
61  * _mx                        (pa,di)
62  * _inthostaddr               (mf,cs)
63  * _inthost                   (cs)
64  * _ptr                       (ckl,pa +icb_ptr)
65  * _strpair                   (mf)
66  * _intstrpair                (mf)
67  * _hinfo                     (pa)
68  * _mailbox                   (pap,csp +pap_mailbox822)
69  * _rp                        (pa,cs)
70  * _soa                       (pa,mf,cs)
71  * _srv*                      (ckl,(pap),pa*2,mf*2,di,(csp),cs*2,postsort)
72  * _byteblock                 (mf)
73  * _opaque                    (pa,cs)
74  * _flat                      (mf)
75  *
76  * within each section:
77  *    ckl_*
78  *    pap_*
79  *    pa_*
80  *    dip_*
81  *    di_*
82  *    mfp_*
83  *    mf_*
84  *    csp_*
85  *    cs_*
86  *    gsz_*
87  *    postsort_*
88  */
89
90 /*
91  * _qstring               (pap,csp)
92  */
93
94 static adns_status pap_qstring(const parseinfo *pai, int *cbyte_io, int max,
95                               int *len_r, char **str_r) {
96   /* Neither len_r nor str_r may be null.
97    * End of datagram (overrun) is indicated by returning adns_s_invaliddata;
98    */
99   const byte *dgram= pai->dgram;
100   int l, cbyte;
101   char *str;
102
103   cbyte= *cbyte_io;
104
105   if (cbyte >= max) return adns_s_invaliddata;
106   GET_B(cbyte,l);
107   if (cbyte+l > max) return adns_s_invaliddata;
108   
109   str= adns__alloc_interim(pai->qu, l+1);
110   if (!str) R_NOMEM;
111   
112   str[l]= 0;
113   memcpy(str,dgram+cbyte,l);
114
115   *len_r= l;
116   *str_r= str;
117   *cbyte_io= cbyte+l;
118   
119   return adns_s_ok;
120 }
121
122 static adns_status csp_qstring(vbuf *vb, const char *dp, int len) {
123   unsigned char ch;
124   char buf[10];
125   int cn;
126
127   CSP_ADDSTR("\"");
128   for (cn=0; cn<len; cn++) {
129     ch= *dp++;
130     if (ch == '\\') {
131       CSP_ADDSTR("\\\\");
132     } else if (ch == '"') {
133       CSP_ADDSTR("\\\"");
134     } else if (ch >= 32 && ch <= 126) {
135       if (!adns__vbuf_append(vb,&ch,1)) R_NOMEM;
136     } else {
137       sprintf(buf,"\\x%02x",ch);
138       CSP_ADDSTR(buf);
139     }
140   }
141   CSP_ADDSTR("\"");
142   
143   return adns_s_ok;
144 }
145
146 /*
147  * _str  (mf)
148  */
149
150 static void mf_str(adns_query qu, void *datap) {
151   char **rrp= datap;
152
153   adns__makefinal_str(qu,rrp);
154 }
155
156 /*
157  * _intstr  (mf)
158  */
159
160 static void mf_intstr(adns_query qu, void *datap) {
161   adns_rr_intstr *rrp= datap;
162
163   adns__makefinal_str(qu,&rrp->str);
164 }
165
166 /*
167  * _manyistr   (mf)
168  */
169
170 static void mf_manyistr(adns_query qu, void *datap) {
171   adns_rr_intstr **rrp= datap;
172   adns_rr_intstr *te, *table;
173   void *tablev;
174   int tc;
175
176   for (tc=0, te= *rrp; te->i >= 0; te++, tc++);
177   tablev= *rrp;
178   adns__makefinal_block(qu,&tablev,sizeof(*te)*(tc+1));
179   *rrp= table= tablev;
180   for (te= *rrp; te->i >= 0; te++)
181     adns__makefinal_str(qu,&te->str);
182 }
183
184 /*
185  * _txt   (pa,cs)
186  */
187
188 static adns_status pa_txt(const parseinfo *pai, int cbyte,
189                           int max, void *datap) {
190   adns_rr_intstr **rrp= datap, *table, *te;
191   const byte *dgram= pai->dgram;
192   int ti, tc, l, startbyte;
193   adns_status st;
194
195   startbyte= cbyte;
196   if (cbyte >= max) return adns_s_invaliddata;
197   tc= 0;
198   while (cbyte < max) {
199     GET_B(cbyte,l);
200     cbyte+= l;
201     tc++;
202   }
203   if (cbyte != max || !tc) return adns_s_invaliddata;
204
205   table= adns__alloc_interim(pai->qu,sizeof(*table)*(tc+1));
206   if (!table) R_NOMEM;
207
208   for (cbyte=startbyte, ti=0, te=table; ti<tc; ti++, te++) {
209     st= pap_qstring(pai, &cbyte, max, &te->i, &te->str);
210     if (st) return st;
211   }
212   assert(cbyte == max);
213
214   te->i= -1;
215   te->str= 0;
216   
217   *rrp= table;
218   return adns_s_ok;
219 }
220
221 static adns_status cs_txt(vbuf *vb, const void *datap) {
222   const adns_rr_intstr *const *rrp= datap;
223   const adns_rr_intstr *current;
224   adns_status st;
225   int spc;
226
227   for (current= *rrp, spc=0;  current->i >= 0;  current++, spc=1) {
228     if (spc) CSP_ADDSTR(" ");
229     st= csp_qstring(vb,current->str,current->i); if (st) return st;
230   }
231   return adns_s_ok;
232 }
233
234 /*
235  * _hinfo   (cs)
236  */
237
238 static adns_status cs_hinfo(vbuf *vb, const void *datap) {
239   const adns_rr_intstrpair *rrp= datap;
240   adns_status st;
241
242   st= csp_qstring(vb,rrp->array[0].str,rrp->array[0].i);  if (st) return st;
243   CSP_ADDSTR(" ");
244   st= csp_qstring(vb,rrp->array[1].str,rrp->array[1].i);  if (st) return st;
245   return adns_s_ok;
246 }
247
248 /*
249  * _inaddr   (pa,di,cs +search_sortlist, dip_genaddr, csp_genaddr)
250  */
251
252 static adns_status pa_inaddr(const parseinfo *pai, int cbyte,
253                              int max, void *datap) {
254   struct in_addr *storeto= datap;
255   
256   if (max-cbyte != 4) return adns_s_invaliddata;
257   memcpy(storeto, pai->dgram + cbyte, 4);
258   return adns_s_ok;
259 }
260
261 static int search_sortlist(adns_state ads, int af, const void *ad) {
262   const struct sortlist *slp;
263   int i;
264   
265   for (i=0, slp=ads->sortlist;
266        i<ads->nsortlist &&
267          !adns__addr_match_p(af,ad, slp->af,&slp->base,&slp->mask);
268        i++, slp++);
269   return i;
270 }
271
272 static int dip_genaddr(adns_state ads, int af, const void *a, const void *b) {
273   int ai, bi;
274   
275   if (!ads->nsortlist) return 0;
276
277   ai= search_sortlist(ads,af,a);
278   bi= search_sortlist(ads,af,b);
279   return bi<ai;
280 }
281
282 static int di_inaddr(adns_state ads,
283                      const void *datap_a, const void *datap_b) {
284   return dip_genaddr(ads,AF_INET,datap_a,datap_b);
285 }
286
287 static adns_status csp_genaddr(vbuf *vb, int af, const void *p) {
288   char buf[ADNS_ADDR2TEXT_BUFLEN];
289   int len= sizeof(buf);
290   adns_rr_addr a;
291   int err;
292
293   memset(&a, 0, sizeof(a));
294   a.addr.sa.sa_family= af;
295   adns__sockaddr_inject(p, 0, &a.addr.sa);
296   err= adns_addr2text(&a.addr.sa,0, buf,&len, 0); assert(!err);
297   CSP_ADDSTR(buf);
298   return adns_s_ok;
299 }
300
301 static adns_status cs_inaddr(vbuf *vb, const void *datap) {
302   return csp_genaddr(vb, AF_INET,datap);
303 }
304
305 /*
306  * _in6addr   (pa,di,cs)
307  */
308
309 static adns_status pa_in6addr(const parseinfo *pai, int cbyte,
310                              int max, void *datap) {
311   struct in6_addr *storeto= datap;
312
313   if (max-cbyte != 16) return adns_s_invaliddata;
314   memcpy(storeto->s6_addr, pai->dgram + cbyte, 16);
315   return adns_s_ok;
316 }
317
318 static int di_in6addr(adns_state ads,
319                      const void *datap_a, const void *datap_b) {
320   return dip_genaddr(ads,AF_INET6,datap_a,datap_b);
321 }
322
323 static adns_status cs_in6addr(vbuf *vb, const void *datap) {
324   return csp_genaddr(vb,AF_INET6,datap);
325 }
326
327 /*
328  * _addr   (pa,di,div,csp,cs,gsz +search_sortlist_sa, dip_sockaddr)
329  */
330
331 static adns_status pa_addr(const parseinfo *pai, int cbyte,
332                            int max, void *datap) {
333   adns_rr_addr *storeto= datap;
334   const byte *dgram= pai->dgram;
335
336   if (max-cbyte != 4) return adns_s_invaliddata;
337   storeto->len= sizeof(storeto->addr.inet);
338   memset(&storeto->addr,0,sizeof(storeto->addr.inet));
339   storeto->addr.inet.sin_family= AF_INET;
340   memcpy(&storeto->addr.inet.sin_addr,dgram+cbyte,4);
341   return adns_s_ok;
342 }
343
344 static int search_sortlist_sa(adns_state ads, const struct sockaddr *sa) {
345   union gen_addr a;
346   adns__sockaddr_extract(sa, &a, 0);
347   return search_sortlist(ads, sa->sa_family, &a);
348 }
349
350 static int dip_sockaddr(adns_state ads,
351                         const struct sockaddr *sa,
352                         const struct sockaddr *sb) {
353   if (!ads->sortlist) return 0;
354   return search_sortlist_sa(ads, sa) > search_sortlist_sa(ads, sb);
355 }
356
357 static int di_addr(adns_state ads, const void *datap_a, const void *datap_b) {
358   const adns_rr_addr *ap= datap_a, *bp= datap_b;
359   return dip_sockaddr(ads, &ap->addr.sa, &bp->addr.sa);
360 }
361
362 static int div_addr(void *context, const void *datap_a, const void *datap_b) {
363   const adns_state ads= context;
364
365   return di_addr(ads, datap_a, datap_b);
366 }                    
367
368 static adns_status csp_addr(vbuf *vb, const adns_rr_addr *rrp) {
369   char buf[ADNS_ADDR2TEXT_BUFLEN];
370   int len= sizeof(buf);
371   int err;
372
373   switch (rrp->addr.inet.sin_family) {
374   case AF_INET:
375     CSP_ADDSTR("INET ");
376     goto a2t;
377   case AF_INET6:
378     CSP_ADDSTR("INET6 ");
379     goto a2t;
380   a2t:
381     err= adns_addr2text(&rrp->addr.sa,0, buf,&len, 0); assert(!err);
382     CSP_ADDSTR(buf);
383     break;
384   default:
385     sprintf(buf,"AF=%u",rrp->addr.sa.sa_family);
386     CSP_ADDSTR(buf);
387     break;
388   }
389   return adns_s_ok;
390 }
391
392 static adns_status cs_addr(vbuf *vb, const void *datap) {
393   const adns_rr_addr *rrp= datap;
394
395   return csp_addr(vb,rrp);
396 }
397
398 static int gsz_addr(const typeinfo *typei, adns_rrtype type) {
399   return type & adns__qtf_bigaddr ?
400     sizeof(adns_rr_addr) : sizeof(adns_rr_addr_v4only);
401 }
402
403 /*
404  * _domain      (pap,csp,cs)
405  * _dom_raw     (pa)
406  */
407
408 static adns_status pap_domain(const parseinfo *pai, int *cbyte_io, int max,
409                               char **domain_r, parsedomain_flags flags) {
410   adns_status st;
411   char *dm;
412   
413   st= adns__parse_domain(pai->qu->ads, pai->serv, pai->qu, &pai->qu->vb, flags,
414                          pai->dgram,pai->dglen, cbyte_io, max);
415   if (st) return st;
416   if (!pai->qu->vb.used) return adns_s_invaliddata;
417
418   dm= adns__alloc_interim(pai->qu, pai->qu->vb.used+1);
419   if (!dm) R_NOMEM;
420
421   dm[pai->qu->vb.used]= 0;
422   memcpy(dm,pai->qu->vb.buf,pai->qu->vb.used);
423   
424   *domain_r= dm;
425   return adns_s_ok;
426 }
427
428 static adns_status csp_domain(vbuf *vb, const char *domain) {
429   CSP_ADDSTR(domain);
430   if (!*domain) CSP_ADDSTR(".");
431   return adns_s_ok;
432 }
433
434 static adns_status cs_domain(vbuf *vb, const void *datap) {
435   const char *const *domainp= datap;
436   return csp_domain(vb,*domainp);
437 }
438
439 static adns_status pa_dom_raw(const parseinfo *pai, int cbyte,
440                               int max, void *datap) {
441   char **rrp= datap;
442   adns_status st;
443
444   st= pap_domain(pai, &cbyte, max, rrp, pdf_quoteok);
445   if (st) return st;
446   
447   if (cbyte != max) return adns_s_invaliddata;
448   return adns_s_ok;
449 }
450
451 /*
452  * _host_raw   (pa)
453  */
454
455 static adns_status pa_host_raw(const parseinfo *pai, int cbyte,
456                                int max, void *datap) {
457   char **rrp= datap;
458   adns_status st;
459
460   st= pap_domain(pai, &cbyte, max, rrp,
461                  pai->qu->flags & adns_qf_quoteok_anshost ? pdf_quoteok : 0);
462   if (st) return st;
463   
464   if (cbyte != max) return adns_s_invaliddata;
465   return adns_s_ok;
466 }
467
468 /*
469  * _hostaddr   (pap,pa,dip,di,mfp,mf,csp,cs +pap_findaddrs, icb_hostaddr)
470  */
471
472 static adns_status pap_findaddrs(const parseinfo *pai, adns_rr_hostaddr *ha,
473                                  size_t addrsz,
474                                  int *cbyte_io, int count, int dmstart) {
475   int rri, naddrs;
476   int type, class, rdlen, rdstart, ownermatched;
477   unsigned long ttl;
478   adns_status st;
479   
480   for (rri=0, naddrs=-1; rri<count; rri++) {
481     st= adns__findrr_anychk(pai->qu, pai->serv, pai->dgram,
482                             pai->dglen, cbyte_io,
483                             &type, &class, &ttl, &rdlen, &rdstart,
484                             pai->dgram, pai->dglen, dmstart, &ownermatched);
485     if (st) return st;
486     if (!ownermatched || class != DNS_CLASS_IN || type != adns_r_a) {
487       if (naddrs>0) break; else continue;
488     }
489     if (naddrs == -1) {
490       naddrs= 0;
491     }
492     if (!adns__vbuf_ensure(&pai->qu->vb, (naddrs+1)*addrsz))
493       R_NOMEM;
494     adns__update_expires(pai->qu,ttl,pai->now);
495     st= pa_addr(pai, rdstart,rdstart+rdlen, pai->qu->vb.buf + naddrs*addrsz);
496     if (st) return st;
497     naddrs++;
498   }
499   if (naddrs >= 0) {
500     ha->addrs= adns__alloc_interim(pai->qu, naddrs*addrsz);
501     if (!ha->addrs) R_NOMEM;
502     memcpy(ha->addrs, pai->qu->vb.buf, naddrs*addrsz);
503     ha->naddrs= naddrs;
504     ha->astatus= adns_s_ok;
505
506     adns__isort(ha->addrs, naddrs, addrsz, pai->qu->vb.buf,
507                 div_addr, pai->ads);
508   }
509   return adns_s_ok;
510 }
511
512 static void icb_hostaddr(adns_query parent, adns_query child) {
513   adns_answer *cans= child->answer;
514   adns_rr_hostaddr *rrp= child->ctx.pinfo.hostaddr;
515   adns_state ads= parent->ads;
516   adns_status st;
517
518   st= cans->status;
519   rrp->astatus= st;
520   rrp->naddrs= (st>0 && st<=adns_s_max_tempfail) ? -1 : cans->nrrs;
521   rrp->addrs= cans->rrs.addr;
522   adns__transfer_interim(child, parent, rrp->addrs);
523
524   if (parent->children.head) {
525     LIST_LINK_TAIL(ads->childw,parent);
526   } else {
527     adns__query_done(parent);
528   }
529 }
530
531 static adns_status pap_hostaddr(const parseinfo *pai, int *cbyte_io,
532                                 int max, adns_rr_hostaddr *rrp) {
533   adns_status st;
534   int dmstart, cbyte;
535   qcontext ctx;
536   int id;
537   adns_query nqu;
538   adns_queryflags nflags;
539   size_t addrsz= gsz_addr(0, pai->qu->answer->type);
540
541   dmstart= cbyte= *cbyte_io;
542   st= pap_domain(pai, &cbyte, max, &rrp->host,
543                  pai->qu->flags & adns_qf_quoteok_anshost ? pdf_quoteok : 0);
544   if (st) return st;
545   *cbyte_io= cbyte;
546
547   rrp->astatus= adns_s_ok;
548   rrp->naddrs= -1;
549   rrp->addrs= 0;
550
551   cbyte= pai->nsstart;
552
553   st= pap_findaddrs(pai, rrp,addrsz, &cbyte, pai->nscount, dmstart);
554   if (st) return st;
555   if (rrp->naddrs != -1) return adns_s_ok;
556
557   st= pap_findaddrs(pai, rrp,addrsz, &cbyte, pai->arcount, dmstart);
558   if (st) return st;
559   if (rrp->naddrs != -1) return adns_s_ok;
560
561   st= adns__mkquery_frdgram(pai->ads, &pai->qu->vb, &id,
562                             pai->dgram, pai->dglen, dmstart,
563                             adns_r_addr, adns_qf_quoteok_query);
564   if (st) return st;
565
566   ctx.ext= 0;
567   ctx.callback= icb_hostaddr;
568   ctx.pinfo.hostaddr= rrp;
569   memset(&ctx.tinfo, 0, sizeof(ctx.tinfo));
570   
571   nflags= adns_qf_quoteok_query;
572   if (!(pai->qu->flags & adns_qf_cname_loose)) nflags |= adns_qf_cname_forbid;
573   
574   st= adns__internal_submit(pai->ads, &nqu, adns__findtype(adns_r_addr),
575                             ((adns_r_addr & adns_rrt_reprmask) |
576                              (pai->qu->answer->type & ~adns_rrt_reprmask)),
577                             &pai->qu->vb, id, nflags, pai->now, &ctx);
578   if (st) return st;
579
580   nqu->parent= pai->qu;
581   LIST_LINK_TAIL_PART(pai->qu->children,nqu,siblings.);
582
583   return adns_s_ok;
584 }
585
586 static adns_status pa_hostaddr(const parseinfo *pai, int cbyte,
587                                int max, void *datap) {
588   adns_rr_hostaddr *rrp= datap;
589   adns_status st;
590
591   st= pap_hostaddr(pai, &cbyte, max, rrp);
592   if (st) return st;
593   if (cbyte != max) return adns_s_invaliddata;
594
595   return adns_s_ok;
596 }
597
598 static int dip_hostaddr(adns_state ads,
599                         const adns_rr_hostaddr *ap, const adns_rr_hostaddr *bp) {
600   if (ap->astatus != bp->astatus) return ap->astatus;
601   if (ap->astatus) return 0;
602
603   return dip_sockaddr(ads, &ap->addrs[0].addr.sa, &bp->addrs[0].addr.sa);
604 }
605
606 static int di_hostaddr(adns_state ads,
607                        const void *datap_a, const void *datap_b) {
608   const adns_rr_hostaddr *ap= datap_a, *bp= datap_b;
609
610   return dip_hostaddr(ads, ap,bp);
611 }
612
613 static void mfp_hostaddr(adns_query qu, adns_rr_hostaddr *rrp) {
614   void *tablev;
615   size_t addrsz= gsz_addr(0, qu->answer->type);
616
617   adns__makefinal_str(qu,&rrp->host);
618   tablev= rrp->addrs;
619   adns__makefinal_block(qu, &tablev, rrp->naddrs*addrsz);
620   rrp->addrs= tablev;
621 }
622
623 static void mf_hostaddr(adns_query qu, void *datap) {
624   adns_rr_hostaddr *rrp= datap;
625
626   mfp_hostaddr(qu,rrp);
627 }
628
629 static adns_status csp_hostaddr(vbuf *vb, const adns_rr_hostaddr *rrp) {
630   const char *errstr;
631   adns_status st;
632   char buf[20];
633   int i;
634
635   st= csp_domain(vb,rrp->host);  if (st) return st;
636
637   CSP_ADDSTR(" ");
638   CSP_ADDSTR(adns_errtypeabbrev(rrp->astatus));
639
640   sprintf(buf," %d ",rrp->astatus);
641   CSP_ADDSTR(buf);
642
643   CSP_ADDSTR(adns_errabbrev(rrp->astatus));
644   CSP_ADDSTR(" ");
645
646   errstr= adns_strerror(rrp->astatus);
647   st= csp_qstring(vb,errstr,strlen(errstr));  if (st) return st;
648   
649   if (rrp->naddrs >= 0) {
650     CSP_ADDSTR(" (");
651     for (i=0; i<rrp->naddrs; i++) {
652       CSP_ADDSTR(" ");
653       st= csp_addr(vb,&rrp->addrs[i]);
654     }
655     CSP_ADDSTR(" )");
656   } else {
657     CSP_ADDSTR(" ?");
658   }
659   return adns_s_ok;
660 }
661
662 static adns_status cs_hostaddr(vbuf *vb, const void *datap) {
663   const adns_rr_hostaddr *rrp= datap;
664
665   return csp_hostaddr(vb,rrp);
666 }
667
668 /*
669  * _mx_raw   (pa,di)
670  */
671
672 static adns_status pa_mx_raw(const parseinfo *pai, int cbyte,
673                              int max, void *datap) {
674   const byte *dgram= pai->dgram;
675   adns_rr_intstr *rrp= datap;
676   adns_status st;
677   int pref;
678
679   if (cbyte+2 > max) return adns_s_invaliddata;
680   GET_W(cbyte,pref);
681   rrp->i= pref;
682   st= pap_domain(pai, &cbyte, max, &rrp->str,
683                  pai->qu->flags & adns_qf_quoteok_anshost ? pdf_quoteok : 0);
684   if (st) return st;
685   
686   if (cbyte != max) return adns_s_invaliddata;
687   return adns_s_ok;
688 }
689
690 static int di_mx_raw(adns_state ads, const void *datap_a, const void *datap_b) {
691   const adns_rr_intstr *ap= datap_a, *bp= datap_b;
692
693   if (ap->i < bp->i) return 0;
694   if (ap->i > bp->i) return 1;
695   return 0;
696 }
697
698 /*
699  * _mx   (pa,di)
700  */
701
702 static adns_status pa_mx(const parseinfo *pai, int cbyte,
703                          int max, void *datap) {
704   const byte *dgram= pai->dgram;
705   adns_rr_inthostaddr *rrp= datap;
706   adns_status st;
707   int pref;
708
709   if (cbyte+2 > max) return adns_s_invaliddata;
710   GET_W(cbyte,pref);
711   rrp->i= pref;
712   st= pap_hostaddr(pai, &cbyte, max, &rrp->ha);
713   if (st) return st;
714   
715   if (cbyte != max) return adns_s_invaliddata;
716   return adns_s_ok;
717 }
718
719 static int di_mx(adns_state ads, const void *datap_a, const void *datap_b) {
720   const adns_rr_inthostaddr *ap= datap_a, *bp= datap_b;
721
722   if (ap->i < bp->i) return 0;
723   if (ap->i > bp->i) return 1;
724   return dip_hostaddr(ads, &ap->ha, &bp->ha);
725 }
726
727 /*
728  * _inthostaddr  (mf,cs)
729  */
730
731 static void mf_inthostaddr(adns_query qu, void *datap) {
732   adns_rr_inthostaddr *rrp= datap;
733
734   mfp_hostaddr(qu,&rrp->ha);
735 }
736
737 static adns_status cs_inthostaddr(vbuf *vb, const void *datap) {
738   const adns_rr_inthostaddr *rrp= datap;
739   char buf[10];
740
741   sprintf(buf,"%u ",rrp->i);
742   CSP_ADDSTR(buf);
743
744   return csp_hostaddr(vb,&rrp->ha);
745 }
746
747 /*
748  * _inthost  (cs)
749  */
750
751 static adns_status cs_inthost(vbuf *vb, const void *datap) {
752   const adns_rr_intstr *rrp= datap;
753   char buf[10];
754
755   sprintf(buf,"%u ",rrp->i);
756   CSP_ADDSTR(buf);
757   return csp_domain(vb,rrp->str);
758 }
759
760 /*
761  * _ptr   (ckl,pa +icb_ptr)
762  */
763
764 static adns_status ckl_ptr(adns_state ads, adns_queryflags flags,
765                            union checklabel_state *cls, qcontext *ctx,
766                            int labnum, const char *label, int lablen) {
767   if (lablen) {
768     if (adns__revparse_label(&cls->ptr, labnum, label,lablen))
769       return adns_s_querydomainwrong;
770   } else {
771     if (adns__revparse_done(&cls->ptr, labnum,
772                             &ctx->tinfo.ptr.rev_rrtype,
773                             &ctx->tinfo.ptr.addr))
774       return adns_s_querydomainwrong;
775   }
776   return adns_s_ok;
777 }
778
779 static void icb_ptr(adns_query parent, adns_query child) {
780   adns_answer *cans= child->answer;
781   const struct af_addr *queried;
782   const unsigned char *found;
783   adns_state ads= parent->ads;
784   int i;
785
786   if (cans->status == adns_s_nxdomain || cans->status == adns_s_nodata) {
787     adns__query_fail(parent,adns_s_inconsistent);
788     return;
789   } else if (cans->status) {
790     adns__query_fail(parent,cans->status);
791     return;
792   }
793
794   queried= &parent->ctx.tinfo.ptr.addr;
795   for (i=0, found=cans->rrs.bytes; i<cans->nrrs; i++, found+=cans->rrsz) {
796     if (adns__genaddr_equal_p(queried->af,&queried->addr,
797                               parent->ctx.tinfo.ptr.addr.af,found)) {
798       if (!parent->children.head) {
799         adns__query_done(parent);
800         return;
801       } else {
802         LIST_LINK_TAIL(ads->childw,parent);
803         return;
804       }
805     }
806   }
807
808   adns__query_fail(parent,adns_s_inconsistent);
809 }
810
811 static adns_status pa_ptr(const parseinfo *pai, int dmstart,
812                           int max, void *datap) {
813   char **rrp= datap;
814   adns_status st;
815   adns_rrtype rrtype= pai->qu->ctx.tinfo.ptr.rev_rrtype;
816   int cbyte, id;
817   adns_query nqu;
818   qcontext ctx;
819
820   cbyte= dmstart;
821   st= pap_domain(pai, &cbyte, max, rrp,
822                  pai->qu->flags & adns_qf_quoteok_anshost ? pdf_quoteok : 0);
823   if (st) return st;
824   if (cbyte != max) return adns_s_invaliddata;
825
826   st= adns__mkquery_frdgram(pai->ads, &pai->qu->vb, &id,
827                             pai->dgram, pai->dglen, dmstart,
828                             rrtype, adns_qf_quoteok_query);
829   if (st) return st;
830
831   ctx.ext= 0;
832   ctx.callback= icb_ptr;
833   memset(&ctx.pinfo,0,sizeof(ctx.pinfo));
834   memset(&ctx.tinfo,0,sizeof(ctx.tinfo));
835   st= adns__internal_submit(pai->ads, &nqu, adns__findtype(rrtype),
836                             rrtype, &pai->qu->vb, id,
837                             adns_qf_quoteok_query, pai->now, &ctx);
838   if (st) return st;
839
840   nqu->parent= pai->qu;
841   LIST_LINK_TAIL_PART(pai->qu->children,nqu,siblings.);
842   return adns_s_ok;
843 }
844
845 /*
846  * _strpair   (mf)
847  */
848
849 static void mf_strpair(adns_query qu, void *datap) {
850   adns_rr_strpair *rrp= datap;
851
852   adns__makefinal_str(qu,&rrp->array[0]);
853   adns__makefinal_str(qu,&rrp->array[1]);
854 }
855
856 /*
857  * _intstrpair   (mf)
858  */
859
860 static void mf_intstrpair(adns_query qu, void *datap) {
861   adns_rr_intstrpair *rrp= datap;
862
863   adns__makefinal_str(qu,&rrp->array[0].str);
864   adns__makefinal_str(qu,&rrp->array[1].str);
865 }
866
867 /*
868  * _hinfo   (pa)
869  */
870
871 static adns_status pa_hinfo(const parseinfo *pai, int cbyte,
872                             int max, void *datap) {
873   adns_rr_intstrpair *rrp= datap;
874   adns_status st;
875   int i;
876
877   for (i=0; i<2; i++) {
878     st= pap_qstring(pai, &cbyte, max, &rrp->array[i].i, &rrp->array[i].str);
879     if (st) return st;
880   }
881
882   if (cbyte != max) return adns_s_invaliddata;
883   
884   return adns_s_ok;
885 }
886
887 /*
888  * _mailbox   (pap,cs +pap_mailbox822)
889  */
890
891 static adns_status pap_mailbox822(const parseinfo *pai,
892                                   int *cbyte_io, int max, char **mb_r) {
893   int lablen, labstart, i, needquote, c, r, neednorm;
894   const unsigned char *p;
895   char *str;
896   findlabel_state fls;
897   adns_status st;
898   vbuf *vb;
899
900   vb= &pai->qu->vb;
901   vb->used= 0;
902   adns__findlabel_start(&fls, pai->ads,
903                         -1, pai->qu,
904                         pai->dgram, pai->dglen, max,
905                         *cbyte_io, cbyte_io);
906   st= adns__findlabel_next(&fls,&lablen,&labstart);
907   if (!lablen) {
908     adns__vbuf_appendstr(vb,".");
909     goto x_ok;
910   }
911
912   neednorm= 1;
913   for (i=0, needquote=0, p= pai->dgram+labstart; i<lablen; i++) {
914     c= *p++;
915     if ((c&~128) < 32 || (c&~128) == 127) return adns_s_invaliddata;
916     if (c == '.' && !neednorm) neednorm= 1;
917     else if (c==' ' || c>=127 || ctype_822special(c)) needquote++;
918     else neednorm= 0;
919   }
920
921   if (needquote || neednorm) {
922     r= adns__vbuf_ensure(vb, lablen+needquote+4); if (!r) R_NOMEM;
923     adns__vbuf_appendq(vb,"\"",1);
924     for (i=0, needquote=0, p= pai->dgram+labstart; i<lablen; i++, p++) {
925       c= *p;
926       if (c == '"' || c=='\\') adns__vbuf_appendq(vb,"\\",1);
927       adns__vbuf_appendq(vb,p,1);
928     }
929     adns__vbuf_appendq(vb,"\"",1);
930   } else {
931     r= adns__vbuf_append(vb, pai->dgram+labstart, lablen); if (!r) R_NOMEM;
932   }
933
934   r= adns__vbuf_appendstr(vb,"@"); if (!r) R_NOMEM;
935
936   st= adns__parse_domain_more(&fls,pai->ads, pai->qu,vb,0, pai->dgram);
937   if (st) return st;
938
939  x_ok:
940   str= adns__alloc_interim(pai->qu, vb->used+1); if (!str) R_NOMEM;
941   memcpy(str,vb->buf,vb->used);
942   str[vb->used]= 0;
943   *mb_r= str;
944   return adns_s_ok;
945 }
946
947 static adns_status pap_mailbox(const parseinfo *pai, int *cbyte_io, int max,
948                                char **mb_r) {
949   if (pai->qu->typei->typekey & adns__qtf_mail822) {
950     return pap_mailbox822(pai, cbyte_io, max, mb_r);
951   } else {
952     return pap_domain(pai, cbyte_io, max, mb_r, pdf_quoteok);
953   }
954 }
955
956 static adns_status csp_mailbox(vbuf *vb, const char *mailbox) {
957   return csp_domain(vb,mailbox);
958 }
959
960 /*
961  * _rp   (pa,cs)
962  */
963
964 static adns_status pa_rp(const parseinfo *pai, int cbyte,
965                          int max, void *datap) {
966   adns_rr_strpair *rrp= datap;
967   adns_status st;
968
969   st= pap_mailbox(pai, &cbyte, max, &rrp->array[0]);
970   if (st) return st;
971
972   st= pap_domain(pai, &cbyte, max, &rrp->array[1], pdf_quoteok);
973   if (st) return st;
974
975   if (cbyte != max) return adns_s_invaliddata;
976   return adns_s_ok;
977 }
978
979 static adns_status cs_rp(vbuf *vb, const void *datap) {
980   const adns_rr_strpair *rrp= datap;
981   adns_status st;
982
983   st= csp_mailbox(vb,rrp->array[0]);  if (st) return st;
984   CSP_ADDSTR(" ");
985   st= csp_domain(vb,rrp->array[1]);  if (st) return st;
986
987   return adns_s_ok;
988 }  
989
990 /*
991  * _soa   (pa,mf,cs)
992  */
993
994 static adns_status pa_soa(const parseinfo *pai, int cbyte,
995                           int max, void *datap) {
996   adns_rr_soa *rrp= datap;
997   const byte *dgram= pai->dgram;
998   adns_status st;
999   int msw, lsw, i;
1000
1001   st= pap_domain(pai, &cbyte, max, &rrp->mname,
1002                  pai->qu->flags & adns_qf_quoteok_anshost ? pdf_quoteok : 0);
1003   if (st) return st;
1004
1005   st= pap_mailbox(pai, &cbyte, max, &rrp->rname);
1006   if (st) return st;
1007
1008   if (cbyte+20 != max) return adns_s_invaliddata;
1009   
1010   for (i=0; i<5; i++) {
1011     GET_W(cbyte,msw);
1012     GET_W(cbyte,lsw);
1013     (&rrp->serial)[i]= (msw<<16) | lsw;
1014   }
1015
1016   return adns_s_ok;
1017 }
1018
1019 static void mf_soa(adns_query qu, void *datap) {
1020   adns_rr_soa *rrp= datap;
1021
1022   adns__makefinal_str(qu,&rrp->mname);
1023   adns__makefinal_str(qu,&rrp->rname);
1024 }
1025
1026 static adns_status cs_soa(vbuf *vb, const void *datap) {
1027   const adns_rr_soa *rrp= datap;
1028   char buf[20];
1029   int i;
1030   adns_status st;
1031   
1032   st= csp_domain(vb,rrp->mname);  if (st) return st;
1033   CSP_ADDSTR(" ");
1034   st= csp_mailbox(vb,rrp->rname);  if (st) return st;
1035
1036   for (i=0; i<5; i++) {
1037     sprintf(buf," %lu",(&rrp->serial)[i]);
1038     CSP_ADDSTR(buf);
1039   }
1040
1041   return adns_s_ok;
1042 }
1043
1044 /*
1045  * _srv*  (ckl,(pap),pa*2,mf*2,di,(csp),cs*2,postsort)
1046  */
1047
1048 static adns_status ckl_srv(adns_state ads, adns_queryflags flags,
1049                            union checklabel_state *cls, qcontext *ctx,
1050                            int labnum, const char *label, int lablen) {
1051   if (labnum < 2 && !(flags & adns_qf_quoteok_query)) {
1052     if (!lablen || label[0] != '_') return adns_s_querydomaininvalid;
1053     return adns_s_ok;
1054   }
1055   return adns__ckl_hostname(ads, flags, cls, ctx, labnum, label, lablen);
1056 }
1057
1058 static adns_status pap_srv_begin(const parseinfo *pai, int *cbyte_io, int max,
1059                                  adns_rr_srvha *rrp
1060                                    /* might be adns_rr_srvraw* */) {
1061   const byte *dgram= pai->dgram;
1062   int ti, cbyte;
1063
1064   cbyte= *cbyte_io;
1065   if ((*cbyte_io += 6) > max) return adns_s_invaliddata;
1066   
1067   rrp->priority= GET_W(cbyte, ti);
1068   rrp->weight=   GET_W(cbyte, ti);
1069   rrp->port=     GET_W(cbyte, ti);
1070   return adns_s_ok;
1071 }
1072
1073 static adns_status pa_srvraw(const parseinfo *pai, int cbyte,
1074                              int max, void *datap) {
1075   adns_rr_srvraw *rrp= datap;
1076   adns_status st;
1077
1078   st= pap_srv_begin(pai,&cbyte,max,datap);
1079   if (st) return st;
1080   
1081   st= pap_domain(pai, &cbyte, max, &rrp->host,
1082                  pai->qu->flags & adns_qf_quoteok_anshost ? pdf_quoteok : 0);
1083   if (st) return st;
1084   
1085   if (cbyte != max) return adns_s_invaliddata;
1086   return adns_s_ok;
1087 }
1088
1089 static adns_status pa_srvha(const parseinfo *pai, int cbyte,
1090                             int max, void *datap) {
1091   adns_rr_srvha *rrp= datap;
1092   adns_status st;
1093
1094   st= pap_srv_begin(pai,&cbyte,max,datap);       if (st) return st;
1095   st= pap_hostaddr(pai, &cbyte, max, &rrp->ha);  if (st) return st;
1096   if (cbyte != max) return adns_s_invaliddata;
1097   return adns_s_ok;
1098 }
1099
1100 static void mf_srvraw(adns_query qu, void *datap) {
1101   adns_rr_srvraw *rrp= datap;
1102   adns__makefinal_str(qu, &rrp->host);
1103 }
1104
1105 static void mf_srvha(adns_query qu, void *datap) {
1106   adns_rr_srvha *rrp= datap;
1107   mfp_hostaddr(qu,&rrp->ha);
1108 }
1109
1110 static int di_srv(adns_state ads, const void *datap_a, const void *datap_b) {
1111   const adns_rr_srvraw *ap= datap_a, *bp= datap_b;
1112     /* might be const adns_rr_svhostaddr* */
1113
1114   if (ap->priority < bp->priority) return 0;
1115   if (ap->priority > bp->priority) return 1;
1116   return 0;
1117 }
1118
1119 static adns_status csp_srv_begin(vbuf *vb, const adns_rr_srvha *rrp
1120                                    /* might be adns_rr_srvraw* */) {
1121   char buf[30];
1122   sprintf(buf,"%u %u %u ", rrp->priority, rrp->weight, rrp->port);
1123   CSP_ADDSTR(buf);
1124   return adns_s_ok;
1125 }
1126
1127 static adns_status cs_srvraw(vbuf *vb, const void *datap) {
1128   const adns_rr_srvraw *rrp= datap;
1129   adns_status st;
1130   
1131   st= csp_srv_begin(vb,(const void*)rrp);  if (st) return st;
1132   return csp_domain(vb,rrp->host);
1133 }
1134
1135 static adns_status cs_srvha(vbuf *vb, const void *datap) {
1136   const adns_rr_srvha *rrp= datap;
1137   adns_status st;
1138
1139   st= csp_srv_begin(vb,(const void*)datap);  if (st) return st;
1140   return csp_hostaddr(vb,&rrp->ha);
1141 }
1142
1143 static void postsort_srv(adns_state ads, void *array, int nrrs,int rrsz,
1144                          const struct typeinfo *typei) {
1145   /* we treat everything in the array as if it were an adns_rr_srvha
1146    * even though the array might be of adns_rr_srvraw.  That's OK
1147    * because they have the same prefix, which is all we access.
1148    * We use rrsz, too, rather than naive array indexing, of course.
1149    */
1150   char *workbegin, *workend, *search, *arrayend;
1151   const adns_rr_srvha *rr;
1152   union { adns_rr_srvha ha; adns_rr_srvraw raw; } rrtmp;
1153   int cpriority, totalweight, runtotal;
1154   long randval;
1155
1156   assert(rrsz <= sizeof(rrtmp));
1157   for (workbegin= array, arrayend= workbegin + rrsz * nrrs;
1158        workbegin < arrayend;
1159        workbegin= workend) {
1160     cpriority= (rr=(void*)workbegin)->priority;
1161     
1162     for (workend= workbegin, totalweight= 0;
1163          workend < arrayend && (rr=(void*)workend)->priority == cpriority;
1164          workend += rrsz) {
1165       totalweight += rr->weight;
1166     }
1167
1168     /* Now workbegin..(workend-1) incl. are exactly all of the RRs of
1169      * cpriority.  From now on, workbegin points to the `remaining'
1170      * records: we select one record at a time (RFC2782 `Usage rules'
1171      * and `Format of the SRV RR' subsection `Weight') to place at
1172      * workbegin (swapping with the one that was there, and then
1173      * advance workbegin. */
1174     for (;
1175          workbegin + rrsz < workend; /* don't bother if just one */
1176          workbegin += rrsz) {
1177       
1178       randval= nrand48(ads->rand48xsubi);
1179       randval %= (totalweight + 1);
1180         /* makes it into 0..totalweight inclusive; with 2^10 RRs,
1181          * totalweight must be <= 2^26 so probability nonuniformity is
1182          * no worse than 1 in 2^(31-26) ie 1 in 2^5, ie
1183          *  abs(log(P_intended(RR_i) / P_actual(RR_i)) <= log(2^-5).
1184          */
1185
1186       for (search=workbegin, runtotal=0;
1187            (runtotal += (rr=(void*)search)->weight) < randval;
1188            search += rrsz);
1189       assert(search < arrayend);
1190       totalweight -= rr->weight;
1191       if (search != workbegin) {
1192         memcpy(&rrtmp, workbegin, rrsz);
1193         memcpy(workbegin, search, rrsz);
1194         memcpy(search, &rrtmp, rrsz);
1195       }
1196     }
1197   }
1198   /* tests:
1199    *  dig -t srv _srv._tcp.test.iwj.relativity.greenend.org.uk.
1200    *   ./adnshost_s -t srv- _sip._udp.voip.net.cam.ac.uk.
1201    *   ./adnshost_s -t srv- _jabber._tcp.jabber.org
1202    */
1203 }
1204
1205 /*
1206  * _byteblock   (mf)
1207  */
1208
1209 static void mf_byteblock(adns_query qu, void *datap) {
1210   adns_rr_byteblock *rrp= datap;
1211   void *bytes= rrp->data;
1212   adns__makefinal_block(qu,&bytes,rrp->len);
1213   rrp->data= bytes;
1214 }
1215
1216 /*
1217  * _opaque   (pa,cs)
1218  */
1219
1220 static adns_status pa_opaque(const parseinfo *pai, int cbyte,
1221                              int max, void *datap) {
1222   adns_rr_byteblock *rrp= datap;
1223
1224   rrp->len= max - cbyte;
1225   rrp->data= adns__alloc_interim(pai->qu, rrp->len);
1226   if (!rrp->data) R_NOMEM;
1227   memcpy(rrp->data, pai->dgram + cbyte, rrp->len);
1228   return adns_s_ok;
1229 }
1230
1231 static adns_status cs_opaque(vbuf *vb, const void *datap) {
1232   const adns_rr_byteblock *rrp= datap;
1233   char buf[10];
1234   int l;
1235   unsigned char *p;
1236
1237   sprintf(buf,"\\# %d",rrp->len);
1238   CSP_ADDSTR(buf);
1239   
1240   for (l= rrp->len, p= rrp->data;
1241        l>=4;
1242        l -= 4, p += 4) {
1243     sprintf(buf," %02x%02x%02x%02x",p[0],p[1],p[2],p[3]);
1244     CSP_ADDSTR(buf);
1245   }
1246   for (;
1247        l>0;
1248        l--, p++) {
1249     sprintf(buf," %02x",*p);
1250     CSP_ADDSTR(buf);
1251   }
1252   return adns_s_ok;
1253 }
1254   
1255 /*
1256  * _flat   (mf)
1257  */
1258
1259 static void mf_flat(adns_query qu, void *data) { }
1260
1261 /*
1262  * Now the table.
1263  */
1264
1265 #define TYPESZ_M(member)           (sizeof(*((adns_answer*)0)->rrs.member))
1266
1267 #define DEEP_TYPE(code,rrt,fmt,memb,parser,comparer,/*printer*/...)     \
1268  { adns_r_##code&adns_rrt_reprmask, rrt,fmt,TYPESZ_M(memb), mf_##memb,  \
1269      GLUE(cs_, CAR(__VA_ARGS__)),pa_##parser,di_##comparer,             \
1270      adns__ckl_hostname, 0, adns__getrrsz_default, CDR(__VA_ARGS__) }
1271 #define FLAT_TYPE(code,rrt,fmt,memb,parser,comparer,/*printer*/...)     \
1272  { adns_r_##code&adns_rrt_reprmask, rrt,fmt,TYPESZ_M(memb), mf_flat,    \
1273      GLUE(cs_, CAR(__VA_ARGS__)),pa_##parser,di_##comparer,             \
1274      adns__ckl_hostname, 0, adns__getrrsz_default, CDR(__VA_ARGS__) }
1275
1276 #define di_0 0
1277
1278 static const typeinfo typeinfos[] = {
1279 /* Must be in ascending order of rrtype ! */
1280 /* mem-mgmt code  rrt     fmt   member   parser      comparer  printer */
1281
1282 FLAT_TYPE(a,      "A",     0,   inaddr,    inaddr,  inaddr,inaddr          ),
1283 DEEP_TYPE(ns_raw, "NS",   "raw",str,       host_raw,0,     domain          ),
1284 DEEP_TYPE(cname,  "CNAME", 0,   str,       dom_raw, 0,     domain          ),
1285 DEEP_TYPE(soa_raw,"SOA",  "raw",soa,       soa,     0,     soa             ),
1286 DEEP_TYPE(ptr_raw,"PTR",  "raw",str,       host_raw,0,     domain          ),
1287 DEEP_TYPE(hinfo,  "HINFO", 0,   intstrpair,hinfo,   0,     hinfo           ),
1288 DEEP_TYPE(mx_raw, "MX",   "raw",intstr,    mx_raw,  mx_raw,inthost         ),
1289 DEEP_TYPE(txt,    "TXT",   0,   manyistr,  txt,     0,     txt             ),
1290 DEEP_TYPE(rp_raw, "RP",   "raw",strpair,   rp,      0,     rp              ),
1291 FLAT_TYPE(aaaa,   "AAAA",  0,   in6addr,   in6addr, in6addr,in6addr        ),
1292 DEEP_TYPE(srv_raw,"SRV",  "raw",srvraw ,   srvraw,  srv,   srvraw,
1293                               .checklabel= ckl_srv, .postsort= postsort_srv),
1294
1295 FLAT_TYPE(addr,   "A",  "addr", addr,      addr,    addr,  addr,
1296                                                          .getrrsz= gsz_addr),
1297 DEEP_TYPE(ns,     "NS", "+addr",hostaddr,  hostaddr,hostaddr,hostaddr      ),
1298 DEEP_TYPE(ptr,    "PTR","checked",str,     ptr,     0,     domain,
1299                                                        .checklabel= ckl_ptr),
1300 DEEP_TYPE(mx,     "MX", "+addr",inthostaddr,mx,     mx,    inthostaddr,    ),
1301 DEEP_TYPE(srv,    "SRV","+addr",srvha,     srvha,   srv,   srvha,
1302                               .checklabel= ckl_srv, .postsort= postsort_srv),
1303
1304 DEEP_TYPE(soa,    "SOA","822",  soa,       soa,     0,     soa             ),
1305 DEEP_TYPE(rp,     "RP", "822",  strpair,   rp,      0,     rp              ),
1306 };
1307
1308 static const typeinfo typeinfo_unknown=
1309 DEEP_TYPE(unknown,0, "unknown",byteblock,opaque,  0,     opaque            );
1310
1311 const typeinfo *adns__findtype(adns_rrtype type) {
1312   const typeinfo *begin, *end, *mid;
1313
1314   if (type & adns_r_unknown) return &typeinfo_unknown;
1315   type &= adns_rrt_reprmask;
1316
1317   begin= typeinfos;  end= typeinfos+(sizeof(typeinfos)/sizeof(typeinfo));
1318
1319   while (begin < end) {
1320     mid= begin + ((end-begin)>>1);
1321     if (mid->typekey == type) return mid;
1322     if (type > mid->typekey) begin= mid+1;
1323     else end= mid;
1324   }
1325   return 0;
1326 }