for (qu= ads->timew.head; qu; qu= nqu) {
nqu= qu->next;
- if (timercmp(&now,&qu->timeout,<=)) {
+ if (!timercmp(&now,&qu->timeout,>)) {
if (!tv_io) continue;
inter_maxtoabs(tv_io,tvbuf,now,qu->timeout);
} else {
abort();
}
pollfds_buf[1].fd= ads->tcpsocket;
- pollfds_buf[1].revents= 0;
return 2;
}
LIST_UNLINK(ads->output,qu);
*answer= qu->answer;
if (context_r) *context_r= qu->ctx.ext;
+ *query_io= qu;
free(qu);
return 0;
}