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);
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);
}
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:
adns_answer *ans;
adns_query parent;
+ cancel_children(qu);
+
qu->id= -1;
ans= qu->answer;
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);