const struct sortlist *sl;
int i;
- assert(ads->udpsocket >= 0);
+ assert(ads->udpsockets >= 0);
for (i=0; i<ads->nsortlist; i++) {
sl= &ads->sortlist[i];
assert(MAX_POLLFDS == MAXUDP + 1);
- for (i=0; i<ads->nudp; i++)
- ADD_POLLFD(ads->udpsocket[i].fd, POLLIN);
+ for (i=0; i<ads->nudpsockets; i++)
+ ADD_POLLFD(ads->udpsockets[i].fd, POLLIN);
switch (ads->tcpstate) {
case server_disconnected:
default:
abort();
}
- for (i=0; i<ads->nudp; i++) {
- udp= &ads->udpsocket[i];
+ for (i=0; i<ads->nudpsockets; i++) {
+ udp= &ads->udpsockets[i];
if (fd == udp->fd) {
for (;;) {
udpaddrlen= sizeof(udpaddr);
struct query_queue udpw, tcpw, childw, output, intdone;
adns_query forallnext;
int nextid, tcpsocket;
- struct udpsocket { int af; int fd; } udpsocket[MAXUDP];
- int nudp;
+ struct udpsocket { int af; int fd; } udpsockets[MAXUDP];
+ int nudpsockets;
vbuf tcpsend, tcprecv;
int nservers, nsortlist, nsearchlist, searchndots, tcpserver, tcprecv_skip;
enum adns__tcpstate {
LIST_INIT(ads->intdone);
ads->forallnext= 0;
ads->nextid= 0x311f;
- ads->nudp= 0;
+ ads->nudpsockets= 0;
ads->tcpsocket= -1;
adns__vbuf_init(&ads->tcpsend);
adns__vbuf_init(&ads->tcprecv);
}
proto= getprotobyname("udp"); if (!proto) { r= ENOPROTOOPT; goto x_free; }
- ads->nudp= 0;
+ ads->nudpsockets= 0;
for (i=0; i<ads->nservers; i++) {
if (adns__udpsocket_by_af(ads, ads->servers[i].addr.sa.sa_family))
continue;
- assert(ads->nudp < MAXUDP);
- udp= &ads->udpsocket[ads->nudp];
+ assert(ads->nudpsockets < MAXUDP);
+ udp= &ads->udpsockets[ads->nudpsockets];
udp->af= ads->servers[i].addr.sa.sa_family;
udp->fd= socket(udp->af,SOCK_DGRAM,proto->p_proto);
if (udp->fd < 0) { r= errno; goto x_free; }
- ads->nudp++;
+ ads->nudpsockets++;
r= adns__setnonblock(ads,udp->fd);
if (r) { r= errno; goto x_closeudp; }
}
return 0;
x_closeudp:
- for (j=0; j<ads->nudp; j++) close(ads->udpsocket[j].fd);
+ for (j=0; j<ads->nudpsockets; j++) close(ads->udpsockets[j].fd);
x_free:
free(ads);
return r;
else if (ads->intdone.head) adns__cancel(ads->output.head);
else break;
}
- for (i=0; i<ads->nudp; i++) close(ads->udpsocket[i].fd);
+ for (i=0; i<ads->nudpsockets; i++) close(ads->udpsockets[i].fd);
if (ads->tcpsocket >= 0) close(ads->tcpsocket);
adns__vbuf_free(&ads->tcpsend);
adns__vbuf_free(&ads->tcprecv);
struct udpsocket *adns__udpsocket_by_af(adns_state ads, int af) {
int i;
- for (i=0; i<ads->nudp; i++)
- if (ads->udpsocket[i].af == af) return &ads->udpsocket[i];
+ for (i=0; i<ads->nudpsockets; i++)
+ if (ads->udpsockets[i].af == af) return &ads->udpsockets[i];
return 0;
}