1 3e0d8fb3 2005-12-27 devnull #include <u.h>
2 3e0d8fb3 2005-12-27 devnull #include <libc.h>
3 3e0d8fb3 2005-12-27 devnull #include <ip.h>
4 3e0d8fb3 2005-12-27 devnull #include <bio.h>
5 3e0d8fb3 2005-12-27 devnull #include <ndb.h>
6 3e0d8fb3 2005-12-27 devnull #include "dns.h"
10 3e0d8fb3 2005-12-27 devnull Maxdest= 24, /* maximum destinations for a request message */
11 226d80b8 2006-04-01 devnull Maxtrans= 3 /* maximum transmissions to a server */
14 3e0d8fb3 2005-12-27 devnull static int netquery(DN*, int, RR*, Request*, int);
15 3e0d8fb3 2005-12-27 devnull static RR* dnresolve1(char*, int, int, Request*, int, int);
17 3e0d8fb3 2005-12-27 devnull char *LOG = "dns";
20 3e0d8fb3 2005-12-27 devnull * lookup 'type' info for domain name 'name'. If it doesn't exist, try
21 3e0d8fb3 2005-12-27 devnull * looking it up as a canonical name.
24 3e0d8fb3 2005-12-27 devnull dnresolve(char *name, int class, int type, Request *req, RR **cn, int depth, int recurse, int rooted, int *status)
26 3e0d8fb3 2005-12-27 devnull RR *rp, *nrp, *drp;
28 3e0d8fb3 2005-12-27 devnull int loops;
29 3e0d8fb3 2005-12-27 devnull char nname[Domlen];
31 3e0d8fb3 2005-12-27 devnull if(status)
32 3e0d8fb3 2005-12-27 devnull *status = 0;
35 3e0d8fb3 2005-12-27 devnull * hack for systems that don't have resolve search
36 3e0d8fb3 2005-12-27 devnull * lists. Just look up the simple name in the database.
38 3e0d8fb3 2005-12-27 devnull if(!rooted && strchr(name, '.') == 0){
39 3e0d8fb3 2005-12-27 devnull rp = nil;
40 3e0d8fb3 2005-12-27 devnull drp = domainlist(class);
41 3e0d8fb3 2005-12-27 devnull for(nrp = drp; nrp != nil; nrp = nrp->next){
42 3e0d8fb3 2005-12-27 devnull snprint(nname, sizeof(nname), "%s.%s", name, nrp->ptr->name);
43 3e0d8fb3 2005-12-27 devnull rp = dnresolve(nname, class, type, req,cn, depth, recurse, rooted, status);
44 3e0d8fb3 2005-12-27 devnull rrfreelist(rrremneg(&rp));
45 3e0d8fb3 2005-12-27 devnull if(rp != nil)
48 3e0d8fb3 2005-12-27 devnull if(drp != nil)
49 3e0d8fb3 2005-12-27 devnull rrfree(drp);
50 3e0d8fb3 2005-12-27 devnull return rp;
54 3e0d8fb3 2005-12-27 devnull * try the name directly
56 3e0d8fb3 2005-12-27 devnull rp = dnresolve1(name, class, type, req, depth, recurse);
58 3e0d8fb3 2005-12-27 devnull return randomize(rp);
60 3e0d8fb3 2005-12-27 devnull /* try it as a canonical name if we weren't told the name didn't exist */
61 3e0d8fb3 2005-12-27 devnull dp = dnlookup(name, class, 0);
62 3e0d8fb3 2005-12-27 devnull if(type != Tptr && dp->nonexistent != Rname){
63 3e0d8fb3 2005-12-27 devnull for(loops=0; rp == nil && loops < 32; loops++){
64 3e0d8fb3 2005-12-27 devnull rp = dnresolve1(name, class, Tcname, req, depth, recurse);
65 3e0d8fb3 2005-12-27 devnull if(rp == nil)
68 3e0d8fb3 2005-12-27 devnull if(rp->negative){
69 3e0d8fb3 2005-12-27 devnull rrfreelist(rp);
70 3e0d8fb3 2005-12-27 devnull rp = nil;
74 3e0d8fb3 2005-12-27 devnull name = rp->host->name;
76 3e0d8fb3 2005-12-27 devnull rrcat(cn, rp);
78 3e0d8fb3 2005-12-27 devnull rrfreelist(rp);
80 3e0d8fb3 2005-12-27 devnull rp = dnresolve1(name, class, type, req, depth, recurse);
84 3e0d8fb3 2005-12-27 devnull /* distinction between not found and not good */
85 3e0d8fb3 2005-12-27 devnull if(rp == 0 && status != 0 && dp->nonexistent != 0)
86 3e0d8fb3 2005-12-27 devnull *status = dp->nonexistent;
88 3e0d8fb3 2005-12-27 devnull return randomize(rp);
91 3e0d8fb3 2005-12-27 devnull static RR*
92 3e0d8fb3 2005-12-27 devnull dnresolve1(char *name, int class, int type, Request *req, int depth, int recurse)
94 3e0d8fb3 2005-12-27 devnull DN *dp, *nsdp;
95 3e0d8fb3 2005-12-27 devnull RR *rp, *nsrp, *dbnsrp;
96 3e0d8fb3 2005-12-27 devnull char *cp;
98 3e0d8fb3 2005-12-27 devnull if(debug)
99 3e0d8fb3 2005-12-27 devnull syslog(0, LOG, "dnresolve1 %s %d %d", name, type, class);
101 3e0d8fb3 2005-12-27 devnull /* only class Cin implemented so far */
102 3e0d8fb3 2005-12-27 devnull if(class != Cin)
103 3e0d8fb3 2005-12-27 devnull return 0;
105 3e0d8fb3 2005-12-27 devnull dp = dnlookup(name, class, 1);
108 3e0d8fb3 2005-12-27 devnull * Try the cache first
110 3e0d8fb3 2005-12-27 devnull rp = rrlookup(dp, type, OKneg);
112 3e0d8fb3 2005-12-27 devnull if(rp->db){
113 3e0d8fb3 2005-12-27 devnull /* unauthenticated db entries are hints */
114 3e0d8fb3 2005-12-27 devnull if(rp->auth)
115 3e0d8fb3 2005-12-27 devnull return rp;
116 3e0d8fb3 2005-12-27 devnull } else {
117 3e0d8fb3 2005-12-27 devnull /* cached entry must still be valid */
118 3e0d8fb3 2005-12-27 devnull if(rp->ttl > now){
119 3e0d8fb3 2005-12-27 devnull /* but Tall entries are special */
120 3e0d8fb3 2005-12-27 devnull if(type != Tall || rp->query == Tall)
121 3e0d8fb3 2005-12-27 devnull return rp;
125 3e0d8fb3 2005-12-27 devnull rrfreelist(rp);
128 3e0d8fb3 2005-12-27 devnull * try the cache for a canonical name. if found punt
129 3e0d8fb3 2005-12-27 devnull * since we'll find it during the canonical name search
130 3e0d8fb3 2005-12-27 devnull * in dnresolve().
132 3e0d8fb3 2005-12-27 devnull if(type != Tcname){
133 3e0d8fb3 2005-12-27 devnull rp = rrlookup(dp, Tcname, NOneg);
134 3e0d8fb3 2005-12-27 devnull rrfreelist(rp);
136 3e0d8fb3 2005-12-27 devnull return 0;
140 3e0d8fb3 2005-12-27 devnull * if we're running as just a resolver, go to our
141 3e0d8fb3 2005-12-27 devnull * designated name servers
143 3e0d8fb3 2005-12-27 devnull if(resolver){
144 3e0d8fb3 2005-12-27 devnull nsrp = randomize(getdnsservers(class));
145 3e0d8fb3 2005-12-27 devnull if(nsrp != nil) {
146 3e0d8fb3 2005-12-27 devnull if(netquery(dp, type, nsrp, req, depth+1)){
147 3e0d8fb3 2005-12-27 devnull rrfreelist(nsrp);
148 3e0d8fb3 2005-12-27 devnull return rrlookup(dp, type, OKneg);
150 3e0d8fb3 2005-12-27 devnull rrfreelist(nsrp);
155 3e0d8fb3 2005-12-27 devnull * walk up the domain name looking for
156 3e0d8fb3 2005-12-27 devnull * a name server for the domain.
158 3e0d8fb3 2005-12-27 devnull for(cp = name; cp; cp = walkup(cp)){
160 3e0d8fb3 2005-12-27 devnull * if this is a local (served by us) domain,
161 3e0d8fb3 2005-12-27 devnull * return answer
163 3e0d8fb3 2005-12-27 devnull dbnsrp = randomize(dblookup(cp, class, Tns, 0, 0));
164 3e0d8fb3 2005-12-27 devnull if(dbnsrp && dbnsrp->local){
165 3e0d8fb3 2005-12-27 devnull rp = dblookup(name, class, type, 1, dbnsrp->ttl);
166 3e0d8fb3 2005-12-27 devnull rrfreelist(dbnsrp);
167 3e0d8fb3 2005-12-27 devnull return rp;
171 3e0d8fb3 2005-12-27 devnull * if recursion isn't set, just accept local
172 3e0d8fb3 2005-12-27 devnull * entries
174 3e0d8fb3 2005-12-27 devnull if(recurse == Dontrecurse){
175 3e0d8fb3 2005-12-27 devnull if(dbnsrp)
176 3e0d8fb3 2005-12-27 devnull rrfreelist(dbnsrp);
177 3e0d8fb3 2005-12-27 devnull continue;
180 3e0d8fb3 2005-12-27 devnull /* look for ns in cache */
181 3e0d8fb3 2005-12-27 devnull nsdp = dnlookup(cp, class, 0);
182 3e0d8fb3 2005-12-27 devnull nsrp = nil;
183 3e0d8fb3 2005-12-27 devnull if(nsdp)
184 3e0d8fb3 2005-12-27 devnull nsrp = randomize(rrlookup(nsdp, Tns, NOneg));
186 3e0d8fb3 2005-12-27 devnull /* if the entry timed out, ignore it */
187 3e0d8fb3 2005-12-27 devnull if(nsrp && nsrp->ttl < now){
188 3e0d8fb3 2005-12-27 devnull rrfreelist(nsrp);
189 3e0d8fb3 2005-12-27 devnull nsrp = nil;
192 3e0d8fb3 2005-12-27 devnull if(nsrp){
193 3e0d8fb3 2005-12-27 devnull rrfreelist(dbnsrp);
195 3e0d8fb3 2005-12-27 devnull /* try the name servers found in cache */
196 3e0d8fb3 2005-12-27 devnull if(netquery(dp, type, nsrp, req, depth+1)){
197 3e0d8fb3 2005-12-27 devnull rrfreelist(nsrp);
198 3e0d8fb3 2005-12-27 devnull return rrlookup(dp, type, OKneg);
200 3e0d8fb3 2005-12-27 devnull rrfreelist(nsrp);
201 3e0d8fb3 2005-12-27 devnull continue;
204 3e0d8fb3 2005-12-27 devnull /* use ns from db */
205 3e0d8fb3 2005-12-27 devnull if(dbnsrp){
206 3e0d8fb3 2005-12-27 devnull /* try the name servers found in db */
207 3e0d8fb3 2005-12-27 devnull if(netquery(dp, type, dbnsrp, req, depth+1)){
208 3e0d8fb3 2005-12-27 devnull /* we got an answer */
209 3e0d8fb3 2005-12-27 devnull rrfreelist(dbnsrp);
210 3e0d8fb3 2005-12-27 devnull return rrlookup(dp, type, NOneg);
212 3e0d8fb3 2005-12-27 devnull rrfreelist(dbnsrp);
216 3e0d8fb3 2005-12-27 devnull /* settle for a non-authoritative answer */
217 3e0d8fb3 2005-12-27 devnull rp = rrlookup(dp, type, OKneg);
219 3e0d8fb3 2005-12-27 devnull return rp;
221 3e0d8fb3 2005-12-27 devnull /* noone answered. try the database, we might have a chance. */
222 3e0d8fb3 2005-12-27 devnull return dblookup(name, class, type, 0, 0);
226 3e0d8fb3 2005-12-27 devnull * walk a domain name one element to the right. return a pointer to that element.
227 3e0d8fb3 2005-12-27 devnull * in other words, return a pointer to the parent domain name.
230 3e0d8fb3 2005-12-27 devnull walkup(char *name)
232 3e0d8fb3 2005-12-27 devnull char *cp;
234 3e0d8fb3 2005-12-27 devnull cp = strchr(name, '.');
236 3e0d8fb3 2005-12-27 devnull return cp+1;
237 3e0d8fb3 2005-12-27 devnull else if(*name)
238 3e0d8fb3 2005-12-27 devnull return "";
240 3e0d8fb3 2005-12-27 devnull return 0;
244 3e0d8fb3 2005-12-27 devnull * Get a udpport for requests and replies.
247 3e0d8fb3 2005-12-27 devnull udpport(void)
251 3e0d8fb3 2005-12-27 devnull if((fd = dial("udp!0!53", nil, nil, nil)) < 0)
252 3e0d8fb3 2005-12-27 devnull warning("can't get udp port");
253 3e0d8fb3 2005-12-27 devnull return fd;
257 3e0d8fb3 2005-12-27 devnull mkreq(DN *dp, int type, uchar *buf, int flags, ushort reqno)
259 3e0d8fb3 2005-12-27 devnull DNSmsg m;
260 3e0d8fb3 2005-12-27 devnull int len;
261 5c9f76b5 2006-02-14 devnull Udphdr *uh = (Udphdr*)buf;
263 3e0d8fb3 2005-12-27 devnull /* stuff port number into output buffer */
264 3e0d8fb3 2005-12-27 devnull memset(uh, 0, sizeof(*uh));
265 3e0d8fb3 2005-12-27 devnull hnputs(uh->rport, 53);
267 3e0d8fb3 2005-12-27 devnull /* make request and convert it to output format */
268 3e0d8fb3 2005-12-27 devnull memset(&m, 0, sizeof(m));
269 3e0d8fb3 2005-12-27 devnull m.flags = flags;
270 3e0d8fb3 2005-12-27 devnull m.id = reqno;
271 3e0d8fb3 2005-12-27 devnull m.qd = rralloc(type);
272 3e0d8fb3 2005-12-27 devnull m.qd->owner = dp;
273 3e0d8fb3 2005-12-27 devnull m.qd->type = type;
274 5c9f76b5 2006-02-14 devnull len = convDNS2M(&m, &buf[Udphdrsize], Maxudp);
275 3e0d8fb3 2005-12-27 devnull if(len < 0)
276 3e0d8fb3 2005-12-27 devnull abort(); /* "can't convert" */;
277 3e0d8fb3 2005-12-27 devnull rrfree(m.qd);
278 3e0d8fb3 2005-12-27 devnull return len;
281 3e0d8fb3 2005-12-27 devnull static void
282 3e0d8fb3 2005-12-27 devnull freeanswers(DNSmsg *mp)
284 3e0d8fb3 2005-12-27 devnull rrfreelist(mp->qd);
285 3e0d8fb3 2005-12-27 devnull rrfreelist(mp->an);
286 3e0d8fb3 2005-12-27 devnull rrfreelist(mp->ns);
287 3e0d8fb3 2005-12-27 devnull rrfreelist(mp->ar);
291 3e0d8fb3 2005-12-27 devnull * read replies to a request. ignore any of the wrong type. wait at most 5 seconds.
293 49a1496c 2006-02-20 devnull static int udpreadtimeout(int, Udphdr*, void*, int, int);
294 3e0d8fb3 2005-12-27 devnull static int
295 3e0d8fb3 2005-12-27 devnull readreply(int fd, DN *dp, int type, ushort req,
296 3e0d8fb3 2005-12-27 devnull uchar *ibuf, DNSmsg *mp, ulong endtime, Request *reqp)
298 3e0d8fb3 2005-12-27 devnull char *err;
299 3e0d8fb3 2005-12-27 devnull int len;
300 3e0d8fb3 2005-12-27 devnull ulong now;
303 3e0d8fb3 2005-12-27 devnull for(; ; freeanswers(mp)){
304 3e0d8fb3 2005-12-27 devnull now = time(0);
305 3e0d8fb3 2005-12-27 devnull if(now >= endtime)
306 3e0d8fb3 2005-12-27 devnull return -1; /* timed out */
308 3e0d8fb3 2005-12-27 devnull /* timed read */
309 49a1496c 2006-02-20 devnull len = udpreadtimeout(fd, (Udphdr*)ibuf, ibuf+Udphdrsize, Maxudpin, (endtime-now)*1000);
310 3e0d8fb3 2005-12-27 devnull if(len < 0)
311 3e0d8fb3 2005-12-27 devnull return -1; /* timed out */
313 3e0d8fb3 2005-12-27 devnull /* convert into internal format */
314 3e0d8fb3 2005-12-27 devnull memset(mp, 0, sizeof(*mp));
315 5c9f76b5 2006-02-14 devnull err = convM2DNS(&ibuf[Udphdrsize], len, mp);
316 3e0d8fb3 2005-12-27 devnull if(err){
317 3e0d8fb3 2005-12-27 devnull syslog(0, LOG, "input err %s: %I", err, ibuf);
318 3e0d8fb3 2005-12-27 devnull continue;
320 3e0d8fb3 2005-12-27 devnull if(debug)
321 3e0d8fb3 2005-12-27 devnull logreply(reqp->id, ibuf, mp);
323 3e0d8fb3 2005-12-27 devnull /* answering the right question? */
324 3e0d8fb3 2005-12-27 devnull if(mp->id != req){
325 3e0d8fb3 2005-12-27 devnull syslog(0, LOG, "%d: id %d instead of %d: %I", reqp->id,
326 3e0d8fb3 2005-12-27 devnull mp->id, req, ibuf);
327 3e0d8fb3 2005-12-27 devnull continue;
329 3e0d8fb3 2005-12-27 devnull if(mp->qd == 0){
330 3e0d8fb3 2005-12-27 devnull syslog(0, LOG, "%d: no question RR: %I", reqp->id, ibuf);
331 3e0d8fb3 2005-12-27 devnull continue;
333 3e0d8fb3 2005-12-27 devnull if(mp->qd->owner != dp){
334 3e0d8fb3 2005-12-27 devnull syslog(0, LOG, "%d: owner %s instead of %s: %I", reqp->id,
335 3e0d8fb3 2005-12-27 devnull mp->qd->owner->name, dp->name, ibuf);
336 3e0d8fb3 2005-12-27 devnull continue;
338 3e0d8fb3 2005-12-27 devnull if(mp->qd->type != type){
339 3e0d8fb3 2005-12-27 devnull syslog(0, LOG, "%d: type %d instead of %d: %I", reqp->id,
340 3e0d8fb3 2005-12-27 devnull mp->qd->type, type, ibuf);
341 3e0d8fb3 2005-12-27 devnull continue;
344 3e0d8fb3 2005-12-27 devnull /* remember what request this is in answer to */
345 3e0d8fb3 2005-12-27 devnull for(rp = mp->an; rp; rp = rp->next)
346 3e0d8fb3 2005-12-27 devnull rp->query = type;
348 3e0d8fb3 2005-12-27 devnull return 0;
351 3e0d8fb3 2005-12-27 devnull return 0; /* never reached */
354 49a1496c 2006-02-20 devnull static int
355 49a1496c 2006-02-20 devnull udpreadtimeout(int fd, Udphdr *h, void *data, int n, int ms)
357 49a1496c 2006-02-20 devnull fd_set rd;
358 49a1496c 2006-02-20 devnull struct timeval tv;
360 49a1496c 2006-02-20 devnull FD_ZERO(&rd);
361 49a1496c 2006-02-20 devnull FD_SET(fd, &rd);
363 49a1496c 2006-02-20 devnull tv.tv_sec = ms/1000;
364 49a1496c 2006-02-20 devnull tv.tv_usec = (ms%1000)*1000;
366 49a1496c 2006-02-20 devnull if(select(fd+1, &rd, 0, 0, &tv) != 1)
367 49a1496c 2006-02-20 devnull return -1;
368 49a1496c 2006-02-20 devnull return udpread(fd, h, data, n);
372 3e0d8fb3 2005-12-27 devnull * return non-0 if first list includes second list
375 3e0d8fb3 2005-12-27 devnull contains(RR *rp1, RR *rp2)
377 3e0d8fb3 2005-12-27 devnull RR *trp1, *trp2;
379 3e0d8fb3 2005-12-27 devnull for(trp2 = rp2; trp2; trp2 = trp2->next){
380 3e0d8fb3 2005-12-27 devnull for(trp1 = rp1; trp1; trp1 = trp1->next){
381 3e0d8fb3 2005-12-27 devnull if(trp1->type == trp2->type)
382 3e0d8fb3 2005-12-27 devnull if(trp1->host == trp2->host)
383 3e0d8fb3 2005-12-27 devnull if(trp1->owner == trp2->owner)
386 3e0d8fb3 2005-12-27 devnull if(trp1 == 0)
387 3e0d8fb3 2005-12-27 devnull return 0;
390 3e0d8fb3 2005-12-27 devnull return 1;
394 3e0d8fb3 2005-12-27 devnull typedef struct Dest Dest;
395 3e0d8fb3 2005-12-27 devnull struct Dest
397 3e0d8fb3 2005-12-27 devnull uchar a[IPaddrlen]; /* ip address */
398 3e0d8fb3 2005-12-27 devnull DN *s; /* name server */
399 3e0d8fb3 2005-12-27 devnull int nx; /* number of transmissions */
400 3e0d8fb3 2005-12-27 devnull int code;
405 3e0d8fb3 2005-12-27 devnull * return multicast version if any
408 3e0d8fb3 2005-12-27 devnull ipisbm(uchar *ip)
410 3e0d8fb3 2005-12-27 devnull if(isv4(ip)){
411 3e0d8fb3 2005-12-27 devnull if(ip[IPv4off] >= 0xe0 && ip[IPv4off] < 0xf0)
412 3e0d8fb3 2005-12-27 devnull return 4;
413 3e0d8fb3 2005-12-27 devnull if(ipcmp(ip, IPv4bcast) == 0)
414 3e0d8fb3 2005-12-27 devnull return 4;
415 3e0d8fb3 2005-12-27 devnull } else {
416 3e0d8fb3 2005-12-27 devnull if(ip[0] == 0xff)
417 3e0d8fb3 2005-12-27 devnull return 6;
419 3e0d8fb3 2005-12-27 devnull return 0;
423 3e0d8fb3 2005-12-27 devnull * Get next server address
425 3e0d8fb3 2005-12-27 devnull static int
426 3e0d8fb3 2005-12-27 devnull serveraddrs(RR *nsrp, Dest *dest, int nd, int depth, Request *reqp)
428 3e0d8fb3 2005-12-27 devnull RR *rp, *arp, *trp;
429 3e0d8fb3 2005-12-27 devnull Dest *cur;
431 3e0d8fb3 2005-12-27 devnull if(nd >= Maxdest)
432 3e0d8fb3 2005-12-27 devnull return 0;
435 3e0d8fb3 2005-12-27 devnull * look for a server whose address we already know.
436 3e0d8fb3 2005-12-27 devnull * if we find one, mark it so we ignore this on
437 3e0d8fb3 2005-12-27 devnull * subsequent passes.
439 3e0d8fb3 2005-12-27 devnull arp = 0;
440 3e0d8fb3 2005-12-27 devnull for(rp = nsrp; rp; rp = rp->next){
441 3e0d8fb3 2005-12-27 devnull assert(rp->magic == RRmagic);
442 3e0d8fb3 2005-12-27 devnull if(rp->marker)
443 3e0d8fb3 2005-12-27 devnull continue;
444 3e0d8fb3 2005-12-27 devnull arp = rrlookup(rp->host, Ta, NOneg);
445 3e0d8fb3 2005-12-27 devnull if(arp){
446 3e0d8fb3 2005-12-27 devnull rp->marker = 1;
449 3e0d8fb3 2005-12-27 devnull arp = dblookup(rp->host->name, Cin, Ta, 0, 0);
450 3e0d8fb3 2005-12-27 devnull if(arp){
451 3e0d8fb3 2005-12-27 devnull rp->marker = 1;
457 3e0d8fb3 2005-12-27 devnull * if the cache and database lookup didn't find any new
458 3e0d8fb3 2005-12-27 devnull * server addresses, try resolving one via the network.
459 3e0d8fb3 2005-12-27 devnull * Mark any we try to resolve so we don't try a second time.
461 3e0d8fb3 2005-12-27 devnull if(arp == 0){
462 3e0d8fb3 2005-12-27 devnull for(rp = nsrp; rp; rp = rp->next){
463 3e0d8fb3 2005-12-27 devnull if(rp->marker)
464 3e0d8fb3 2005-12-27 devnull continue;
465 3e0d8fb3 2005-12-27 devnull rp->marker = 1;
468 3e0d8fb3 2005-12-27 devnull * avoid loops looking up a server under itself
470 3e0d8fb3 2005-12-27 devnull if(subsume(rp->owner->name, rp->host->name))
471 3e0d8fb3 2005-12-27 devnull continue;
473 3e0d8fb3 2005-12-27 devnull arp = dnresolve(rp->host->name, Cin, Ta, reqp, 0, depth+1, Recurse, 1, 0);
474 3e0d8fb3 2005-12-27 devnull rrfreelist(rrremneg(&arp));
480 3e0d8fb3 2005-12-27 devnull /* use any addresses that we found */
481 3e0d8fb3 2005-12-27 devnull for(trp = arp; trp; trp = trp->next){
482 3e0d8fb3 2005-12-27 devnull if(nd >= Maxdest)
484 3e0d8fb3 2005-12-27 devnull cur = &dest[nd];
485 3e0d8fb3 2005-12-27 devnull parseip(cur->a, trp->ip->name);
486 3e0d8fb3 2005-12-27 devnull if(ipisbm(cur->a))
487 3e0d8fb3 2005-12-27 devnull continue;
488 3e0d8fb3 2005-12-27 devnull cur->nx = 0;
489 3e0d8fb3 2005-12-27 devnull cur->s = trp->owner;
490 3e0d8fb3 2005-12-27 devnull cur->code = Rtimeout;
493 3e0d8fb3 2005-12-27 devnull rrfreelist(arp);
494 3e0d8fb3 2005-12-27 devnull return nd;
498 3e0d8fb3 2005-12-27 devnull * cache negative responses
500 3e0d8fb3 2005-12-27 devnull static void
501 3e0d8fb3 2005-12-27 devnull cacheneg(DN *dp, int type, int rcode, RR *soarr)
504 3e0d8fb3 2005-12-27 devnull DN *soaowner;
505 3e0d8fb3 2005-12-27 devnull ulong ttl;
507 3e0d8fb3 2005-12-27 devnull /* no cache time specified, don' make anything up */
508 3e0d8fb3 2005-12-27 devnull if(soarr != nil){
509 3e0d8fb3 2005-12-27 devnull if(soarr->next != nil){
510 3e0d8fb3 2005-12-27 devnull rrfreelist(soarr->next);
511 3e0d8fb3 2005-12-27 devnull soarr->next = nil;
513 3e0d8fb3 2005-12-27 devnull soaowner = soarr->owner;
515 3e0d8fb3 2005-12-27 devnull soaowner = nil;
517 3e0d8fb3 2005-12-27 devnull /* the attach can cause soarr to be freed so mine it now */
518 3e0d8fb3 2005-12-27 devnull if(soarr != nil && soarr->soa != nil)
519 3e0d8fb3 2005-12-27 devnull ttl = soarr->soa->minttl+now;
521 3e0d8fb3 2005-12-27 devnull ttl = 5*Min;
523 3e0d8fb3 2005-12-27 devnull /* add soa and negative RR to the database */
524 3e0d8fb3 2005-12-27 devnull rrattach(soarr, 1);
526 3e0d8fb3 2005-12-27 devnull rp = rralloc(type);
527 3e0d8fb3 2005-12-27 devnull rp->owner = dp;
528 3e0d8fb3 2005-12-27 devnull rp->negative = 1;
529 3e0d8fb3 2005-12-27 devnull rp->negsoaowner = soaowner;
530 3e0d8fb3 2005-12-27 devnull rp->negrcode = rcode;
531 3e0d8fb3 2005-12-27 devnull rp->ttl = ttl;
532 3e0d8fb3 2005-12-27 devnull rrattach(rp, 1);
536 3e0d8fb3 2005-12-27 devnull * query name servers. If the name server returns a pointer to another
537 3e0d8fb3 2005-12-27 devnull * name server, recurse.
539 3e0d8fb3 2005-12-27 devnull static int
540 3e0d8fb3 2005-12-27 devnull netquery1(int fd, DN *dp, int type, RR *nsrp, Request *reqp, int depth, uchar *ibuf, uchar *obuf)
542 3e0d8fb3 2005-12-27 devnull int ndest, j, len, replywaits, rv;
543 3e0d8fb3 2005-12-27 devnull ushort req;
544 3e0d8fb3 2005-12-27 devnull RR *tp, *soarr;
545 3e0d8fb3 2005-12-27 devnull Dest *p, *l, *np;
546 3e0d8fb3 2005-12-27 devnull DN *ndp;
547 3e0d8fb3 2005-12-27 devnull Dest dest[Maxdest];
548 3e0d8fb3 2005-12-27 devnull DNSmsg m;
549 3e0d8fb3 2005-12-27 devnull ulong endtime;
550 5c9f76b5 2006-02-14 devnull Udphdr *uh;
552 3e0d8fb3 2005-12-27 devnull /* pack request into a message */
553 3e0d8fb3 2005-12-27 devnull req = rand();
554 3e0d8fb3 2005-12-27 devnull len = mkreq(dp, type, obuf, Frecurse|Oquery, req);
556 3e0d8fb3 2005-12-27 devnull /* no server addresses yet */
557 3e0d8fb3 2005-12-27 devnull l = dest;
560 3e0d8fb3 2005-12-27 devnull * transmit requests and wait for answers.
561 3e0d8fb3 2005-12-27 devnull * at most Maxtrans attempts to each address.
562 3e0d8fb3 2005-12-27 devnull * each cycle send one more message than the previous.
564 3e0d8fb3 2005-12-27 devnull for(ndest = 1; ndest < Maxdest; ndest++){
565 3e0d8fb3 2005-12-27 devnull p = dest;
567 3e0d8fb3 2005-12-27 devnull endtime = time(0);
568 3e0d8fb3 2005-12-27 devnull if(endtime >= reqp->aborttime)
571 3e0d8fb3 2005-12-27 devnull /* get a server address if we need one */
572 3e0d8fb3 2005-12-27 devnull if(ndest > l - p){
573 3e0d8fb3 2005-12-27 devnull j = serveraddrs(nsrp, dest, l - p, depth, reqp);
574 3e0d8fb3 2005-12-27 devnull l = &dest[j];
577 3e0d8fb3 2005-12-27 devnull /* no servers, punt */
578 3e0d8fb3 2005-12-27 devnull if(l == dest)
581 3e0d8fb3 2005-12-27 devnull /* send to first 'ndest' destinations */
583 3e0d8fb3 2005-12-27 devnull for(; p < &dest[ndest] && p < l; p++){
584 3e0d8fb3 2005-12-27 devnull /* skip destinations we've finished with */
585 3e0d8fb3 2005-12-27 devnull if(p->nx >= Maxtrans)
586 3e0d8fb3 2005-12-27 devnull continue;
590 3e0d8fb3 2005-12-27 devnull /* exponential backoff of requests */
591 3e0d8fb3 2005-12-27 devnull if((1<<p->nx) > ndest)
592 3e0d8fb3 2005-12-27 devnull continue;
594 3e0d8fb3 2005-12-27 devnull memmove(obuf, p->a, sizeof(p->a));
595 3e0d8fb3 2005-12-27 devnull if(debug)
596 3e0d8fb3 2005-12-27 devnull logsend(reqp->id, depth, obuf, p->s->name,
597 3e0d8fb3 2005-12-27 devnull dp->name, type);
598 5c9f76b5 2006-02-14 devnull uh = (Udphdr*)obuf;
599 5c9f76b5 2006-02-14 devnull fprint(2, "send %I %I %d %d\n", uh->raddr, uh->laddr, nhgets(uh->rport), nhgets(uh->lport));
600 5c9f76b5 2006-02-14 devnull if(udpwrite(fd, uh, obuf+Udphdrsize, len) < 0)
601 3e0d8fb3 2005-12-27 devnull warning("sending udp msg %r");
602 3e0d8fb3 2005-12-27 devnull p->nx++;
604 3e0d8fb3 2005-12-27 devnull if(j == 0)
605 3e0d8fb3 2005-12-27 devnull break; /* no destinations left */
607 3e0d8fb3 2005-12-27 devnull /* wait up to 5 seconds for replies */
608 3e0d8fb3 2005-12-27 devnull endtime = time(0) + 5;
609 3e0d8fb3 2005-12-27 devnull if(endtime > reqp->aborttime)
610 3e0d8fb3 2005-12-27 devnull endtime = reqp->aborttime;
612 3e0d8fb3 2005-12-27 devnull for(replywaits = 0; replywaits < ndest; replywaits++){
613 3e0d8fb3 2005-12-27 devnull if(readreply(fd, dp, type, req, ibuf, &m, endtime, reqp) < 0)
614 3e0d8fb3 2005-12-27 devnull break; /* timed out */
616 3e0d8fb3 2005-12-27 devnull /* find responder */
617 3e0d8fb3 2005-12-27 devnull for(p = dest; p < l; p++)
618 3e0d8fb3 2005-12-27 devnull if(memcmp(p->a, ibuf, sizeof(p->a)) == 0)
621 3e0d8fb3 2005-12-27 devnull /* remove all addrs of responding server from list */
622 3e0d8fb3 2005-12-27 devnull for(np = dest; np < l; np++)
623 3e0d8fb3 2005-12-27 devnull if(np->s == p->s)
624 3e0d8fb3 2005-12-27 devnull p->nx = Maxtrans;
626 3e0d8fb3 2005-12-27 devnull /* ignore any error replies */
627 3e0d8fb3 2005-12-27 devnull if((m.flags & Rmask) == Rserver){
628 3e0d8fb3 2005-12-27 devnull rrfreelist(m.qd);
629 3e0d8fb3 2005-12-27 devnull rrfreelist(m.an);
630 3e0d8fb3 2005-12-27 devnull rrfreelist(m.ar);
631 3e0d8fb3 2005-12-27 devnull rrfreelist(m.ns);
632 3e0d8fb3 2005-12-27 devnull if(p != l)
633 3e0d8fb3 2005-12-27 devnull p->code = Rserver;
634 3e0d8fb3 2005-12-27 devnull continue;
637 3e0d8fb3 2005-12-27 devnull /* ignore any bad delegations */
638 3e0d8fb3 2005-12-27 devnull if(m.ns && baddelegation(m.ns, nsrp, ibuf)){
639 3e0d8fb3 2005-12-27 devnull rrfreelist(m.ns);
640 3e0d8fb3 2005-12-27 devnull m.ns = nil;
641 3e0d8fb3 2005-12-27 devnull if(m.an == nil){
642 3e0d8fb3 2005-12-27 devnull rrfreelist(m.qd);
643 3e0d8fb3 2005-12-27 devnull rrfreelist(m.ar);
644 3e0d8fb3 2005-12-27 devnull if(p != l)
645 3e0d8fb3 2005-12-27 devnull p->code = Rserver;
646 3e0d8fb3 2005-12-27 devnull continue;
651 3e0d8fb3 2005-12-27 devnull /* remove any soa's from the authority section */
652 3e0d8fb3 2005-12-27 devnull soarr = rrremtype(&m.ns, Tsoa);
654 3e0d8fb3 2005-12-27 devnull /* incorporate answers */
655 3e0d8fb3 2005-12-27 devnull if(m.an)
656 3e0d8fb3 2005-12-27 devnull rrattach(m.an, (m.flags & Fauth) ? 1 : 0);
657 3e0d8fb3 2005-12-27 devnull if(m.ar)
658 3e0d8fb3 2005-12-27 devnull rrattach(m.ar, 0);
659 3e0d8fb3 2005-12-27 devnull if(m.ns){
660 3e0d8fb3 2005-12-27 devnull ndp = m.ns->owner;
661 3e0d8fb3 2005-12-27 devnull rrattach(m.ns, 0);
663 3e0d8fb3 2005-12-27 devnull ndp = 0;
665 3e0d8fb3 2005-12-27 devnull /* free the question */
666 3e0d8fb3 2005-12-27 devnull if(m.qd)
667 3e0d8fb3 2005-12-27 devnull rrfreelist(m.qd);
670 3e0d8fb3 2005-12-27 devnull * Any reply from an authoritative server,
671 3e0d8fb3 2005-12-27 devnull * or a positive reply terminates the search
673 3e0d8fb3 2005-12-27 devnull if(m.an != nil || (m.flags & Fauth)){
674 3e0d8fb3 2005-12-27 devnull if(m.an == nil && (m.flags & Rmask) == Rname)
675 3e0d8fb3 2005-12-27 devnull dp->nonexistent = Rname;
677 3e0d8fb3 2005-12-27 devnull dp->nonexistent = 0;
680 3e0d8fb3 2005-12-27 devnull * cache any negative responses, free soarr
682 3e0d8fb3 2005-12-27 devnull if((m.flags & Fauth) && m.an == nil)
683 3e0d8fb3 2005-12-27 devnull cacheneg(dp, type, (m.flags & Rmask), soarr);
685 3e0d8fb3 2005-12-27 devnull rrfreelist(soarr);
686 3e0d8fb3 2005-12-27 devnull return 1;
688 3e0d8fb3 2005-12-27 devnull rrfreelist(soarr);
691 3e0d8fb3 2005-12-27 devnull * if we've been given better name servers
692 3e0d8fb3 2005-12-27 devnull * recurse
694 3e0d8fb3 2005-12-27 devnull if(m.ns){
695 3e0d8fb3 2005-12-27 devnull tp = rrlookup(ndp, Tns, NOneg);
696 3e0d8fb3 2005-12-27 devnull if(!contains(nsrp, tp)){
697 3e0d8fb3 2005-12-27 devnull rv = netquery(dp, type, tp, reqp, depth+1);
698 3e0d8fb3 2005-12-27 devnull rrfreelist(tp);
699 3e0d8fb3 2005-12-27 devnull return rv;
701 3e0d8fb3 2005-12-27 devnull rrfreelist(tp);
706 3e0d8fb3 2005-12-27 devnull /* if all servers returned failure, propogate it */
707 3e0d8fb3 2005-12-27 devnull dp->nonexistent = Rserver;
708 3e0d8fb3 2005-12-27 devnull for(p = dest; p < l; p++)
709 3e0d8fb3 2005-12-27 devnull if(p->code != Rserver)
710 3e0d8fb3 2005-12-27 devnull dp->nonexistent = 0;
712 3e0d8fb3 2005-12-27 devnull return 0;
715 3e0d8fb3 2005-12-27 devnull typedef struct Qarg Qarg;
716 3e0d8fb3 2005-12-27 devnull struct Qarg
719 3e0d8fb3 2005-12-27 devnull int type;
720 3e0d8fb3 2005-12-27 devnull RR *nsrp;
721 3e0d8fb3 2005-12-27 devnull Request *reqp;
722 3e0d8fb3 2005-12-27 devnull int depth;
726 3e0d8fb3 2005-12-27 devnull static int
727 3e0d8fb3 2005-12-27 devnull netquery(DN *dp, int type, RR *nsrp, Request *reqp, int depth)
729 3e0d8fb3 2005-12-27 devnull uchar *obuf;
730 3e0d8fb3 2005-12-27 devnull uchar *ibuf;
732 3e0d8fb3 2005-12-27 devnull int fd, rv;
734 3e0d8fb3 2005-12-27 devnull if(depth > 12)
735 3e0d8fb3 2005-12-27 devnull return 0;
737 3e0d8fb3 2005-12-27 devnull /* use alloced buffers rather than ones from the stack */
738 5c9f76b5 2006-02-14 devnull ibuf = emalloc(Maxudpin+Udphdrsize);
739 5c9f76b5 2006-02-14 devnull obuf = emalloc(Maxudp+Udphdrsize);
741 3e0d8fb3 2005-12-27 devnull /* prepare server RR's for incremental lookup */
742 3e0d8fb3 2005-12-27 devnull for(rp = nsrp; rp; rp = rp->next)
743 3e0d8fb3 2005-12-27 devnull rp->marker = 0;
745 3e0d8fb3 2005-12-27 devnull fd = udpport();
746 3e0d8fb3 2005-12-27 devnull if(fd < 0)
747 3e0d8fb3 2005-12-27 devnull return 0;
748 3e0d8fb3 2005-12-27 devnull rv = netquery1(fd, dp, type, nsrp, reqp, depth, ibuf, obuf);
749 3e0d8fb3 2005-12-27 devnull close(fd);
750 3e0d8fb3 2005-12-27 devnull free(ibuf);
751 3e0d8fb3 2005-12-27 devnull free(obuf);
753 3e0d8fb3 2005-12-27 devnull return rv;
