X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~mdw/git/adns/blobdiff_plain/1be24aefb650dc38c9121dc7a3e1de2fceb900fa..2d77da38fe14f5a9ae8d3fc9ee455c5acdf2be1a:/src/query.c diff --git a/src/query.c b/src/query.c index b02abda..a35d8ba 100644 --- a/src/query.c +++ b/src/query.c @@ -42,7 +42,7 @@ static adns_query query_alloc(adns_state ads, const typeinfo *typei, qu->answer= malloc(sizeof(*qu->answer)); if (!qu->answer) { free(qu); return 0; } qu->ads= ads; - qu->state= query_udp; + qu->state= query_tosend; qu->back= qu->next= qu->parent= 0; LIST_INIT(qu->children); LINK_INIT(qu->siblings); @@ -100,7 +100,7 @@ static void query_submit(adns_state ads, adns_query qu, qu->query_dglen= qu->vb.used; memcpy(qu->query_dgram,qu->vb.buf,qu->vb.used); - adns__query_udp(qu,now); + adns__query_send(qu,now); adns__autosys(ads,now); } @@ -203,7 +203,7 @@ int adns_submit(adns_state ads, const char *p; typei= adns__findtype(type); - if (!typei) return adns_s_unknownrrtype; + if (!typei) return ENOSYS; r= gettimeofday(&now,0); if (r) goto x_errno; qu= query_alloc(ads,typei,flags,now); if (!qu) goto x_errno; @@ -363,7 +363,7 @@ static void free_query_allocs(adns_query qu) { void adns_cancel(adns_query qu) { switch (qu->state) { - case query_udp: case query_tcpwait: case query_tcpsent: + case query_tosend: case query_tcpwait: case query_tcpsent: LIST_UNLINK(qu->ads->timew,qu); break; case query_child: @@ -429,6 +429,8 @@ void adns__query_done(adns_query qu) { adns_answer *ans; adns_query parent; + cancel_children(qu); + qu->id= -1; ans= qu->answer; @@ -455,7 +457,7 @@ void adns__query_done(adns_query qu) { parent= qu->parent; if (parent) { LIST_UNLINK_PART(parent->children,qu,siblings.); - if (!parent->children.head) LIST_UNLINK(qu->ads->childw,parent); + LIST_UNLINK(qu->ads->childw,parent); qu->ctx.callback(parent,qu); free_query_allocs(qu); free(qu);