for (qu= ads->timew.head; qu; qu= nqu) {
nqu= qu->next;
- if (qu->state == query_udp) continue;
+ if (qu->state == query_tosend) continue;
assert(qu->state == query_tcpwait || qu->state == query_tcpsent);
qu->state= query_tcpwait;
qu->tcpfailed |= (1<<serv);
ads->tcpstate= server_ok;
for (qu= ads->timew.head; qu; qu= nqu) {
nqu= qu->next;
- if (qu->state == query_udp) continue;
+ if (qu->state == query_tosend) continue;
assert (qu->state == query_tcpwait);
adns__query_tcp(qu,now);
}
} else {
if (!act) continue;
LIST_UNLINK(ads->timew,qu);
- if (qu->state != query_udp) {
+ if (qu->state != query_tosend) {
adns__query_fail(qu,adns_s_timeout);
} else {
- adns__query_udp(qu,now);
+ adns__query_send(qu,now);
}
nqu= ads->timew.head;
}
if (ads->tcprecv.used<skip+2+dgramlen) {
want= 2+dgramlen;
} else {
- adns__procdgram(ads,ads->tcprecv.buf+skip+2,dgramlen,ads->tcpserver,*now);
+ adns__procdgram(ads,ads->tcprecv.buf+skip+2,dgramlen,ads->tcpserver,1,*now);
skip+= 2+dgramlen; continue;
}
}
inet_ntoa(udpaddr.sin_addr));
continue;
}
- adns__procdgram(ads,udpbuf,r,serv,*now);
+ adns__procdgram(ads,udpbuf,r,serv,0,*now);
}
}
return 0;