X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Fquery.c;h=c32acbacf2cec16303c9528d7035bbfbed451478;hb=60b40c591fd6136f91f7119383c34524279b7f1b;hp=541d8ac35d11fc40d69e6195bf41079b2962f5db;hpb=c37d270aba4917429f1377e1148613b48d06aaaa;p=adns.git diff --git a/src/query.c b/src/query.c index 541d8ac..c32acba 100644 --- a/src/query.c +++ b/src/query.c @@ -83,7 +83,7 @@ static adns_query query_alloc(adns_state ads, qu->answer->expires= -1; qu->answer->nrrs= 0; qu->answer->rrs.untyped= 0; - qu->answer->rrsz= typei->rrsz; + qu->answer->rrsz= typei->getrrsz(typei,type); return qu; } @@ -331,28 +331,15 @@ int adns_submit_reverse_any(adns_state ads, adns_queryflags flags, void *context, adns_query *query_r) { - const unsigned char *iaddr; - char *buf, *buf_free; + char *buf, *buf_free = 0; char shortbuf[100]; - int r, lreq; + int r; flags &= ~adns_qf_search; - if (addr->sa_family != AF_INET) return ENOSYS; - iaddr= (const unsigned char*) - &(((const struct sockaddr_in*)addr) -> sin_addr); - - lreq= strlen(zone) + 4*4 + 1; - if (lreq > sizeof(shortbuf)) { - buf= malloc(strlen(zone) + 4*4 + 1); - if (!buf) return errno; - buf_free= buf; - } else { - buf= shortbuf; - buf_free= 0; - } - sprintf(buf, "%d.%d.%d.%d.%s", iaddr[3], iaddr[2], iaddr[1], iaddr[0], zone); - + buf = shortbuf; + r= adns__make_reverse_domain(addr,zone, &buf,sizeof(shortbuf),&buf_free); + if (r) return r; r= adns_submit(ads,buf,type,flags,context,query_r); free(buf_free); return r; @@ -367,8 +354,7 @@ int adns_submit_reverse(adns_state ads, if (((type^adns_r_ptr) & adns_rrt_reprmask) && ((type^adns_r_ptr_raw) & adns_rrt_reprmask)) return EINVAL; - return adns_submit_reverse_any(ads,addr,"in-addr.arpa", - type,flags,context,query_r); + return adns_submit_reverse_any(ads,addr,0,type,flags,context,query_r); } int adns_synchronous(adns_state ads, @@ -580,7 +566,7 @@ void adns__query_done(adns_query qu) { } if (ans->nrrs && qu->typei->diff_needswap) { - if (!adns__vbuf_ensure(&qu->vb,qu->typei->rrsz)) { + if (!adns__vbuf_ensure(&qu->vb,qu->answer->rrsz)) { adns__query_fail(qu,adns_s_nomemory); return; } @@ -591,7 +577,8 @@ void adns__query_done(adns_query qu) { qu->ads); } if (ans->nrrs && qu->typei->postsort) { - qu->typei->postsort(qu->ads, ans->rrs.bytes, ans->nrrs, qu->typei); + qu->typei->postsort(qu->ads, ans->rrs.bytes, + ans->nrrs,ans->rrsz, qu->typei); } ans->expires= qu->expires;