Blame


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 <ctype.h>
5 3e0d8fb3 2005-12-27 devnull #include <bio.h>
6 3e0d8fb3 2005-12-27 devnull #include <ndb.h>
7 3e0d8fb3 2005-12-27 devnull #include "dns.h"
8 3e0d8fb3 2005-12-27 devnull
9 3e0d8fb3 2005-12-27 devnull /*
10 3e0d8fb3 2005-12-27 devnull * Hash table for domain names. The hash is based only on the
11 3e0d8fb3 2005-12-27 devnull * first element of the domain name.
12 3e0d8fb3 2005-12-27 devnull */
13 3e0d8fb3 2005-12-27 devnull DN *ht[HTLEN];
14 3e0d8fb3 2005-12-27 devnull
15 3e0d8fb3 2005-12-27 devnull
16 3e0d8fb3 2005-12-27 devnull static struct
17 3e0d8fb3 2005-12-27 devnull {
18 3e0d8fb3 2005-12-27 devnull Lock lk;
19 3e0d8fb3 2005-12-27 devnull ulong names; /* names allocated */
20 3e0d8fb3 2005-12-27 devnull ulong oldest; /* longest we'll leave a name around */
21 3e0d8fb3 2005-12-27 devnull int active;
22 3e0d8fb3 2005-12-27 devnull int mutex;
23 3e0d8fb3 2005-12-27 devnull int id;
24 3e0d8fb3 2005-12-27 devnull } dnvars;
25 3e0d8fb3 2005-12-27 devnull
26 3e0d8fb3 2005-12-27 devnull /* names of RR types */
27 3e0d8fb3 2005-12-27 devnull char *rrtname[] =
28 3e0d8fb3 2005-12-27 devnull {
29 3e0d8fb3 2005-12-27 devnull [Ta] "ip",
30 3e0d8fb3 2005-12-27 devnull [Tns] "ns",
31 3e0d8fb3 2005-12-27 devnull [Tmd] "md",
32 3e0d8fb3 2005-12-27 devnull [Tmf] "mf",
33 3e0d8fb3 2005-12-27 devnull [Tcname] "cname",
34 3e0d8fb3 2005-12-27 devnull [Tsoa] "soa",
35 3e0d8fb3 2005-12-27 devnull [Tmb] "mb",
36 3e0d8fb3 2005-12-27 devnull [Tmg] "mg",
37 3e0d8fb3 2005-12-27 devnull [Tmr] "mr",
38 3e0d8fb3 2005-12-27 devnull [Tnull] "null",
39 3e0d8fb3 2005-12-27 devnull [Twks] "wks",
40 3e0d8fb3 2005-12-27 devnull [Tptr] "ptr",
41 3e0d8fb3 2005-12-27 devnull [Thinfo] "hinfo",
42 3e0d8fb3 2005-12-27 devnull [Tminfo] "minfo",
43 3e0d8fb3 2005-12-27 devnull [Tmx] "mx",
44 3e0d8fb3 2005-12-27 devnull [Ttxt] "txt",
45 3e0d8fb3 2005-12-27 devnull [Trp] "rp",
46 3e0d8fb3 2005-12-27 devnull [Tkey] "key",
47 3e0d8fb3 2005-12-27 devnull [Tcert] "cert",
48 3e0d8fb3 2005-12-27 devnull [Tsig] "sig",
49 3e0d8fb3 2005-12-27 devnull [Taaaa] "ipv6",
50 3e0d8fb3 2005-12-27 devnull [Tixfr] "ixfr",
51 3e0d8fb3 2005-12-27 devnull [Taxfr] "axfr",
52 3e0d8fb3 2005-12-27 devnull [Tall] "all",
53 3e0d8fb3 2005-12-27 devnull 0,
54 3e0d8fb3 2005-12-27 devnull };
55 3e0d8fb3 2005-12-27 devnull
56 3e0d8fb3 2005-12-27 devnull /* names of response codes */
57 3e0d8fb3 2005-12-27 devnull char *rname[Rmask+1] =
58 3e0d8fb3 2005-12-27 devnull {
59 3e0d8fb3 2005-12-27 devnull [Rok] "ok",
60 3e0d8fb3 2005-12-27 devnull [Rformat] "format error",
61 3e0d8fb3 2005-12-27 devnull [Rserver] "server failure",
62 3e0d8fb3 2005-12-27 devnull [Rname] "bad name",
63 3e0d8fb3 2005-12-27 devnull [Runimplimented] "unimplemented",
64 3e0d8fb3 2005-12-27 devnull [Rrefused] "we don't like you",
65 3e0d8fb3 2005-12-27 devnull };
66 3e0d8fb3 2005-12-27 devnull
67 3e0d8fb3 2005-12-27 devnull /* names of op codes */
68 3e0d8fb3 2005-12-27 devnull char *opname[] =
69 3e0d8fb3 2005-12-27 devnull {
70 3e0d8fb3 2005-12-27 devnull [Oquery] "query",
71 3e0d8fb3 2005-12-27 devnull [Oinverse] "inverse",
72 3e0d8fb3 2005-12-27 devnull [Ostatus] "status",
73 3e0d8fb3 2005-12-27 devnull };
74 3e0d8fb3 2005-12-27 devnull
75 3e0d8fb3 2005-12-27 devnull Lock dnlock;
76 3e0d8fb3 2005-12-27 devnull
77 3e0d8fb3 2005-12-27 devnull static int sencodefmt(Fmt*);
78 3e0d8fb3 2005-12-27 devnull
79 3e0d8fb3 2005-12-27 devnull /*
80 3e0d8fb3 2005-12-27 devnull * set up a pipe to use as a lock
81 3e0d8fb3 2005-12-27 devnull */
82 3e0d8fb3 2005-12-27 devnull void
83 3e0d8fb3 2005-12-27 devnull dninit(void)
84 3e0d8fb3 2005-12-27 devnull {
85 3e0d8fb3 2005-12-27 devnull fmtinstall('E', eipfmt);
86 3e0d8fb3 2005-12-27 devnull fmtinstall('I', eipfmt);
87 3e0d8fb3 2005-12-27 devnull fmtinstall('V', eipfmt);
88 3e0d8fb3 2005-12-27 devnull fmtinstall('R', rrfmt);
89 3e0d8fb3 2005-12-27 devnull fmtinstall('Q', rravfmt);
90 3e0d8fb3 2005-12-27 devnull fmtinstall('H', sencodefmt);
91 3e0d8fb3 2005-12-27 devnull
92 3e0d8fb3 2005-12-27 devnull dnvars.oldest = maxage;
93 3e0d8fb3 2005-12-27 devnull dnvars.names = 0;
94 3e0d8fb3 2005-12-27 devnull }
95 3e0d8fb3 2005-12-27 devnull
96 3e0d8fb3 2005-12-27 devnull /*
97 3e0d8fb3 2005-12-27 devnull * hash for a domain name
98 3e0d8fb3 2005-12-27 devnull */
99 3e0d8fb3 2005-12-27 devnull static ulong
100 3e0d8fb3 2005-12-27 devnull dnhash(char *name)
101 3e0d8fb3 2005-12-27 devnull {
102 3e0d8fb3 2005-12-27 devnull ulong hash;
103 3e0d8fb3 2005-12-27 devnull uchar *val = (uchar*)name;
104 3e0d8fb3 2005-12-27 devnull
105 3e0d8fb3 2005-12-27 devnull for(hash = 0; *val; val++)
106 3e0d8fb3 2005-12-27 devnull hash = (hash*13) + tolower(*val)-'a';
107 3e0d8fb3 2005-12-27 devnull return hash % HTLEN;
108 3e0d8fb3 2005-12-27 devnull }
109 3e0d8fb3 2005-12-27 devnull
110 3e0d8fb3 2005-12-27 devnull /*
111 3e0d8fb3 2005-12-27 devnull * lookup a symbol. if enter is not zero and the name is
112 3e0d8fb3 2005-12-27 devnull * not found, create it.
113 3e0d8fb3 2005-12-27 devnull */
114 3e0d8fb3 2005-12-27 devnull DN*
115 3e0d8fb3 2005-12-27 devnull dnlookup(char *name, int class, int enter)
116 3e0d8fb3 2005-12-27 devnull {
117 3e0d8fb3 2005-12-27 devnull DN **l;
118 3e0d8fb3 2005-12-27 devnull DN *dp;
119 3e0d8fb3 2005-12-27 devnull
120 3e0d8fb3 2005-12-27 devnull l = &ht[dnhash(name)];
121 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
122 3e0d8fb3 2005-12-27 devnull for(dp = *l; dp; dp = dp->next) {
123 3e0d8fb3 2005-12-27 devnull assert(dp->magic == DNmagic);
124 3e0d8fb3 2005-12-27 devnull if(dp->class == class && cistrcmp(dp->name, name) == 0){
125 3e0d8fb3 2005-12-27 devnull dp->referenced = now;
126 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
127 3e0d8fb3 2005-12-27 devnull return dp;
128 3e0d8fb3 2005-12-27 devnull }
129 3e0d8fb3 2005-12-27 devnull l = &dp->next;
130 3e0d8fb3 2005-12-27 devnull }
131 3e0d8fb3 2005-12-27 devnull if(enter == 0){
132 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
133 3e0d8fb3 2005-12-27 devnull return 0;
134 3e0d8fb3 2005-12-27 devnull }
135 3e0d8fb3 2005-12-27 devnull dnvars.names++;
136 3e0d8fb3 2005-12-27 devnull dp = emalloc(sizeof(*dp));
137 3e0d8fb3 2005-12-27 devnull dp->magic = DNmagic;
138 3e0d8fb3 2005-12-27 devnull dp->name = estrdup(name);
139 3e0d8fb3 2005-12-27 devnull assert(dp->name != 0);
140 3e0d8fb3 2005-12-27 devnull dp->class = class;
141 3e0d8fb3 2005-12-27 devnull dp->rr = 0;
142 3e0d8fb3 2005-12-27 devnull dp->next = 0;
143 3e0d8fb3 2005-12-27 devnull dp->referenced = now;
144 3e0d8fb3 2005-12-27 devnull *l = dp;
145 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
146 3e0d8fb3 2005-12-27 devnull
147 3e0d8fb3 2005-12-27 devnull return dp;
148 3e0d8fb3 2005-12-27 devnull }
149 3e0d8fb3 2005-12-27 devnull
150 3e0d8fb3 2005-12-27 devnull /*
151 3e0d8fb3 2005-12-27 devnull * dump the cache
152 3e0d8fb3 2005-12-27 devnull */
153 3e0d8fb3 2005-12-27 devnull void
154 3e0d8fb3 2005-12-27 devnull dndump(char *file)
155 3e0d8fb3 2005-12-27 devnull {
156 3e0d8fb3 2005-12-27 devnull DN *dp;
157 3e0d8fb3 2005-12-27 devnull int i, fd;
158 3e0d8fb3 2005-12-27 devnull RR *rp;
159 3e0d8fb3 2005-12-27 devnull
160 3e0d8fb3 2005-12-27 devnull fd = open(file, OWRITE|OTRUNC);
161 3e0d8fb3 2005-12-27 devnull if(fd < 0)
162 3e0d8fb3 2005-12-27 devnull return;
163 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
164 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++){
165 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next){
166 3e0d8fb3 2005-12-27 devnull fprint(fd, "%s\n", dp->name);
167 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next)
168 3e0d8fb3 2005-12-27 devnull fprint(fd, " %R %c%c %lud/%lud\n", rp, rp->auth?'A':'U',
169 3e0d8fb3 2005-12-27 devnull rp->db?'D':'N', rp->expire, rp->ttl);
170 3e0d8fb3 2005-12-27 devnull }
171 3e0d8fb3 2005-12-27 devnull }
172 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
173 3e0d8fb3 2005-12-27 devnull close(fd);
174 3e0d8fb3 2005-12-27 devnull }
175 3e0d8fb3 2005-12-27 devnull
176 3e0d8fb3 2005-12-27 devnull /*
177 3e0d8fb3 2005-12-27 devnull * purge all records
178 3e0d8fb3 2005-12-27 devnull */
179 3e0d8fb3 2005-12-27 devnull void
180 3e0d8fb3 2005-12-27 devnull dnpurge(void)
181 3e0d8fb3 2005-12-27 devnull {
182 3e0d8fb3 2005-12-27 devnull DN *dp;
183 3e0d8fb3 2005-12-27 devnull RR *rp, *srp;
184 3e0d8fb3 2005-12-27 devnull int i;
185 3e0d8fb3 2005-12-27 devnull
186 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
187 3e0d8fb3 2005-12-27 devnull
188 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++)
189 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next){
190 3e0d8fb3 2005-12-27 devnull srp = rp = dp->rr;
191 3e0d8fb3 2005-12-27 devnull dp->rr = nil;
192 3e0d8fb3 2005-12-27 devnull for(; rp != nil; rp = rp->next)
193 3e0d8fb3 2005-12-27 devnull rp->cached = 0;
194 3e0d8fb3 2005-12-27 devnull rrfreelist(srp);
195 3e0d8fb3 2005-12-27 devnull }
196 3e0d8fb3 2005-12-27 devnull
197 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
198 3e0d8fb3 2005-12-27 devnull }
199 3e0d8fb3 2005-12-27 devnull
200 3e0d8fb3 2005-12-27 devnull /*
201 3e0d8fb3 2005-12-27 devnull * check the age of resource records, free any that have timed out
202 3e0d8fb3 2005-12-27 devnull */
203 3e0d8fb3 2005-12-27 devnull void
204 3e0d8fb3 2005-12-27 devnull dnage(DN *dp)
205 3e0d8fb3 2005-12-27 devnull {
206 3e0d8fb3 2005-12-27 devnull RR **l;
207 3e0d8fb3 2005-12-27 devnull RR *rp, *next;
208 3e0d8fb3 2005-12-27 devnull ulong diff;
209 3e0d8fb3 2005-12-27 devnull
210 3e0d8fb3 2005-12-27 devnull diff = now - dp->referenced;
211 3e0d8fb3 2005-12-27 devnull if(diff < Reserved)
212 3e0d8fb3 2005-12-27 devnull return;
213 3e0d8fb3 2005-12-27 devnull
214 3e0d8fb3 2005-12-27 devnull l = &dp->rr;
215 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = next){
216 3e0d8fb3 2005-12-27 devnull assert(rp->magic == RRmagic && rp->cached);
217 3e0d8fb3 2005-12-27 devnull next = rp->next;
218 3e0d8fb3 2005-12-27 devnull if(!rp->db)
219 3e0d8fb3 2005-12-27 devnull if(rp->expire < now || diff > dnvars.oldest){
220 3e0d8fb3 2005-12-27 devnull *l = next;
221 3e0d8fb3 2005-12-27 devnull rp->cached = 0;
222 3e0d8fb3 2005-12-27 devnull rrfree(rp);
223 3e0d8fb3 2005-12-27 devnull continue;
224 3e0d8fb3 2005-12-27 devnull }
225 3e0d8fb3 2005-12-27 devnull l = &rp->next;
226 3e0d8fb3 2005-12-27 devnull }
227 3e0d8fb3 2005-12-27 devnull }
228 3e0d8fb3 2005-12-27 devnull
229 3e0d8fb3 2005-12-27 devnull #define REF(x) if(x) x->refs++
230 3e0d8fb3 2005-12-27 devnull
231 3e0d8fb3 2005-12-27 devnull /*
232 3e0d8fb3 2005-12-27 devnull * our target is 4000 names cached, this should be larger on large servers
233 3e0d8fb3 2005-12-27 devnull */
234 3e0d8fb3 2005-12-27 devnull #define TARGET 4000
235 3e0d8fb3 2005-12-27 devnull
236 3e0d8fb3 2005-12-27 devnull /*
237 3e0d8fb3 2005-12-27 devnull * periodicly sweep for old records and remove unreferenced domain names
238 3e0d8fb3 2005-12-27 devnull *
239 3e0d8fb3 2005-12-27 devnull * only called when all other threads are locked out
240 3e0d8fb3 2005-12-27 devnull */
241 3e0d8fb3 2005-12-27 devnull void
242 3e0d8fb3 2005-12-27 devnull dnageall(int doit)
243 3e0d8fb3 2005-12-27 devnull {
244 3e0d8fb3 2005-12-27 devnull DN *dp, **l;
245 3e0d8fb3 2005-12-27 devnull int i;
246 3e0d8fb3 2005-12-27 devnull RR *rp;
247 3e0d8fb3 2005-12-27 devnull static ulong nextage;
248 3e0d8fb3 2005-12-27 devnull
249 3e0d8fb3 2005-12-27 devnull if(dnvars.names < TARGET && now < nextage && !doit){
250 3e0d8fb3 2005-12-27 devnull dnvars.oldest = maxage;
251 3e0d8fb3 2005-12-27 devnull return;
252 3e0d8fb3 2005-12-27 devnull }
253 3e0d8fb3 2005-12-27 devnull
254 3e0d8fb3 2005-12-27 devnull if(dnvars.names > TARGET)
255 3e0d8fb3 2005-12-27 devnull dnvars.oldest /= 2;
256 3e0d8fb3 2005-12-27 devnull nextage = now + maxage;
257 3e0d8fb3 2005-12-27 devnull
258 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
259 3e0d8fb3 2005-12-27 devnull
260 3e0d8fb3 2005-12-27 devnull /* time out all old entries (and set refs to 0) */
261 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++)
262 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next){
263 3e0d8fb3 2005-12-27 devnull dp->refs = 0;
264 3e0d8fb3 2005-12-27 devnull dnage(dp);
265 3e0d8fb3 2005-12-27 devnull }
266 3e0d8fb3 2005-12-27 devnull
267 3e0d8fb3 2005-12-27 devnull /* mark all referenced domain names */
268 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++)
269 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next)
270 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
271 3e0d8fb3 2005-12-27 devnull REF(rp->owner);
272 3e0d8fb3 2005-12-27 devnull if(rp->negative){
273 3e0d8fb3 2005-12-27 devnull REF(rp->negsoaowner);
274 3e0d8fb3 2005-12-27 devnull continue;
275 3e0d8fb3 2005-12-27 devnull }
276 3e0d8fb3 2005-12-27 devnull switch(rp->type){
277 3e0d8fb3 2005-12-27 devnull case Thinfo:
278 3e0d8fb3 2005-12-27 devnull REF(rp->cpu);
279 3e0d8fb3 2005-12-27 devnull REF(rp->os);
280 3e0d8fb3 2005-12-27 devnull break;
281 3e0d8fb3 2005-12-27 devnull case Ttxt:
282 3e0d8fb3 2005-12-27 devnull break;
283 3e0d8fb3 2005-12-27 devnull case Tcname:
284 3e0d8fb3 2005-12-27 devnull case Tmb:
285 3e0d8fb3 2005-12-27 devnull case Tmd:
286 3e0d8fb3 2005-12-27 devnull case Tmf:
287 3e0d8fb3 2005-12-27 devnull case Tns:
288 3e0d8fb3 2005-12-27 devnull REF(rp->host);
289 3e0d8fb3 2005-12-27 devnull break;
290 3e0d8fb3 2005-12-27 devnull case Tmg:
291 3e0d8fb3 2005-12-27 devnull case Tmr:
292 3e0d8fb3 2005-12-27 devnull REF(rp->mb);
293 3e0d8fb3 2005-12-27 devnull break;
294 3e0d8fb3 2005-12-27 devnull case Tminfo:
295 3e0d8fb3 2005-12-27 devnull REF(rp->rmb);
296 3e0d8fb3 2005-12-27 devnull REF(rp->mb);
297 3e0d8fb3 2005-12-27 devnull break;
298 3e0d8fb3 2005-12-27 devnull case Trp:
299 3e0d8fb3 2005-12-27 devnull REF(rp->rmb);
300 3e0d8fb3 2005-12-27 devnull REF(rp->rp);
301 3e0d8fb3 2005-12-27 devnull break;
302 3e0d8fb3 2005-12-27 devnull case Tmx:
303 3e0d8fb3 2005-12-27 devnull REF(rp->host);
304 3e0d8fb3 2005-12-27 devnull break;
305 3e0d8fb3 2005-12-27 devnull case Ta:
306 3e0d8fb3 2005-12-27 devnull case Taaaa:
307 3e0d8fb3 2005-12-27 devnull REF(rp->ip);
308 3e0d8fb3 2005-12-27 devnull break;
309 3e0d8fb3 2005-12-27 devnull case Tptr:
310 3e0d8fb3 2005-12-27 devnull REF(rp->ptr);
311 3e0d8fb3 2005-12-27 devnull break;
312 3e0d8fb3 2005-12-27 devnull case Tsoa:
313 3e0d8fb3 2005-12-27 devnull REF(rp->host);
314 3e0d8fb3 2005-12-27 devnull REF(rp->rmb);
315 3e0d8fb3 2005-12-27 devnull break;
316 3e0d8fb3 2005-12-27 devnull }
317 3e0d8fb3 2005-12-27 devnull }
318 3e0d8fb3 2005-12-27 devnull
319 3e0d8fb3 2005-12-27 devnull /* sweep and remove unreferenced domain names */
320 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++){
321 3e0d8fb3 2005-12-27 devnull l = &ht[i];
322 3e0d8fb3 2005-12-27 devnull for(dp = *l; dp; dp = *l){
323 3e0d8fb3 2005-12-27 devnull if(dp->rr == 0 && dp->refs == 0){
324 3e0d8fb3 2005-12-27 devnull assert(dp->magic == DNmagic);
325 3e0d8fb3 2005-12-27 devnull *l = dp->next;
326 3e0d8fb3 2005-12-27 devnull if(dp->name)
327 3e0d8fb3 2005-12-27 devnull free(dp->name);
328 3e0d8fb3 2005-12-27 devnull dp->magic = ~dp->magic;
329 3e0d8fb3 2005-12-27 devnull dnvars.names--;
330 3e0d8fb3 2005-12-27 devnull free(dp);
331 3e0d8fb3 2005-12-27 devnull continue;
332 3e0d8fb3 2005-12-27 devnull }
333 3e0d8fb3 2005-12-27 devnull l = &dp->next;
334 3e0d8fb3 2005-12-27 devnull }
335 3e0d8fb3 2005-12-27 devnull }
336 3e0d8fb3 2005-12-27 devnull
337 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
338 3e0d8fb3 2005-12-27 devnull }
339 3e0d8fb3 2005-12-27 devnull
340 3e0d8fb3 2005-12-27 devnull /*
341 3e0d8fb3 2005-12-27 devnull * timeout all database records (used when rereading db)
342 3e0d8fb3 2005-12-27 devnull */
343 3e0d8fb3 2005-12-27 devnull void
344 3e0d8fb3 2005-12-27 devnull dnagedb(void)
345 3e0d8fb3 2005-12-27 devnull {
346 3e0d8fb3 2005-12-27 devnull DN *dp;
347 3e0d8fb3 2005-12-27 devnull int i;
348 3e0d8fb3 2005-12-27 devnull RR *rp;
349 3e0d8fb3 2005-12-27 devnull static ulong nextage;
350 3e0d8fb3 2005-12-27 devnull
351 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
352 3e0d8fb3 2005-12-27 devnull
353 3e0d8fb3 2005-12-27 devnull /* time out all database entries */
354 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++)
355 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next)
356 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next)
357 3e0d8fb3 2005-12-27 devnull if(rp->db)
358 3e0d8fb3 2005-12-27 devnull rp->expire = 0;
359 3e0d8fb3 2005-12-27 devnull
360 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
361 3e0d8fb3 2005-12-27 devnull }
362 3e0d8fb3 2005-12-27 devnull
363 3e0d8fb3 2005-12-27 devnull /*
364 3e0d8fb3 2005-12-27 devnull * mark all local db records about my area as authoritative, time out any others
365 3e0d8fb3 2005-12-27 devnull */
366 3e0d8fb3 2005-12-27 devnull void
367 3e0d8fb3 2005-12-27 devnull dnauthdb(void)
368 3e0d8fb3 2005-12-27 devnull {
369 3e0d8fb3 2005-12-27 devnull DN *dp;
370 3e0d8fb3 2005-12-27 devnull int i;
371 3e0d8fb3 2005-12-27 devnull Area *area;
372 3e0d8fb3 2005-12-27 devnull RR *rp;
373 3e0d8fb3 2005-12-27 devnull static ulong nextage;
374 3e0d8fb3 2005-12-27 devnull
375 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
376 3e0d8fb3 2005-12-27 devnull
377 3e0d8fb3 2005-12-27 devnull /* time out all database entries */
378 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++)
379 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next){
380 3e0d8fb3 2005-12-27 devnull area = inmyarea(dp->name);
381 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next)
382 3e0d8fb3 2005-12-27 devnull if(rp->db){
383 3e0d8fb3 2005-12-27 devnull if(area){
384 3e0d8fb3 2005-12-27 devnull if(rp->ttl < area->soarr->soa->minttl)
385 3e0d8fb3 2005-12-27 devnull rp->ttl = area->soarr->soa->minttl;
386 3e0d8fb3 2005-12-27 devnull rp->auth = 1;
387 3e0d8fb3 2005-12-27 devnull }
388 3e0d8fb3 2005-12-27 devnull if(rp->expire == 0){
389 3e0d8fb3 2005-12-27 devnull rp->db = 0;
390 3e0d8fb3 2005-12-27 devnull dp->referenced = now - Reserved - 1;
391 3e0d8fb3 2005-12-27 devnull }
392 3e0d8fb3 2005-12-27 devnull }
393 3e0d8fb3 2005-12-27 devnull }
394 3e0d8fb3 2005-12-27 devnull
395 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
396 3e0d8fb3 2005-12-27 devnull }
397 3e0d8fb3 2005-12-27 devnull
398 3e0d8fb3 2005-12-27 devnull /*
399 3e0d8fb3 2005-12-27 devnull * keep track of other processes to know if we can
400 3e0d8fb3 2005-12-27 devnull * garbage collect. block while garbage collecting.
401 3e0d8fb3 2005-12-27 devnull */
402 3e0d8fb3 2005-12-27 devnull int
403 3e0d8fb3 2005-12-27 devnull getactivity(Request *req)
404 3e0d8fb3 2005-12-27 devnull {
405 3e0d8fb3 2005-12-27 devnull int rv;
406 3e0d8fb3 2005-12-27 devnull
407 3e0d8fb3 2005-12-27 devnull if(traceactivity) syslog(0, "dns", "get %d by %d", dnvars.active, getpid());
408 3e0d8fb3 2005-12-27 devnull lock(&dnvars.lk);
409 3e0d8fb3 2005-12-27 devnull while(dnvars.mutex){
410 3e0d8fb3 2005-12-27 devnull unlock(&dnvars.lk);
411 3e0d8fb3 2005-12-27 devnull sleep(200);
412 3e0d8fb3 2005-12-27 devnull lock(&dnvars.lk);
413 3e0d8fb3 2005-12-27 devnull }
414 3e0d8fb3 2005-12-27 devnull rv = ++dnvars.active;
415 3e0d8fb3 2005-12-27 devnull now = time(0);
416 3e0d8fb3 2005-12-27 devnull req->id = ++dnvars.id;
417 3e0d8fb3 2005-12-27 devnull unlock(&dnvars.lk);
418 3e0d8fb3 2005-12-27 devnull
419 3e0d8fb3 2005-12-27 devnull return rv;
420 3e0d8fb3 2005-12-27 devnull }
421 3e0d8fb3 2005-12-27 devnull void
422 3e0d8fb3 2005-12-27 devnull putactivity(void)
423 3e0d8fb3 2005-12-27 devnull {
424 3e0d8fb3 2005-12-27 devnull static ulong lastclean;
425 3e0d8fb3 2005-12-27 devnull
426 3e0d8fb3 2005-12-27 devnull if(traceactivity) syslog(0, "dns", "put %d by %d", dnvars.active, getpid());
427 3e0d8fb3 2005-12-27 devnull lock(&dnvars.lk);
428 3e0d8fb3 2005-12-27 devnull dnvars.active--;
429 3e0d8fb3 2005-12-27 devnull assert(dnvars.active >= 0); /* "dnvars.active %d", dnvars.active */;
430 3e0d8fb3 2005-12-27 devnull
431 3e0d8fb3 2005-12-27 devnull /*
432 3e0d8fb3 2005-12-27 devnull * clean out old entries and check for new db periodicly
433 3e0d8fb3 2005-12-27 devnull */
434 3e0d8fb3 2005-12-27 devnull if(dnvars.mutex || (needrefresh == 0 && dnvars.active > 0)){
435 3e0d8fb3 2005-12-27 devnull unlock(&dnvars.lk);
436 3e0d8fb3 2005-12-27 devnull return;
437 3e0d8fb3 2005-12-27 devnull }
438 3e0d8fb3 2005-12-27 devnull
439 3e0d8fb3 2005-12-27 devnull /* wait till we're alone */
440 3e0d8fb3 2005-12-27 devnull dnvars.mutex = 1;
441 3e0d8fb3 2005-12-27 devnull while(dnvars.active > 0){
442 3e0d8fb3 2005-12-27 devnull unlock(&dnvars.lk);
443 3e0d8fb3 2005-12-27 devnull sleep(100);
444 3e0d8fb3 2005-12-27 devnull lock(&dnvars.lk);
445 3e0d8fb3 2005-12-27 devnull }
446 3e0d8fb3 2005-12-27 devnull unlock(&dnvars.lk);
447 3e0d8fb3 2005-12-27 devnull
448 3e0d8fb3 2005-12-27 devnull db2cache(needrefresh);
449 3e0d8fb3 2005-12-27 devnull dnageall(0);
450 3e0d8fb3 2005-12-27 devnull
451 3e0d8fb3 2005-12-27 devnull /* let others back in */
452 3e0d8fb3 2005-12-27 devnull lastclean = now;
453 3e0d8fb3 2005-12-27 devnull needrefresh = 0;
454 3e0d8fb3 2005-12-27 devnull dnvars.mutex = 0;
455 3e0d8fb3 2005-12-27 devnull }
456 3e0d8fb3 2005-12-27 devnull
457 3e0d8fb3 2005-12-27 devnull /*
458 3e0d8fb3 2005-12-27 devnull * Attach a single resource record to a domain name.
459 3e0d8fb3 2005-12-27 devnull * - Avoid duplicates with already present RR's
460 3e0d8fb3 2005-12-27 devnull * - Chain all RR's of the same type adjacent to one another
461 3e0d8fb3 2005-12-27 devnull * - chain authoritative RR's ahead of non-authoritative ones
462 3e0d8fb3 2005-12-27 devnull */
463 3e0d8fb3 2005-12-27 devnull static void
464 3e0d8fb3 2005-12-27 devnull rrattach1(RR *new, int auth)
465 3e0d8fb3 2005-12-27 devnull {
466 3e0d8fb3 2005-12-27 devnull RR **l;
467 3e0d8fb3 2005-12-27 devnull RR *rp;
468 3e0d8fb3 2005-12-27 devnull DN *dp;
469 3e0d8fb3 2005-12-27 devnull
470 3e0d8fb3 2005-12-27 devnull assert(new->magic == RRmagic && !new->cached);
471 3e0d8fb3 2005-12-27 devnull
472 3e0d8fb3 2005-12-27 devnull if(!new->db)
473 3e0d8fb3 2005-12-27 devnull new->expire = new->ttl;
474 3e0d8fb3 2005-12-27 devnull else
475 3e0d8fb3 2005-12-27 devnull new->expire = now + Year;
476 3e0d8fb3 2005-12-27 devnull dp = new->owner;
477 3e0d8fb3 2005-12-27 devnull assert(dp->magic == DNmagic);
478 3e0d8fb3 2005-12-27 devnull new->auth |= auth;
479 3e0d8fb3 2005-12-27 devnull new->next = 0;
480 3e0d8fb3 2005-12-27 devnull
481 3e0d8fb3 2005-12-27 devnull /*
482 3e0d8fb3 2005-12-27 devnull * find first rr of the right type
483 3e0d8fb3 2005-12-27 devnull */
484 3e0d8fb3 2005-12-27 devnull l = &dp->rr;
485 3e0d8fb3 2005-12-27 devnull for(rp = *l; rp; rp = *l){
486 3e0d8fb3 2005-12-27 devnull assert(rp->magic == RRmagic && rp->cached);
487 3e0d8fb3 2005-12-27 devnull if(rp->type == new->type)
488 3e0d8fb3 2005-12-27 devnull break;
489 3e0d8fb3 2005-12-27 devnull l = &rp->next;
490 3e0d8fb3 2005-12-27 devnull }
491 3e0d8fb3 2005-12-27 devnull
492 3e0d8fb3 2005-12-27 devnull /*
493 3e0d8fb3 2005-12-27 devnull * negative entries replace positive entries
494 3e0d8fb3 2005-12-27 devnull * positive entries replace negative entries
495 3e0d8fb3 2005-12-27 devnull * newer entries replace older entries with the same fields
496 3e0d8fb3 2005-12-27 devnull */
497 3e0d8fb3 2005-12-27 devnull for(rp = *l; rp; rp = *l){
498 3e0d8fb3 2005-12-27 devnull assert(rp->magic == RRmagic && rp->cached);
499 3e0d8fb3 2005-12-27 devnull if(rp->type != new->type)
500 3e0d8fb3 2005-12-27 devnull break;
501 3e0d8fb3 2005-12-27 devnull
502 3e0d8fb3 2005-12-27 devnull if(rp->db == new->db && rp->auth == new->auth){
503 3e0d8fb3 2005-12-27 devnull /* negative drives out positive and vice versa */
504 3e0d8fb3 2005-12-27 devnull if(rp->negative != new->negative){
505 3e0d8fb3 2005-12-27 devnull *l = rp->next;
506 3e0d8fb3 2005-12-27 devnull rp->cached = 0;
507 3e0d8fb3 2005-12-27 devnull rrfree(rp);
508 3e0d8fb3 2005-12-27 devnull continue;
509 3e0d8fb3 2005-12-27 devnull }
510 3e0d8fb3 2005-12-27 devnull
511 3e0d8fb3 2005-12-27 devnull /* all things equal, pick the newer one */
512 3e0d8fb3 2005-12-27 devnull if(rp->arg0 == new->arg0 && rp->arg1 == new->arg1){
513 3e0d8fb3 2005-12-27 devnull /* new drives out old */
514 3e0d8fb3 2005-12-27 devnull if(new->ttl > rp->ttl || new->expire > rp->expire){
515 3e0d8fb3 2005-12-27 devnull *l = rp->next;
516 3e0d8fb3 2005-12-27 devnull rp->cached = 0;
517 3e0d8fb3 2005-12-27 devnull rrfree(rp);
518 3e0d8fb3 2005-12-27 devnull continue;
519 3e0d8fb3 2005-12-27 devnull } else {
520 3e0d8fb3 2005-12-27 devnull rrfree(new);
521 3e0d8fb3 2005-12-27 devnull return;
522 3e0d8fb3 2005-12-27 devnull }
523 3e0d8fb3 2005-12-27 devnull }
524 3e0d8fb3 2005-12-27 devnull
525 3e0d8fb3 2005-12-27 devnull /* Hack for pointer records. This makes sure
526 3e0d8fb3 2005-12-27 devnull * the ordering in the list reflects the ordering
527 3e0d8fb3 2005-12-27 devnull * received or read from the database
528 3e0d8fb3 2005-12-27 devnull */
529 3e0d8fb3 2005-12-27 devnull if(rp->type == Tptr){
530 3e0d8fb3 2005-12-27 devnull if(!rp->negative && !new->negative
531 3e0d8fb3 2005-12-27 devnull && rp->ptr->ordinal > new->ptr->ordinal)
532 3e0d8fb3 2005-12-27 devnull break;
533 3e0d8fb3 2005-12-27 devnull }
534 3e0d8fb3 2005-12-27 devnull }
535 3e0d8fb3 2005-12-27 devnull l = &rp->next;
536 3e0d8fb3 2005-12-27 devnull }
537 3e0d8fb3 2005-12-27 devnull
538 3e0d8fb3 2005-12-27 devnull /*
539 3e0d8fb3 2005-12-27 devnull * add to chain
540 3e0d8fb3 2005-12-27 devnull */
541 3e0d8fb3 2005-12-27 devnull new->cached = 1;
542 3e0d8fb3 2005-12-27 devnull new->next = *l;
543 3e0d8fb3 2005-12-27 devnull *l = new;
544 3e0d8fb3 2005-12-27 devnull }
545 3e0d8fb3 2005-12-27 devnull
546 3e0d8fb3 2005-12-27 devnull /*
547 3e0d8fb3 2005-12-27 devnull * Attach a list of resource records to a domain name.
548 3e0d8fb3 2005-12-27 devnull * - Avoid duplicates with already present RR's
549 3e0d8fb3 2005-12-27 devnull * - Chain all RR's of the same type adjacent to one another
550 3e0d8fb3 2005-12-27 devnull * - chain authoritative RR's ahead of non-authoritative ones
551 3e0d8fb3 2005-12-27 devnull * - remove any expired RR's
552 3e0d8fb3 2005-12-27 devnull */
553 3e0d8fb3 2005-12-27 devnull void
554 3e0d8fb3 2005-12-27 devnull rrattach(RR *rp, int auth)
555 3e0d8fb3 2005-12-27 devnull {
556 3e0d8fb3 2005-12-27 devnull RR *next;
557 3e0d8fb3 2005-12-27 devnull
558 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
559 3e0d8fb3 2005-12-27 devnull for(; rp; rp = next){
560 3e0d8fb3 2005-12-27 devnull next = rp->next;
561 3e0d8fb3 2005-12-27 devnull rp->next = 0;
562 3e0d8fb3 2005-12-27 devnull
563 3e0d8fb3 2005-12-27 devnull /* avoid any outside spoofing */
564 3e0d8fb3 2005-12-27 devnull if(cachedb && !rp->db && inmyarea(rp->owner->name))
565 3e0d8fb3 2005-12-27 devnull rrfree(rp);
566 3e0d8fb3 2005-12-27 devnull else
567 3e0d8fb3 2005-12-27 devnull rrattach1(rp, auth);
568 3e0d8fb3 2005-12-27 devnull }
569 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
570 3e0d8fb3 2005-12-27 devnull }
571 3e0d8fb3 2005-12-27 devnull
572 3e0d8fb3 2005-12-27 devnull /*
573 3e0d8fb3 2005-12-27 devnull * allocate a resource record of a given type
574 3e0d8fb3 2005-12-27 devnull */
575 3e0d8fb3 2005-12-27 devnull RR*
576 3e0d8fb3 2005-12-27 devnull rralloc(int type)
577 3e0d8fb3 2005-12-27 devnull {
578 3e0d8fb3 2005-12-27 devnull RR *rp;
579 3e0d8fb3 2005-12-27 devnull
580 3e0d8fb3 2005-12-27 devnull rp = emalloc(sizeof(*rp));
581 3e0d8fb3 2005-12-27 devnull rp->magic = RRmagic;
582 3e0d8fb3 2005-12-27 devnull rp->pc = getcallerpc(&type);
583 3e0d8fb3 2005-12-27 devnull rp->type = type;
584 3e0d8fb3 2005-12-27 devnull switch(type){
585 3e0d8fb3 2005-12-27 devnull case Tsoa:
586 3e0d8fb3 2005-12-27 devnull rp->soa = emalloc(sizeof(*rp->soa));
587 3e0d8fb3 2005-12-27 devnull rp->soa->slaves = nil;
588 3e0d8fb3 2005-12-27 devnull break;
589 3e0d8fb3 2005-12-27 devnull case Tkey:
590 3e0d8fb3 2005-12-27 devnull rp->key = emalloc(sizeof(*rp->key));
591 3e0d8fb3 2005-12-27 devnull break;
592 3e0d8fb3 2005-12-27 devnull case Tcert:
593 3e0d8fb3 2005-12-27 devnull rp->cert = emalloc(sizeof(*rp->cert));
594 3e0d8fb3 2005-12-27 devnull break;
595 3e0d8fb3 2005-12-27 devnull case Tsig:
596 3e0d8fb3 2005-12-27 devnull rp->sig = emalloc(sizeof(*rp->sig));
597 3e0d8fb3 2005-12-27 devnull break;
598 3e0d8fb3 2005-12-27 devnull case Tnull:
599 3e0d8fb3 2005-12-27 devnull rp->null = emalloc(sizeof(*rp->null));
600 3e0d8fb3 2005-12-27 devnull break;
601 3e0d8fb3 2005-12-27 devnull }
602 3e0d8fb3 2005-12-27 devnull rp->ttl = 0;
603 3e0d8fb3 2005-12-27 devnull rp->expire = 0;
604 3e0d8fb3 2005-12-27 devnull rp->next = 0;
605 3e0d8fb3 2005-12-27 devnull return rp;
606 3e0d8fb3 2005-12-27 devnull }
607 3e0d8fb3 2005-12-27 devnull
608 3e0d8fb3 2005-12-27 devnull /*
609 3e0d8fb3 2005-12-27 devnull * free a resource record and any related structs
610 3e0d8fb3 2005-12-27 devnull */
611 3e0d8fb3 2005-12-27 devnull void
612 3e0d8fb3 2005-12-27 devnull rrfree(RR *rp)
613 3e0d8fb3 2005-12-27 devnull {
614 3e0d8fb3 2005-12-27 devnull DN *dp;
615 3e0d8fb3 2005-12-27 devnull RR *nrp;
616 3e0d8fb3 2005-12-27 devnull Txt *t;
617 3e0d8fb3 2005-12-27 devnull
618 3e0d8fb3 2005-12-27 devnull assert(rp->magic = RRmagic);
619 3e0d8fb3 2005-12-27 devnull assert(!rp->cached);
620 3e0d8fb3 2005-12-27 devnull
621 3e0d8fb3 2005-12-27 devnull dp = rp->owner;
622 3e0d8fb3 2005-12-27 devnull if(dp){
623 3e0d8fb3 2005-12-27 devnull assert(dp->magic == DNmagic);
624 3e0d8fb3 2005-12-27 devnull for(nrp = dp->rr; nrp; nrp = nrp->next)
625 3e0d8fb3 2005-12-27 devnull assert(nrp != rp); /* "rrfree of live rr" */;
626 3e0d8fb3 2005-12-27 devnull }
627 3e0d8fb3 2005-12-27 devnull
628 3e0d8fb3 2005-12-27 devnull switch(rp->type){
629 3e0d8fb3 2005-12-27 devnull case Tsoa:
630 3e0d8fb3 2005-12-27 devnull freeserverlist(rp->soa->slaves);
631 3e0d8fb3 2005-12-27 devnull free(rp->soa);
632 3e0d8fb3 2005-12-27 devnull break;
633 3e0d8fb3 2005-12-27 devnull case Tkey:
634 3e0d8fb3 2005-12-27 devnull free(rp->key->data);
635 3e0d8fb3 2005-12-27 devnull free(rp->key);
636 3e0d8fb3 2005-12-27 devnull break;
637 3e0d8fb3 2005-12-27 devnull case Tcert:
638 3e0d8fb3 2005-12-27 devnull free(rp->cert->data);
639 3e0d8fb3 2005-12-27 devnull free(rp->cert);
640 3e0d8fb3 2005-12-27 devnull break;
641 3e0d8fb3 2005-12-27 devnull case Tsig:
642 3e0d8fb3 2005-12-27 devnull free(rp->sig->data);
643 3e0d8fb3 2005-12-27 devnull free(rp->sig);
644 3e0d8fb3 2005-12-27 devnull break;
645 3e0d8fb3 2005-12-27 devnull case Tnull:
646 3e0d8fb3 2005-12-27 devnull free(rp->null->data);
647 3e0d8fb3 2005-12-27 devnull free(rp->null);
648 3e0d8fb3 2005-12-27 devnull break;
649 3e0d8fb3 2005-12-27 devnull case Ttxt:
650 3e0d8fb3 2005-12-27 devnull while(rp->txt != nil){
651 3e0d8fb3 2005-12-27 devnull t = rp->txt;
652 3e0d8fb3 2005-12-27 devnull rp->txt = t->next;
653 3e0d8fb3 2005-12-27 devnull free(t->p);
654 3e0d8fb3 2005-12-27 devnull free(t);
655 3e0d8fb3 2005-12-27 devnull }
656 3e0d8fb3 2005-12-27 devnull break;
657 3e0d8fb3 2005-12-27 devnull }
658 3e0d8fb3 2005-12-27 devnull
659 3e0d8fb3 2005-12-27 devnull rp->magic = ~rp->magic;
660 3e0d8fb3 2005-12-27 devnull free(rp);
661 3e0d8fb3 2005-12-27 devnull }
662 3e0d8fb3 2005-12-27 devnull
663 3e0d8fb3 2005-12-27 devnull /*
664 3e0d8fb3 2005-12-27 devnull * free a list of resource records and any related structs
665 3e0d8fb3 2005-12-27 devnull */
666 3e0d8fb3 2005-12-27 devnull void
667 3e0d8fb3 2005-12-27 devnull rrfreelist(RR *rp)
668 3e0d8fb3 2005-12-27 devnull {
669 3e0d8fb3 2005-12-27 devnull RR *next;
670 3e0d8fb3 2005-12-27 devnull
671 3e0d8fb3 2005-12-27 devnull for(; rp; rp = next){
672 3e0d8fb3 2005-12-27 devnull next = rp->next;
673 3e0d8fb3 2005-12-27 devnull rrfree(rp);
674 3e0d8fb3 2005-12-27 devnull }
675 3e0d8fb3 2005-12-27 devnull }
676 3e0d8fb3 2005-12-27 devnull
677 3e0d8fb3 2005-12-27 devnull extern RR**
678 3e0d8fb3 2005-12-27 devnull rrcopy(RR *rp, RR **last)
679 3e0d8fb3 2005-12-27 devnull {
680 3e0d8fb3 2005-12-27 devnull RR *nrp;
681 3e0d8fb3 2005-12-27 devnull SOA *soa;
682 3e0d8fb3 2005-12-27 devnull Key *key;
683 3e0d8fb3 2005-12-27 devnull Cert *cert;
684 3e0d8fb3 2005-12-27 devnull Sig *sig;
685 3e0d8fb3 2005-12-27 devnull Null *null;
686 3e0d8fb3 2005-12-27 devnull Txt *t, *nt, **l;
687 3e0d8fb3 2005-12-27 devnull
688 3e0d8fb3 2005-12-27 devnull nrp = rralloc(rp->type);
689 3e0d8fb3 2005-12-27 devnull switch(rp->type){
690 3e0d8fb3 2005-12-27 devnull case Ttxt:
691 3e0d8fb3 2005-12-27 devnull *nrp = *rp;
692 3e0d8fb3 2005-12-27 devnull l = &nrp->txt;
693 3e0d8fb3 2005-12-27 devnull *l = nil;
694 3e0d8fb3 2005-12-27 devnull for(t = rp->txt; t != nil; t = t->next){
695 3e0d8fb3 2005-12-27 devnull nt = emalloc(sizeof(*nt));
696 3e0d8fb3 2005-12-27 devnull nt->p = estrdup(t->p);
697 3e0d8fb3 2005-12-27 devnull nt->next = nil;
698 3e0d8fb3 2005-12-27 devnull *l = nt;
699 3e0d8fb3 2005-12-27 devnull l = &nt->next;
700 3e0d8fb3 2005-12-27 devnull }
701 3e0d8fb3 2005-12-27 devnull break;
702 3e0d8fb3 2005-12-27 devnull case Tsoa:
703 3e0d8fb3 2005-12-27 devnull soa = nrp->soa;
704 3e0d8fb3 2005-12-27 devnull *nrp = *rp;
705 3e0d8fb3 2005-12-27 devnull nrp->soa = soa;
706 3e0d8fb3 2005-12-27 devnull *nrp->soa = *rp->soa;
707 3e0d8fb3 2005-12-27 devnull nrp->soa->slaves = copyserverlist(rp->soa->slaves);
708 3e0d8fb3 2005-12-27 devnull break;
709 3e0d8fb3 2005-12-27 devnull case Tkey:
710 3e0d8fb3 2005-12-27 devnull key = nrp->key;
711 3e0d8fb3 2005-12-27 devnull *nrp = *rp;
712 3e0d8fb3 2005-12-27 devnull nrp->key = key;
713 3e0d8fb3 2005-12-27 devnull *key = *rp->key;
714 3e0d8fb3 2005-12-27 devnull key->data = emalloc(key->dlen);
715 3e0d8fb3 2005-12-27 devnull memmove(key->data, rp->key->data, rp->key->dlen);
716 3e0d8fb3 2005-12-27 devnull break;
717 3e0d8fb3 2005-12-27 devnull case Tsig:
718 3e0d8fb3 2005-12-27 devnull sig = nrp->sig;
719 3e0d8fb3 2005-12-27 devnull *nrp = *rp;
720 3e0d8fb3 2005-12-27 devnull nrp->sig = sig;
721 3e0d8fb3 2005-12-27 devnull *sig = *rp->sig;
722 3e0d8fb3 2005-12-27 devnull sig->data = emalloc(sig->dlen);
723 3e0d8fb3 2005-12-27 devnull memmove(sig->data, rp->sig->data, rp->sig->dlen);
724 3e0d8fb3 2005-12-27 devnull break;
725 3e0d8fb3 2005-12-27 devnull case Tcert:
726 3e0d8fb3 2005-12-27 devnull cert = nrp->cert;
727 3e0d8fb3 2005-12-27 devnull *nrp = *rp;
728 3e0d8fb3 2005-12-27 devnull nrp->cert = cert;
729 3e0d8fb3 2005-12-27 devnull *cert = *rp->cert;
730 3e0d8fb3 2005-12-27 devnull cert->data = emalloc(cert->dlen);
731 3e0d8fb3 2005-12-27 devnull memmove(cert->data, rp->cert->data, rp->cert->dlen);
732 3e0d8fb3 2005-12-27 devnull break;
733 3e0d8fb3 2005-12-27 devnull case Tnull:
734 3e0d8fb3 2005-12-27 devnull null = nrp->null;
735 3e0d8fb3 2005-12-27 devnull *nrp = *rp;
736 3e0d8fb3 2005-12-27 devnull nrp->null = null;
737 3e0d8fb3 2005-12-27 devnull *null = *rp->null;
738 3e0d8fb3 2005-12-27 devnull null->data = emalloc(null->dlen);
739 3e0d8fb3 2005-12-27 devnull memmove(null->data, rp->null->data, rp->null->dlen);
740 3e0d8fb3 2005-12-27 devnull break;
741 3e0d8fb3 2005-12-27 devnull default:
742 3e0d8fb3 2005-12-27 devnull *nrp = *rp;
743 3e0d8fb3 2005-12-27 devnull break;
744 3e0d8fb3 2005-12-27 devnull }
745 3e0d8fb3 2005-12-27 devnull nrp->cached = 0;
746 3e0d8fb3 2005-12-27 devnull nrp->next = 0;
747 3e0d8fb3 2005-12-27 devnull *last = nrp;
748 3e0d8fb3 2005-12-27 devnull return &nrp->next;
749 3e0d8fb3 2005-12-27 devnull }
750 3e0d8fb3 2005-12-27 devnull
751 3e0d8fb3 2005-12-27 devnull /*
752 3e0d8fb3 2005-12-27 devnull * lookup a resource record of a particular type and
753 3e0d8fb3 2005-12-27 devnull * class attached to a domain name. Return copies.
754 3e0d8fb3 2005-12-27 devnull *
755 3e0d8fb3 2005-12-27 devnull * Priority ordering is:
756 3e0d8fb3 2005-12-27 devnull * db authoritative
757 3e0d8fb3 2005-12-27 devnull * not timed out network authoritative
758 3e0d8fb3 2005-12-27 devnull * not timed out network unauthoritative
759 3e0d8fb3 2005-12-27 devnull * unauthoritative db
760 3e0d8fb3 2005-12-27 devnull *
761 3e0d8fb3 2005-12-27 devnull * if flag NOneg is set, don't return negative cached entries.
762 3e0d8fb3 2005-12-27 devnull * return nothing instead.
763 3e0d8fb3 2005-12-27 devnull */
764 3e0d8fb3 2005-12-27 devnull RR*
765 3e0d8fb3 2005-12-27 devnull rrlookup(DN *dp, int type, int flag)
766 3e0d8fb3 2005-12-27 devnull {
767 3e0d8fb3 2005-12-27 devnull RR *rp, *first, **last;
768 3e0d8fb3 2005-12-27 devnull
769 3e0d8fb3 2005-12-27 devnull assert(dp->magic == DNmagic);
770 3e0d8fb3 2005-12-27 devnull
771 3e0d8fb3 2005-12-27 devnull first = 0;
772 3e0d8fb3 2005-12-27 devnull last = &first;
773 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
774 3e0d8fb3 2005-12-27 devnull
775 3e0d8fb3 2005-12-27 devnull /* try for an authoritative db entry */
776 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
777 3e0d8fb3 2005-12-27 devnull assert(rp->magic == RRmagic && rp->cached);
778 3e0d8fb3 2005-12-27 devnull if(rp->db)
779 3e0d8fb3 2005-12-27 devnull if(rp->auth)
780 3e0d8fb3 2005-12-27 devnull if(tsame(type, rp->type))
781 3e0d8fb3 2005-12-27 devnull last = rrcopy(rp, last);
782 3e0d8fb3 2005-12-27 devnull }
783 3e0d8fb3 2005-12-27 devnull if(first)
784 3e0d8fb3 2005-12-27 devnull goto out;
785 3e0d8fb3 2005-12-27 devnull
786 3e0d8fb3 2005-12-27 devnull /* try for an living authoritative network entry */
787 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
788 3e0d8fb3 2005-12-27 devnull if(!rp->db)
789 3e0d8fb3 2005-12-27 devnull if(rp->auth)
790 3e0d8fb3 2005-12-27 devnull if(rp->ttl + 60 > now)
791 3e0d8fb3 2005-12-27 devnull if(tsame(type, rp->type)){
792 3e0d8fb3 2005-12-27 devnull if(flag == NOneg && rp->negative)
793 3e0d8fb3 2005-12-27 devnull goto out;
794 3e0d8fb3 2005-12-27 devnull last = rrcopy(rp, last);
795 3e0d8fb3 2005-12-27 devnull }
796 3e0d8fb3 2005-12-27 devnull }
797 3e0d8fb3 2005-12-27 devnull if(first)
798 3e0d8fb3 2005-12-27 devnull goto out;
799 3e0d8fb3 2005-12-27 devnull
800 3e0d8fb3 2005-12-27 devnull /* try for an living unauthoritative network entry */
801 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
802 3e0d8fb3 2005-12-27 devnull if(!rp->db)
803 3e0d8fb3 2005-12-27 devnull if(rp->ttl + 60 > now)
804 3e0d8fb3 2005-12-27 devnull if(tsame(type, rp->type)){
805 3e0d8fb3 2005-12-27 devnull if(flag == NOneg && rp->negative)
806 3e0d8fb3 2005-12-27 devnull goto out;
807 3e0d8fb3 2005-12-27 devnull last = rrcopy(rp, last);
808 3e0d8fb3 2005-12-27 devnull }
809 3e0d8fb3 2005-12-27 devnull }
810 3e0d8fb3 2005-12-27 devnull if(first)
811 3e0d8fb3 2005-12-27 devnull goto out;
812 3e0d8fb3 2005-12-27 devnull
813 3e0d8fb3 2005-12-27 devnull /* try for an unauthoritative db entry */
814 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
815 3e0d8fb3 2005-12-27 devnull if(rp->db)
816 3e0d8fb3 2005-12-27 devnull if(tsame(type, rp->type))
817 3e0d8fb3 2005-12-27 devnull last = rrcopy(rp, last);
818 3e0d8fb3 2005-12-27 devnull }
819 3e0d8fb3 2005-12-27 devnull if(first)
820 3e0d8fb3 2005-12-27 devnull goto out;
821 3e0d8fb3 2005-12-27 devnull
822 3e0d8fb3 2005-12-27 devnull /* otherwise, settle for anything we got (except for negative caches) */
823 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
824 3e0d8fb3 2005-12-27 devnull if(tsame(type, rp->type)){
825 3e0d8fb3 2005-12-27 devnull if(rp->negative)
826 3e0d8fb3 2005-12-27 devnull goto out;
827 3e0d8fb3 2005-12-27 devnull last = rrcopy(rp, last);
828 3e0d8fb3 2005-12-27 devnull }
829 3e0d8fb3 2005-12-27 devnull }
830 3e0d8fb3 2005-12-27 devnull
831 3e0d8fb3 2005-12-27 devnull out:
832 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
833 3e0d8fb3 2005-12-27 devnull unique(first);
834 3e0d8fb3 2005-12-27 devnull return first;
835 3e0d8fb3 2005-12-27 devnull }
836 3e0d8fb3 2005-12-27 devnull
837 3e0d8fb3 2005-12-27 devnull /*
838 3e0d8fb3 2005-12-27 devnull * convert an ascii RR type name to its integer representation
839 3e0d8fb3 2005-12-27 devnull */
840 3e0d8fb3 2005-12-27 devnull int
841 3e0d8fb3 2005-12-27 devnull rrtype(char *atype)
842 3e0d8fb3 2005-12-27 devnull {
843 3e0d8fb3 2005-12-27 devnull int i;
844 3e0d8fb3 2005-12-27 devnull
845 3e0d8fb3 2005-12-27 devnull for(i = 0; i <= Tall; i++)
846 3e0d8fb3 2005-12-27 devnull if(rrtname[i] && strcmp(rrtname[i], atype) == 0)
847 3e0d8fb3 2005-12-27 devnull return i;
848 3e0d8fb3 2005-12-27 devnull
849 3e0d8fb3 2005-12-27 devnull // make any a synonym for all
850 3e0d8fb3 2005-12-27 devnull if(strcmp(atype, "any") == 0)
851 3e0d8fb3 2005-12-27 devnull return Tall;
852 3e0d8fb3 2005-12-27 devnull return atoi(atype);
853 3e0d8fb3 2005-12-27 devnull }
854 3e0d8fb3 2005-12-27 devnull
855 3e0d8fb3 2005-12-27 devnull /*
856 3e0d8fb3 2005-12-27 devnull * convert an integer RR type to it's ascii name
857 3e0d8fb3 2005-12-27 devnull */
858 3e0d8fb3 2005-12-27 devnull char*
859 3e0d8fb3 2005-12-27 devnull rrname(int type, char *buf, int len)
860 3e0d8fb3 2005-12-27 devnull {
861 3e0d8fb3 2005-12-27 devnull char *t;
862 3e0d8fb3 2005-12-27 devnull
863 3e0d8fb3 2005-12-27 devnull t = 0;
864 3e0d8fb3 2005-12-27 devnull if(type <= Tall)
865 3e0d8fb3 2005-12-27 devnull t = rrtname[type];
866 3e0d8fb3 2005-12-27 devnull if(t==0){
867 3e0d8fb3 2005-12-27 devnull snprint(buf, len, "%d", type);
868 3e0d8fb3 2005-12-27 devnull t = buf;
869 3e0d8fb3 2005-12-27 devnull }
870 3e0d8fb3 2005-12-27 devnull return t;
871 3e0d8fb3 2005-12-27 devnull }
872 3e0d8fb3 2005-12-27 devnull
873 3e0d8fb3 2005-12-27 devnull /*
874 3e0d8fb3 2005-12-27 devnull * return 0 if not a supported rr type
875 3e0d8fb3 2005-12-27 devnull */
876 3e0d8fb3 2005-12-27 devnull int
877 3e0d8fb3 2005-12-27 devnull rrsupported(int type)
878 3e0d8fb3 2005-12-27 devnull {
879 3e0d8fb3 2005-12-27 devnull if(type < 0 || type >Tall)
880 3e0d8fb3 2005-12-27 devnull return 0;
881 3e0d8fb3 2005-12-27 devnull return rrtname[type] != 0;
882 3e0d8fb3 2005-12-27 devnull }
883 3e0d8fb3 2005-12-27 devnull
884 3e0d8fb3 2005-12-27 devnull /*
885 3e0d8fb3 2005-12-27 devnull * compare 2 types
886 3e0d8fb3 2005-12-27 devnull */
887 3e0d8fb3 2005-12-27 devnull int
888 3e0d8fb3 2005-12-27 devnull tsame(int t1, int t2)
889 3e0d8fb3 2005-12-27 devnull {
890 3e0d8fb3 2005-12-27 devnull return t1 == t2 || t1 == Tall;
891 3e0d8fb3 2005-12-27 devnull }
892 3e0d8fb3 2005-12-27 devnull
893 3e0d8fb3 2005-12-27 devnull /*
894 3e0d8fb3 2005-12-27 devnull * Add resource records to a list, duplicate them if they are cached
895 3e0d8fb3 2005-12-27 devnull * RR's since these are shared.
896 3e0d8fb3 2005-12-27 devnull */
897 3e0d8fb3 2005-12-27 devnull RR*
898 3e0d8fb3 2005-12-27 devnull rrcat(RR **start, RR *rp)
899 3e0d8fb3 2005-12-27 devnull {
900 3e0d8fb3 2005-12-27 devnull RR **last;
901 3e0d8fb3 2005-12-27 devnull
902 3e0d8fb3 2005-12-27 devnull last = start;
903 3e0d8fb3 2005-12-27 devnull while(*last != 0)
904 3e0d8fb3 2005-12-27 devnull last = &(*last)->next;
905 3e0d8fb3 2005-12-27 devnull
906 3e0d8fb3 2005-12-27 devnull *last = rp;
907 3e0d8fb3 2005-12-27 devnull return *start;
908 3e0d8fb3 2005-12-27 devnull }
909 3e0d8fb3 2005-12-27 devnull
910 3e0d8fb3 2005-12-27 devnull /*
911 3e0d8fb3 2005-12-27 devnull * remove negative cache rr's from an rr list
912 3e0d8fb3 2005-12-27 devnull */
913 3e0d8fb3 2005-12-27 devnull RR*
914 3e0d8fb3 2005-12-27 devnull rrremneg(RR **l)
915 3e0d8fb3 2005-12-27 devnull {
916 3e0d8fb3 2005-12-27 devnull RR **nl, *rp;
917 3e0d8fb3 2005-12-27 devnull RR *first;
918 3e0d8fb3 2005-12-27 devnull
919 3e0d8fb3 2005-12-27 devnull first = nil;
920 3e0d8fb3 2005-12-27 devnull nl = &first;
921 3e0d8fb3 2005-12-27 devnull while(*l != nil){
922 3e0d8fb3 2005-12-27 devnull rp = *l;
923 3e0d8fb3 2005-12-27 devnull if(rp->negative){
924 3e0d8fb3 2005-12-27 devnull *l = rp->next;
925 3e0d8fb3 2005-12-27 devnull *nl = rp;
926 3e0d8fb3 2005-12-27 devnull nl = &rp->next;
927 3e0d8fb3 2005-12-27 devnull *nl = nil;
928 3e0d8fb3 2005-12-27 devnull } else
929 3e0d8fb3 2005-12-27 devnull l = &rp->next;
930 3e0d8fb3 2005-12-27 devnull }
931 3e0d8fb3 2005-12-27 devnull
932 3e0d8fb3 2005-12-27 devnull return first;
933 3e0d8fb3 2005-12-27 devnull }
934 3e0d8fb3 2005-12-27 devnull
935 3e0d8fb3 2005-12-27 devnull /*
936 3e0d8fb3 2005-12-27 devnull * remove rr's of a particular type from an rr list
937 3e0d8fb3 2005-12-27 devnull */
938 3e0d8fb3 2005-12-27 devnull RR*
939 3e0d8fb3 2005-12-27 devnull rrremtype(RR **l, int type)
940 3e0d8fb3 2005-12-27 devnull {
941 3e0d8fb3 2005-12-27 devnull RR **nl, *rp;
942 3e0d8fb3 2005-12-27 devnull RR *first;
943 3e0d8fb3 2005-12-27 devnull
944 3e0d8fb3 2005-12-27 devnull first = nil;
945 3e0d8fb3 2005-12-27 devnull nl = &first;
946 3e0d8fb3 2005-12-27 devnull while(*l != nil){
947 3e0d8fb3 2005-12-27 devnull rp = *l;
948 3e0d8fb3 2005-12-27 devnull if(rp->type == type){
949 3e0d8fb3 2005-12-27 devnull *l = rp->next;
950 3e0d8fb3 2005-12-27 devnull *nl = rp;
951 3e0d8fb3 2005-12-27 devnull nl = &rp->next;
952 3e0d8fb3 2005-12-27 devnull *nl = nil;
953 3e0d8fb3 2005-12-27 devnull } else
954 3e0d8fb3 2005-12-27 devnull l = &(*l)->next;
955 3e0d8fb3 2005-12-27 devnull }
956 3e0d8fb3 2005-12-27 devnull
957 3e0d8fb3 2005-12-27 devnull return first;
958 3e0d8fb3 2005-12-27 devnull }
959 3e0d8fb3 2005-12-27 devnull
960 3e0d8fb3 2005-12-27 devnull /*
961 3e0d8fb3 2005-12-27 devnull * print conversion for rr records
962 3e0d8fb3 2005-12-27 devnull */
963 3e0d8fb3 2005-12-27 devnull int
964 3e0d8fb3 2005-12-27 devnull rrfmt(Fmt *f)
965 3e0d8fb3 2005-12-27 devnull {
966 3e0d8fb3 2005-12-27 devnull RR *rp;
967 3e0d8fb3 2005-12-27 devnull char *strp;
968 3e0d8fb3 2005-12-27 devnull Fmt fstr;
969 3e0d8fb3 2005-12-27 devnull int rv;
970 3e0d8fb3 2005-12-27 devnull char buf[Domlen];
971 3e0d8fb3 2005-12-27 devnull Server *s;
972 3e0d8fb3 2005-12-27 devnull Txt *t;
973 3e0d8fb3 2005-12-27 devnull
974 3e0d8fb3 2005-12-27 devnull fmtstrinit(&fstr);
975 3e0d8fb3 2005-12-27 devnull
976 3e0d8fb3 2005-12-27 devnull rp = va_arg(f->args, RR*);
977 3e0d8fb3 2005-12-27 devnull if(rp == 0){
978 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "<null>");
979 3e0d8fb3 2005-12-27 devnull goto out;
980 3e0d8fb3 2005-12-27 devnull }
981 3e0d8fb3 2005-12-27 devnull
982 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "%s %s", rp->owner->name,
983 3e0d8fb3 2005-12-27 devnull rrname(rp->type, buf, sizeof buf));
984 3e0d8fb3 2005-12-27 devnull
985 3e0d8fb3 2005-12-27 devnull if(rp->negative){
986 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\tnegative - rcode %d", rp->negrcode);
987 3e0d8fb3 2005-12-27 devnull goto out;
988 3e0d8fb3 2005-12-27 devnull }
989 3e0d8fb3 2005-12-27 devnull
990 3e0d8fb3 2005-12-27 devnull switch(rp->type){
991 3e0d8fb3 2005-12-27 devnull case Thinfo:
992 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s %s", rp->cpu->name, rp->os->name);
993 3e0d8fb3 2005-12-27 devnull break;
994 3e0d8fb3 2005-12-27 devnull case Tcname:
995 3e0d8fb3 2005-12-27 devnull case Tmb:
996 3e0d8fb3 2005-12-27 devnull case Tmd:
997 3e0d8fb3 2005-12-27 devnull case Tmf:
998 3e0d8fb3 2005-12-27 devnull case Tns:
999 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s", rp->host->name);
1000 3e0d8fb3 2005-12-27 devnull break;
1001 3e0d8fb3 2005-12-27 devnull case Tmg:
1002 3e0d8fb3 2005-12-27 devnull case Tmr:
1003 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s", rp->mb->name);
1004 3e0d8fb3 2005-12-27 devnull break;
1005 3e0d8fb3 2005-12-27 devnull case Tminfo:
1006 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s %s", rp->mb->name, rp->rmb->name);
1007 3e0d8fb3 2005-12-27 devnull break;
1008 3e0d8fb3 2005-12-27 devnull case Tmx:
1009 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%lud %s", rp->pref, rp->host->name);
1010 3e0d8fb3 2005-12-27 devnull break;
1011 3e0d8fb3 2005-12-27 devnull case Ta:
1012 3e0d8fb3 2005-12-27 devnull case Taaaa:
1013 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s", rp->ip->name);
1014 3e0d8fb3 2005-12-27 devnull break;
1015 3e0d8fb3 2005-12-27 devnull case Tptr:
1016 3e0d8fb3 2005-12-27 devnull // fmtprint(&fstr, "\t%s(%lud)", rp->ptr->name, rp->ptr->ordinal);
1017 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s", rp->ptr->name);
1018 3e0d8fb3 2005-12-27 devnull break;
1019 3e0d8fb3 2005-12-27 devnull case Tsoa:
1020 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s %s %lud %lud %lud %lud %lud", rp->host->name,
1021 3e0d8fb3 2005-12-27 devnull rp->rmb->name, rp->soa->serial, rp->soa->refresh, rp->soa->retry,
1022 3e0d8fb3 2005-12-27 devnull rp->soa->expire, rp->soa->minttl);
1023 3e0d8fb3 2005-12-27 devnull for(s = rp->soa->slaves; s != nil; s = s->next)
1024 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " %s", s->name);
1025 3e0d8fb3 2005-12-27 devnull break;
1026 3e0d8fb3 2005-12-27 devnull case Tnull:
1027 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%.*H", rp->null->dlen, rp->null->data);
1028 3e0d8fb3 2005-12-27 devnull break;
1029 3e0d8fb3 2005-12-27 devnull case Ttxt:
1030 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t");
1031 3e0d8fb3 2005-12-27 devnull for(t = rp->txt; t != nil; t = t->next)
1032 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "%s", t->p);
1033 3e0d8fb3 2005-12-27 devnull break;
1034 3e0d8fb3 2005-12-27 devnull case Trp:
1035 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%s %s", rp->rmb->name, rp->rp->name);
1036 3e0d8fb3 2005-12-27 devnull break;
1037 3e0d8fb3 2005-12-27 devnull case Tkey:
1038 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%d %d %d", rp->key->flags, rp->key->proto,
1039 3e0d8fb3 2005-12-27 devnull rp->key->alg);
1040 3e0d8fb3 2005-12-27 devnull break;
1041 3e0d8fb3 2005-12-27 devnull case Tsig:
1042 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%d %d %d %lud %lud %lud %d %s",
1043 3e0d8fb3 2005-12-27 devnull rp->sig->type, rp->sig->alg, rp->sig->labels, rp->sig->ttl,
1044 3e0d8fb3 2005-12-27 devnull rp->sig->exp, rp->sig->incep, rp->sig->tag, rp->sig->signer->name);
1045 3e0d8fb3 2005-12-27 devnull break;
1046 3e0d8fb3 2005-12-27 devnull case Tcert:
1047 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\t%d %d %d",
1048 3e0d8fb3 2005-12-27 devnull rp->sig->type, rp->sig->tag, rp->sig->alg);
1049 3e0d8fb3 2005-12-27 devnull break;
1050 3e0d8fb3 2005-12-27 devnull default:
1051 3e0d8fb3 2005-12-27 devnull break;
1052 3e0d8fb3 2005-12-27 devnull }
1053 3e0d8fb3 2005-12-27 devnull out:
1054 3e0d8fb3 2005-12-27 devnull strp = fmtstrflush(&fstr);
1055 3e0d8fb3 2005-12-27 devnull rv = fmtstrcpy(f, strp);
1056 3e0d8fb3 2005-12-27 devnull free(strp);
1057 3e0d8fb3 2005-12-27 devnull return rv;
1058 3e0d8fb3 2005-12-27 devnull }
1059 3e0d8fb3 2005-12-27 devnull
1060 3e0d8fb3 2005-12-27 devnull /*
1061 3e0d8fb3 2005-12-27 devnull * print conversion for rr records in attribute value form
1062 3e0d8fb3 2005-12-27 devnull */
1063 3e0d8fb3 2005-12-27 devnull int
1064 3e0d8fb3 2005-12-27 devnull rravfmt(Fmt *f)
1065 3e0d8fb3 2005-12-27 devnull {
1066 3e0d8fb3 2005-12-27 devnull RR *rp;
1067 3e0d8fb3 2005-12-27 devnull char *strp;
1068 3e0d8fb3 2005-12-27 devnull Fmt fstr;
1069 3e0d8fb3 2005-12-27 devnull int rv;
1070 3e0d8fb3 2005-12-27 devnull Server *s;
1071 3e0d8fb3 2005-12-27 devnull Txt *t;
1072 3e0d8fb3 2005-12-27 devnull int quote;
1073 3e0d8fb3 2005-12-27 devnull
1074 3e0d8fb3 2005-12-27 devnull fmtstrinit(&fstr);
1075 3e0d8fb3 2005-12-27 devnull
1076 3e0d8fb3 2005-12-27 devnull rp = va_arg(f->args, RR*);
1077 3e0d8fb3 2005-12-27 devnull if(rp == 0){
1078 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "<null>");
1079 3e0d8fb3 2005-12-27 devnull goto out;
1080 3e0d8fb3 2005-12-27 devnull }
1081 3e0d8fb3 2005-12-27 devnull
1082 3e0d8fb3 2005-12-27 devnull if(rp->type == Tptr)
1083 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "ptr=%s", rp->owner->name);
1084 3e0d8fb3 2005-12-27 devnull else
1085 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "dom=%s", rp->owner->name);
1086 3e0d8fb3 2005-12-27 devnull
1087 3e0d8fb3 2005-12-27 devnull switch(rp->type){
1088 3e0d8fb3 2005-12-27 devnull case Thinfo:
1089 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " cpu=%s os=%s", rp->cpu->name, rp->os->name);
1090 3e0d8fb3 2005-12-27 devnull break;
1091 3e0d8fb3 2005-12-27 devnull case Tcname:
1092 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " cname=%s", rp->host->name);
1093 3e0d8fb3 2005-12-27 devnull break;
1094 3e0d8fb3 2005-12-27 devnull case Tmb:
1095 3e0d8fb3 2005-12-27 devnull case Tmd:
1096 3e0d8fb3 2005-12-27 devnull case Tmf:
1097 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " mbox=%s", rp->host->name);
1098 3e0d8fb3 2005-12-27 devnull break;
1099 3e0d8fb3 2005-12-27 devnull case Tns:
1100 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " ns=%s", rp->host->name);
1101 3e0d8fb3 2005-12-27 devnull break;
1102 3e0d8fb3 2005-12-27 devnull case Tmg:
1103 3e0d8fb3 2005-12-27 devnull case Tmr:
1104 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " mbox=%s", rp->mb->name);
1105 3e0d8fb3 2005-12-27 devnull break;
1106 3e0d8fb3 2005-12-27 devnull case Tminfo:
1107 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " mbox=%s mbox=%s", rp->mb->name, rp->rmb->name);
1108 3e0d8fb3 2005-12-27 devnull break;
1109 3e0d8fb3 2005-12-27 devnull case Tmx:
1110 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " pref=%lud mx=%s", rp->pref, rp->host->name);
1111 3e0d8fb3 2005-12-27 devnull break;
1112 3e0d8fb3 2005-12-27 devnull case Ta:
1113 3e0d8fb3 2005-12-27 devnull case Taaaa:
1114 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " ip=%s", rp->ip->name);
1115 3e0d8fb3 2005-12-27 devnull break;
1116 3e0d8fb3 2005-12-27 devnull case Tptr:
1117 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " dom=%s", rp->ptr->name);
1118 3e0d8fb3 2005-12-27 devnull break;
1119 3e0d8fb3 2005-12-27 devnull case Tsoa:
1120 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " ns=%s mbox=%s serial=%lud refresh=%lud retry=%lud expire=%lud ttl=%lud",
1121 3e0d8fb3 2005-12-27 devnull rp->host->name, rp->rmb->name, rp->soa->serial,
1122 3e0d8fb3 2005-12-27 devnull rp->soa->refresh, rp->soa->retry,
1123 3e0d8fb3 2005-12-27 devnull rp->soa->expire, rp->soa->minttl);
1124 3e0d8fb3 2005-12-27 devnull for(s = rp->soa->slaves; s != nil; s = s->next)
1125 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " dnsslave=%s", s->name);
1126 3e0d8fb3 2005-12-27 devnull break;
1127 3e0d8fb3 2005-12-27 devnull case Tnull:
1128 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " null=%.*H", rp->null->dlen, rp->null->data);
1129 3e0d8fb3 2005-12-27 devnull break;
1130 3e0d8fb3 2005-12-27 devnull case Ttxt:
1131 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " txt=");
1132 3e0d8fb3 2005-12-27 devnull quote = 0;
1133 3e0d8fb3 2005-12-27 devnull for(t = rp->txt; t != nil; t = t->next)
1134 3e0d8fb3 2005-12-27 devnull if(strchr(t->p, ' '))
1135 3e0d8fb3 2005-12-27 devnull quote = 1;
1136 3e0d8fb3 2005-12-27 devnull if(quote)
1137 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\"");
1138 3e0d8fb3 2005-12-27 devnull for(t = rp->txt; t != nil; t = t->next)
1139 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "%s", t->p);
1140 3e0d8fb3 2005-12-27 devnull if(quote)
1141 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, "\"");
1142 3e0d8fb3 2005-12-27 devnull break;
1143 3e0d8fb3 2005-12-27 devnull case Trp:
1144 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " rp=%s txt=%s", rp->rmb->name, rp->rp->name);
1145 3e0d8fb3 2005-12-27 devnull break;
1146 3e0d8fb3 2005-12-27 devnull case Tkey:
1147 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " flags=%d proto=%d alg=%d",
1148 3e0d8fb3 2005-12-27 devnull rp->key->flags, rp->key->proto, rp->key->alg);
1149 3e0d8fb3 2005-12-27 devnull break;
1150 3e0d8fb3 2005-12-27 devnull case Tsig:
1151 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " type=%d alg=%d labels=%d ttl=%lud exp=%lud incep=%lud tag=%d signer=%s",
1152 3e0d8fb3 2005-12-27 devnull rp->sig->type, rp->sig->alg, rp->sig->labels, rp->sig->ttl,
1153 3e0d8fb3 2005-12-27 devnull rp->sig->exp, rp->sig->incep, rp->sig->tag, rp->sig->signer->name);
1154 3e0d8fb3 2005-12-27 devnull break;
1155 3e0d8fb3 2005-12-27 devnull case Tcert:
1156 3e0d8fb3 2005-12-27 devnull fmtprint(&fstr, " type=%d tag=%d alg=%d",
1157 3e0d8fb3 2005-12-27 devnull rp->sig->type, rp->sig->tag, rp->sig->alg);
1158 3e0d8fb3 2005-12-27 devnull break;
1159 3e0d8fb3 2005-12-27 devnull default:
1160 3e0d8fb3 2005-12-27 devnull break;
1161 3e0d8fb3 2005-12-27 devnull }
1162 3e0d8fb3 2005-12-27 devnull out:
1163 3e0d8fb3 2005-12-27 devnull strp = fmtstrflush(&fstr);
1164 3e0d8fb3 2005-12-27 devnull rv = fmtstrcpy(f, strp);
1165 3e0d8fb3 2005-12-27 devnull free(strp);
1166 3e0d8fb3 2005-12-27 devnull return rv;
1167 3e0d8fb3 2005-12-27 devnull }
1168 3e0d8fb3 2005-12-27 devnull
1169 3e0d8fb3 2005-12-27 devnull void
1170 3e0d8fb3 2005-12-27 devnull warning(char *fmt, ...)
1171 3e0d8fb3 2005-12-27 devnull {
1172 3e0d8fb3 2005-12-27 devnull char dnserr[128];
1173 3e0d8fb3 2005-12-27 devnull va_list arg;
1174 3e0d8fb3 2005-12-27 devnull
1175 3e0d8fb3 2005-12-27 devnull va_start(arg, fmt);
1176 3e0d8fb3 2005-12-27 devnull vseprint(dnserr, dnserr+sizeof(dnserr), fmt, arg);
1177 3e0d8fb3 2005-12-27 devnull va_end(arg);
1178 3e0d8fb3 2005-12-27 devnull syslog(1, "dns", dnserr);
1179 3e0d8fb3 2005-12-27 devnull }
1180 3e0d8fb3 2005-12-27 devnull
1181 3e0d8fb3 2005-12-27 devnull /*
1182 3e0d8fb3 2005-12-27 devnull * create a slave process to handle a request to avoid one request blocking
1183 3e0d8fb3 2005-12-27 devnull * another
1184 3e0d8fb3 2005-12-27 devnull */
1185 3e0d8fb3 2005-12-27 devnull void
1186 3e0d8fb3 2005-12-27 devnull slave(Request *req)
1187 3e0d8fb3 2005-12-27 devnull {
1188 3e0d8fb3 2005-12-27 devnull static int slaveid;
1189 3e0d8fb3 2005-12-27 devnull
1190 3e0d8fb3 2005-12-27 devnull if(req->isslave)
1191 3e0d8fb3 2005-12-27 devnull return; /* we're already a slave process */
1192 3e0d8fb3 2005-12-27 devnull
1193 3e0d8fb3 2005-12-27 devnull /* limit parallelism */
1194 3e0d8fb3 2005-12-27 devnull if(getactivity(req) > Maxactive){
1195 3e0d8fb3 2005-12-27 devnull putactivity();
1196 3e0d8fb3 2005-12-27 devnull return;
1197 3e0d8fb3 2005-12-27 devnull }
1198 3e0d8fb3 2005-12-27 devnull
1199 3e0d8fb3 2005-12-27 devnull switch(rfork(RFPROC|RFNOTEG|RFMEM|RFNOWAIT)){
1200 3e0d8fb3 2005-12-27 devnull case -1:
1201 3e0d8fb3 2005-12-27 devnull putactivity();
1202 3e0d8fb3 2005-12-27 devnull break;
1203 3e0d8fb3 2005-12-27 devnull case 0:
1204 3e0d8fb3 2005-12-27 devnull req->isslave = 1;
1205 3e0d8fb3 2005-12-27 devnull break;
1206 3e0d8fb3 2005-12-27 devnull default:
1207 3e0d8fb3 2005-12-27 devnull longjmp(req->mret, 1);
1208 3e0d8fb3 2005-12-27 devnull }
1209 3e0d8fb3 2005-12-27 devnull }
1210 3e0d8fb3 2005-12-27 devnull
1211 3e0d8fb3 2005-12-27 devnull /*
1212 3e0d8fb3 2005-12-27 devnull * chasing down double free's
1213 3e0d8fb3 2005-12-27 devnull */
1214 3e0d8fb3 2005-12-27 devnull void
1215 3e0d8fb3 2005-12-27 devnull dncheck(void *p, int dolock)
1216 3e0d8fb3 2005-12-27 devnull {
1217 3e0d8fb3 2005-12-27 devnull int i;
1218 3e0d8fb3 2005-12-27 devnull DN *dp;
1219 3e0d8fb3 2005-12-27 devnull RR *rp;
1220 3e0d8fb3 2005-12-27 devnull
1221 3e0d8fb3 2005-12-27 devnull if(p != nil){
1222 3e0d8fb3 2005-12-27 devnull dp = p;
1223 3e0d8fb3 2005-12-27 devnull assert(dp->magic == DNmagic);
1224 3e0d8fb3 2005-12-27 devnull }
1225 3e0d8fb3 2005-12-27 devnull
1226 3e0d8fb3 2005-12-27 devnull if(!testing)
1227 3e0d8fb3 2005-12-27 devnull return;
1228 3e0d8fb3 2005-12-27 devnull
1229 3e0d8fb3 2005-12-27 devnull if(dolock)
1230 3e0d8fb3 2005-12-27 devnull lock(&dnlock);
1231 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++)
1232 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next){
1233 3e0d8fb3 2005-12-27 devnull assert(dp != p);
1234 3e0d8fb3 2005-12-27 devnull assert(dp->magic == DNmagic);
1235 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
1236 3e0d8fb3 2005-12-27 devnull assert(rp->magic == RRmagic);
1237 3e0d8fb3 2005-12-27 devnull assert(rp->cached);
1238 3e0d8fb3 2005-12-27 devnull assert(rp->owner == dp);
1239 3e0d8fb3 2005-12-27 devnull }
1240 3e0d8fb3 2005-12-27 devnull }
1241 3e0d8fb3 2005-12-27 devnull if(dolock)
1242 3e0d8fb3 2005-12-27 devnull unlock(&dnlock);
1243 3e0d8fb3 2005-12-27 devnull }
1244 3e0d8fb3 2005-12-27 devnull
1245 3e0d8fb3 2005-12-27 devnull static int
1246 3e0d8fb3 2005-12-27 devnull rrequiv(RR *r1, RR *r2)
1247 3e0d8fb3 2005-12-27 devnull {
1248 3e0d8fb3 2005-12-27 devnull return r1->owner == r2->owner
1249 3e0d8fb3 2005-12-27 devnull && r1->type == r2->type
1250 3e0d8fb3 2005-12-27 devnull && r1->arg0 == r2->arg0
1251 3e0d8fb3 2005-12-27 devnull && r1->arg1 == r2->arg1;
1252 3e0d8fb3 2005-12-27 devnull }
1253 3e0d8fb3 2005-12-27 devnull
1254 3e0d8fb3 2005-12-27 devnull void
1255 3e0d8fb3 2005-12-27 devnull unique(RR *rp)
1256 3e0d8fb3 2005-12-27 devnull {
1257 3e0d8fb3 2005-12-27 devnull RR **l, *nrp;
1258 3e0d8fb3 2005-12-27 devnull
1259 3e0d8fb3 2005-12-27 devnull for(; rp; rp = rp->next){
1260 3e0d8fb3 2005-12-27 devnull l = &rp->next;
1261 3e0d8fb3 2005-12-27 devnull for(nrp = *l; nrp; nrp = *l){
1262 3e0d8fb3 2005-12-27 devnull if(rrequiv(rp, nrp)){
1263 3e0d8fb3 2005-12-27 devnull *l = nrp->next;
1264 3e0d8fb3 2005-12-27 devnull rrfree(nrp);
1265 3e0d8fb3 2005-12-27 devnull } else
1266 3e0d8fb3 2005-12-27 devnull l = &nrp->next;
1267 3e0d8fb3 2005-12-27 devnull }
1268 3e0d8fb3 2005-12-27 devnull }
1269 3e0d8fb3 2005-12-27 devnull }
1270 3e0d8fb3 2005-12-27 devnull
1271 3e0d8fb3 2005-12-27 devnull /*
1272 3e0d8fb3 2005-12-27 devnull * true if second domain is subsumed by the first
1273 3e0d8fb3 2005-12-27 devnull */
1274 3e0d8fb3 2005-12-27 devnull int
1275 3e0d8fb3 2005-12-27 devnull subsume(char *higher, char *lower)
1276 3e0d8fb3 2005-12-27 devnull {
1277 3e0d8fb3 2005-12-27 devnull int hn, ln;
1278 3e0d8fb3 2005-12-27 devnull
1279 3e0d8fb3 2005-12-27 devnull ln = strlen(lower);
1280 3e0d8fb3 2005-12-27 devnull hn = strlen(higher);
1281 3e0d8fb3 2005-12-27 devnull if(ln < hn)
1282 3e0d8fb3 2005-12-27 devnull return 0;
1283 3e0d8fb3 2005-12-27 devnull
1284 3e0d8fb3 2005-12-27 devnull if(cistrcmp(lower + ln - hn, higher) != 0)
1285 3e0d8fb3 2005-12-27 devnull return 0;
1286 3e0d8fb3 2005-12-27 devnull
1287 3e0d8fb3 2005-12-27 devnull if(ln > hn && hn != 0 && lower[ln - hn - 1] != '.')
1288 3e0d8fb3 2005-12-27 devnull return 0;
1289 3e0d8fb3 2005-12-27 devnull
1290 3e0d8fb3 2005-12-27 devnull return 1;
1291 3e0d8fb3 2005-12-27 devnull }
1292 3e0d8fb3 2005-12-27 devnull
1293 3e0d8fb3 2005-12-27 devnull /*
1294 3e0d8fb3 2005-12-27 devnull * randomize the order we return items to provide some
1295 3e0d8fb3 2005-12-27 devnull * load balancing for servers.
1296 3e0d8fb3 2005-12-27 devnull *
1297 3e0d8fb3 2005-12-27 devnull * only randomize the first class of entries
1298 3e0d8fb3 2005-12-27 devnull */
1299 3e0d8fb3 2005-12-27 devnull RR*
1300 3e0d8fb3 2005-12-27 devnull randomize(RR *rp)
1301 3e0d8fb3 2005-12-27 devnull {
1302 3e0d8fb3 2005-12-27 devnull RR *first, *last, *x, *base;
1303 3e0d8fb3 2005-12-27 devnull ulong n;
1304 3e0d8fb3 2005-12-27 devnull
1305 3e0d8fb3 2005-12-27 devnull if(rp == nil || rp->next == nil)
1306 3e0d8fb3 2005-12-27 devnull return rp;
1307 3e0d8fb3 2005-12-27 devnull
1308 3e0d8fb3 2005-12-27 devnull /* just randomize addresses and mx's */
1309 3e0d8fb3 2005-12-27 devnull for(x = rp; x; x = x->next)
1310 3e0d8fb3 2005-12-27 devnull if(x->type != Ta && x->type != Tmx && x->type != Tns)
1311 3e0d8fb3 2005-12-27 devnull return rp;
1312 3e0d8fb3 2005-12-27 devnull
1313 3e0d8fb3 2005-12-27 devnull base = rp;
1314 3e0d8fb3 2005-12-27 devnull
1315 3e0d8fb3 2005-12-27 devnull n = rand();
1316 3e0d8fb3 2005-12-27 devnull last = first = nil;
1317 3e0d8fb3 2005-12-27 devnull while(rp != nil){
1318 3e0d8fb3 2005-12-27 devnull /* stop randomizing if we've moved past our class */
1319 3e0d8fb3 2005-12-27 devnull if(base->auth != rp->auth || base->db != rp->db){
1320 3e0d8fb3 2005-12-27 devnull last->next = rp;
1321 3e0d8fb3 2005-12-27 devnull break;
1322 3e0d8fb3 2005-12-27 devnull }
1323 3e0d8fb3 2005-12-27 devnull
1324 3e0d8fb3 2005-12-27 devnull /* unchain */
1325 3e0d8fb3 2005-12-27 devnull x = rp;
1326 3e0d8fb3 2005-12-27 devnull rp = x->next;
1327 3e0d8fb3 2005-12-27 devnull x->next = nil;
1328 3e0d8fb3 2005-12-27 devnull
1329 3e0d8fb3 2005-12-27 devnull if(n&1){
1330 3e0d8fb3 2005-12-27 devnull /* add to tail */
1331 3e0d8fb3 2005-12-27 devnull if(last == nil)
1332 3e0d8fb3 2005-12-27 devnull first = x;
1333 3e0d8fb3 2005-12-27 devnull else
1334 3e0d8fb3 2005-12-27 devnull last->next = x;
1335 3e0d8fb3 2005-12-27 devnull last = x;
1336 3e0d8fb3 2005-12-27 devnull } else {
1337 3e0d8fb3 2005-12-27 devnull /* add to head */
1338 3e0d8fb3 2005-12-27 devnull if(last == nil)
1339 3e0d8fb3 2005-12-27 devnull last = x;
1340 3e0d8fb3 2005-12-27 devnull x->next = first;
1341 3e0d8fb3 2005-12-27 devnull first = x;
1342 3e0d8fb3 2005-12-27 devnull }
1343 3e0d8fb3 2005-12-27 devnull
1344 3e0d8fb3 2005-12-27 devnull /* reroll the dice */
1345 3e0d8fb3 2005-12-27 devnull n >>= 1;
1346 3e0d8fb3 2005-12-27 devnull }
1347 3e0d8fb3 2005-12-27 devnull return first;
1348 3e0d8fb3 2005-12-27 devnull }
1349 3e0d8fb3 2005-12-27 devnull
1350 3e0d8fb3 2005-12-27 devnull static int
1351 3e0d8fb3 2005-12-27 devnull sencodefmt(Fmt *f)
1352 3e0d8fb3 2005-12-27 devnull {
1353 3e0d8fb3 2005-12-27 devnull char *out;
1354 3e0d8fb3 2005-12-27 devnull char *buf;
1355 3e0d8fb3 2005-12-27 devnull int i, len;
1356 3e0d8fb3 2005-12-27 devnull int ilen;
1357 3e0d8fb3 2005-12-27 devnull int rv;
1358 3e0d8fb3 2005-12-27 devnull uchar *b;
1359 3e0d8fb3 2005-12-27 devnull char obuf[64]; // rsc optimization
1360 3e0d8fb3 2005-12-27 devnull
1361 3e0d8fb3 2005-12-27 devnull if(!(f->flags&FmtPrec) || f->prec < 1)
1362 3e0d8fb3 2005-12-27 devnull goto error;
1363 3e0d8fb3 2005-12-27 devnull
1364 3e0d8fb3 2005-12-27 devnull b = va_arg(f->args, uchar*);
1365 3e0d8fb3 2005-12-27 devnull if(b == nil)
1366 3e0d8fb3 2005-12-27 devnull goto error;
1367 3e0d8fb3 2005-12-27 devnull
1368 3e0d8fb3 2005-12-27 devnull /* if it's a printable, go for it */
1369 3e0d8fb3 2005-12-27 devnull len = f->prec;
1370 3e0d8fb3 2005-12-27 devnull for(i = 0; i < len; i++)
1371 3e0d8fb3 2005-12-27 devnull if(!isprint(b[i]))
1372 3e0d8fb3 2005-12-27 devnull break;
1373 3e0d8fb3 2005-12-27 devnull if(i == len){
1374 3e0d8fb3 2005-12-27 devnull if(len >= sizeof obuf)
1375 3e0d8fb3 2005-12-27 devnull len = sizeof(obuf)-1;
1376 3e0d8fb3 2005-12-27 devnull memmove(obuf, b, len);
1377 3e0d8fb3 2005-12-27 devnull obuf[len] = 0;
1378 3e0d8fb3 2005-12-27 devnull fmtstrcpy(f, obuf);
1379 3e0d8fb3 2005-12-27 devnull return 0;
1380 3e0d8fb3 2005-12-27 devnull }
1381 3e0d8fb3 2005-12-27 devnull
1382 3e0d8fb3 2005-12-27 devnull ilen = f->prec;
1383 3e0d8fb3 2005-12-27 devnull f->prec = 0;
1384 3e0d8fb3 2005-12-27 devnull f->flags &= ~FmtPrec;
1385 3e0d8fb3 2005-12-27 devnull switch(f->r){
1386 3e0d8fb3 2005-12-27 devnull case '<':
1387 3e0d8fb3 2005-12-27 devnull len = (8*ilen+4)/5 + 3;
1388 3e0d8fb3 2005-12-27 devnull break;
1389 3e0d8fb3 2005-12-27 devnull case '[':
1390 3e0d8fb3 2005-12-27 devnull len = (8*ilen+5)/6 + 4;
1391 3e0d8fb3 2005-12-27 devnull break;
1392 3e0d8fb3 2005-12-27 devnull case 'H':
1393 3e0d8fb3 2005-12-27 devnull len = 2*ilen + 1;
1394 3e0d8fb3 2005-12-27 devnull break;
1395 3e0d8fb3 2005-12-27 devnull default:
1396 3e0d8fb3 2005-12-27 devnull goto error;
1397 3e0d8fb3 2005-12-27 devnull }
1398 3e0d8fb3 2005-12-27 devnull
1399 3e0d8fb3 2005-12-27 devnull if(len > sizeof(obuf)){
1400 3e0d8fb3 2005-12-27 devnull buf = malloc(len);
1401 3e0d8fb3 2005-12-27 devnull if(buf == nil)
1402 3e0d8fb3 2005-12-27 devnull goto error;
1403 3e0d8fb3 2005-12-27 devnull } else
1404 3e0d8fb3 2005-12-27 devnull buf = obuf;
1405 3e0d8fb3 2005-12-27 devnull
1406 3e0d8fb3 2005-12-27 devnull // convert
1407 3e0d8fb3 2005-12-27 devnull out = buf;
1408 3e0d8fb3 2005-12-27 devnull switch(f->r){
1409 3e0d8fb3 2005-12-27 devnull case '<':
1410 3e0d8fb3 2005-12-27 devnull rv = enc32(out, len, b, ilen);
1411 3e0d8fb3 2005-12-27 devnull break;
1412 3e0d8fb3 2005-12-27 devnull case '[':
1413 3e0d8fb3 2005-12-27 devnull rv = enc64(out, len, b, ilen);
1414 3e0d8fb3 2005-12-27 devnull break;
1415 3e0d8fb3 2005-12-27 devnull case 'H':
1416 3e0d8fb3 2005-12-27 devnull rv = enc16(out, len, b, ilen);
1417 3e0d8fb3 2005-12-27 devnull break;
1418 3e0d8fb3 2005-12-27 devnull default:
1419 3e0d8fb3 2005-12-27 devnull rv = -1;
1420 3e0d8fb3 2005-12-27 devnull break;
1421 3e0d8fb3 2005-12-27 devnull }
1422 3e0d8fb3 2005-12-27 devnull if(rv < 0)
1423 3e0d8fb3 2005-12-27 devnull goto error;
1424 3e0d8fb3 2005-12-27 devnull
1425 3e0d8fb3 2005-12-27 devnull fmtstrcpy(f, buf);
1426 3e0d8fb3 2005-12-27 devnull if(buf != obuf)
1427 3e0d8fb3 2005-12-27 devnull free(buf);
1428 3e0d8fb3 2005-12-27 devnull return 0;
1429 3e0d8fb3 2005-12-27 devnull
1430 3e0d8fb3 2005-12-27 devnull error:
1431 3e0d8fb3 2005-12-27 devnull return fmtstrcpy(f, "<encodefmt>");
1432 3e0d8fb3 2005-12-27 devnull
1433 3e0d8fb3 2005-12-27 devnull }
1434 3e0d8fb3 2005-12-27 devnull
1435 3e0d8fb3 2005-12-27 devnull void*
1436 3e0d8fb3 2005-12-27 devnull emalloc(int size)
1437 3e0d8fb3 2005-12-27 devnull {
1438 3e0d8fb3 2005-12-27 devnull char *x;
1439 3e0d8fb3 2005-12-27 devnull
1440 3e0d8fb3 2005-12-27 devnull x = mallocz(size, 1);
1441 3e0d8fb3 2005-12-27 devnull if(x == nil)
1442 3e0d8fb3 2005-12-27 devnull abort();
1443 3e0d8fb3 2005-12-27 devnull setmalloctag(x, getcallerpc(&size));
1444 3e0d8fb3 2005-12-27 devnull return x;
1445 3e0d8fb3 2005-12-27 devnull }
1446 3e0d8fb3 2005-12-27 devnull
1447 3e0d8fb3 2005-12-27 devnull char*
1448 3e0d8fb3 2005-12-27 devnull estrdup(char *s)
1449 3e0d8fb3 2005-12-27 devnull {
1450 3e0d8fb3 2005-12-27 devnull int size;
1451 3e0d8fb3 2005-12-27 devnull char *p;
1452 3e0d8fb3 2005-12-27 devnull
1453 3e0d8fb3 2005-12-27 devnull size = strlen(s)+1;
1454 3e0d8fb3 2005-12-27 devnull p = mallocz(size, 0);
1455 3e0d8fb3 2005-12-27 devnull if(p == nil)
1456 3e0d8fb3 2005-12-27 devnull abort();
1457 3e0d8fb3 2005-12-27 devnull memmove(p, s, size);
1458 3e0d8fb3 2005-12-27 devnull setmalloctag(p, getcallerpc(&s));
1459 3e0d8fb3 2005-12-27 devnull return p;
1460 3e0d8fb3 2005-12-27 devnull }
1461 3e0d8fb3 2005-12-27 devnull
1462 3e0d8fb3 2005-12-27 devnull /*
1463 3e0d8fb3 2005-12-27 devnull * create a pointer record
1464 3e0d8fb3 2005-12-27 devnull */
1465 3e0d8fb3 2005-12-27 devnull static RR*
1466 3e0d8fb3 2005-12-27 devnull mkptr(DN *dp, char *ptr, ulong ttl)
1467 3e0d8fb3 2005-12-27 devnull {
1468 3e0d8fb3 2005-12-27 devnull DN *ipdp;
1469 3e0d8fb3 2005-12-27 devnull RR *rp;
1470 3e0d8fb3 2005-12-27 devnull
1471 3e0d8fb3 2005-12-27 devnull ipdp = dnlookup(ptr, Cin, 1);
1472 3e0d8fb3 2005-12-27 devnull
1473 3e0d8fb3 2005-12-27 devnull rp = rralloc(Tptr);
1474 3e0d8fb3 2005-12-27 devnull rp->ptr = dp;
1475 3e0d8fb3 2005-12-27 devnull rp->owner = ipdp;
1476 3e0d8fb3 2005-12-27 devnull rp->db = 1;
1477 3e0d8fb3 2005-12-27 devnull if(ttl)
1478 3e0d8fb3 2005-12-27 devnull rp->ttl = ttl;
1479 3e0d8fb3 2005-12-27 devnull return rp;
1480 3e0d8fb3 2005-12-27 devnull }
1481 3e0d8fb3 2005-12-27 devnull
1482 3e0d8fb3 2005-12-27 devnull /*
1483 3e0d8fb3 2005-12-27 devnull * look for all ip addresses in this network and make
1484 3e0d8fb3 2005-12-27 devnull * pointer records for them.
1485 3e0d8fb3 2005-12-27 devnull */
1486 3e0d8fb3 2005-12-27 devnull void
1487 3e0d8fb3 2005-12-27 devnull dnptr(uchar *net, uchar *mask, char *dom, int bytes, int ttl)
1488 3e0d8fb3 2005-12-27 devnull {
1489 3e0d8fb3 2005-12-27 devnull int i, j;
1490 3e0d8fb3 2005-12-27 devnull DN *dp;
1491 3e0d8fb3 2005-12-27 devnull RR *rp, *nrp, *first, **l;
1492 3e0d8fb3 2005-12-27 devnull uchar ip[IPaddrlen];
1493 3e0d8fb3 2005-12-27 devnull uchar nnet[IPaddrlen];
1494 3e0d8fb3 2005-12-27 devnull char ptr[Domlen];
1495 3e0d8fb3 2005-12-27 devnull char *p, *e;
1496 3e0d8fb3 2005-12-27 devnull
1497 3e0d8fb3 2005-12-27 devnull l = &first;
1498 3e0d8fb3 2005-12-27 devnull first = nil;
1499 3e0d8fb3 2005-12-27 devnull for(i = 0; i < HTLEN; i++){
1500 3e0d8fb3 2005-12-27 devnull for(dp = ht[i]; dp; dp = dp->next){
1501 3e0d8fb3 2005-12-27 devnull for(rp = dp->rr; rp; rp = rp->next){
1502 3e0d8fb3 2005-12-27 devnull if(rp->type != Ta || rp->negative)
1503 3e0d8fb3 2005-12-27 devnull continue;
1504 3e0d8fb3 2005-12-27 devnull parseip(ip, rp->ip->name);
1505 3e0d8fb3 2005-12-27 devnull maskip(ip, mask, nnet);
1506 3e0d8fb3 2005-12-27 devnull if(ipcmp(net, nnet) != 0)
1507 3e0d8fb3 2005-12-27 devnull continue;
1508 3e0d8fb3 2005-12-27 devnull p = ptr;
1509 3e0d8fb3 2005-12-27 devnull e = ptr+sizeof(ptr);
1510 3e0d8fb3 2005-12-27 devnull for(j = IPaddrlen-1; j >= IPaddrlen-bytes; j--)
1511 3e0d8fb3 2005-12-27 devnull p = seprint(p, e, "%d.", ip[j]);
1512 3e0d8fb3 2005-12-27 devnull seprint(p, e, "%s", dom);
1513 3e0d8fb3 2005-12-27 devnull nrp = mkptr(dp, ptr, ttl);
1514 3e0d8fb3 2005-12-27 devnull *l = nrp;
1515 3e0d8fb3 2005-12-27 devnull l = &nrp->next;
1516 3e0d8fb3 2005-12-27 devnull }
1517 3e0d8fb3 2005-12-27 devnull }
1518 3e0d8fb3 2005-12-27 devnull }
1519 3e0d8fb3 2005-12-27 devnull
1520 3e0d8fb3 2005-12-27 devnull for(rp = first; rp != nil; rp = nrp){
1521 3e0d8fb3 2005-12-27 devnull nrp = rp->next;
1522 3e0d8fb3 2005-12-27 devnull rp->next = nil;
1523 3e0d8fb3 2005-12-27 devnull rrattach(rp, 1);
1524 3e0d8fb3 2005-12-27 devnull }
1525 3e0d8fb3 2005-12-27 devnull }
1526 3e0d8fb3 2005-12-27 devnull
1527 3e0d8fb3 2005-12-27 devnull void
1528 3e0d8fb3 2005-12-27 devnull freeserverlist(Server *s)
1529 3e0d8fb3 2005-12-27 devnull {
1530 3e0d8fb3 2005-12-27 devnull Server *next;
1531 3e0d8fb3 2005-12-27 devnull
1532 3e0d8fb3 2005-12-27 devnull for(; s != nil; s = next){
1533 3e0d8fb3 2005-12-27 devnull next = s->next;
1534 3e0d8fb3 2005-12-27 devnull free(s);
1535 3e0d8fb3 2005-12-27 devnull }
1536 3e0d8fb3 2005-12-27 devnull }
1537 3e0d8fb3 2005-12-27 devnull
1538 3e0d8fb3 2005-12-27 devnull void
1539 3e0d8fb3 2005-12-27 devnull addserver(Server **l, char *name)
1540 3e0d8fb3 2005-12-27 devnull {
1541 3e0d8fb3 2005-12-27 devnull Server *s;
1542 3e0d8fb3 2005-12-27 devnull
1543 3e0d8fb3 2005-12-27 devnull while(*l)
1544 3e0d8fb3 2005-12-27 devnull l = &(*l)->next;
1545 3e0d8fb3 2005-12-27 devnull s = malloc(sizeof(Server)+strlen(name)+1);
1546 3e0d8fb3 2005-12-27 devnull if(s == nil)
1547 3e0d8fb3 2005-12-27 devnull return;
1548 3e0d8fb3 2005-12-27 devnull s->name = (char*)(s+1);
1549 3e0d8fb3 2005-12-27 devnull strcpy(s->name, name);
1550 3e0d8fb3 2005-12-27 devnull s->next = nil;
1551 3e0d8fb3 2005-12-27 devnull *l = s;
1552 3e0d8fb3 2005-12-27 devnull }
1553 3e0d8fb3 2005-12-27 devnull
1554 3e0d8fb3 2005-12-27 devnull Server*
1555 3e0d8fb3 2005-12-27 devnull copyserverlist(Server *s)
1556 3e0d8fb3 2005-12-27 devnull {
1557 3e0d8fb3 2005-12-27 devnull Server *ns;
1558 3e0d8fb3 2005-12-27 devnull
1559 3e0d8fb3 2005-12-27 devnull
1560 3e0d8fb3 2005-12-27 devnull for(ns = nil; s != nil; s = s->next)
1561 3e0d8fb3 2005-12-27 devnull addserver(&ns, s->name);
1562 3e0d8fb3 2005-12-27 devnull return ns;
1563 3e0d8fb3 2005-12-27 devnull }