+ for (qu= ads->timew; qu; qu= nqu) {
+ nqu= qu->next;
+ if (qu->senttcpserver == -1) continue;
+ assert(qu->senttcpserver == serv);
+ DLIST_UNLINK(ads->timew,qu);
+ adns__query_fail(ads,qu,adns_s_connlost); /* wishlist: send to other servers ? */
+ }
+
+ ads->tcpbuf.used= 0;
+ ads->tcpserver= (serv+1)%ads->nservers;
+}
+
+void adns__tcp_tryconnect(adns_state ads) {
+ int r, fd, tries;
+ sockaddr_in addr;
+
+ for (tries=0; tries<ads->nservers; tries++) {
+ if (ads->tcpstate == server_connecting || ads->tcpstate == server_ok) return;
+ assert(ads->tcpstate == server_disconnected);
+ assert(!ads->tcpbuf.used);
+
+ proto= getprotobyname("tcp");
+ if (!proto) { diag(ads,"unable to find protocol number for TCP !",-1); return; }
+ fd= socket(AF_INET,SOCK_STREAM,proto->p_proto);
+ if (fd<0) { diag(ads,"cannot create TCP socket: %s",-1,strerror(errno)); return; }
+ if (!adns__setnonblock(fd)) return;
+ memset(&addr,0,sizeof(addr));
+ addr.sin_family= AF_INET;
+ addr.sin_port= htons(NSPORT);
+ addr.sin_addr= ads->servers[ads->tcpserver].addr;
+ r= connect(fd,&addr,sizeof(addr));
+ ads->tcpsocket= fd;
+ ads->tcpstate= server_connecting;
+ if (r==0) { ads->tcpstate= server_ok; return; }
+ if (errno == EWOULDBLOCK || errno == EINPROGRESS) return;
+ tcpserver_broken(ads,"connect",strerror(errno));
+ }
+}
+