![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to ns_init.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSD / etc / named|
Return to ns_init.c CVS log | Up to [CSRG BSD Unix] / 43BSD / etc / named |
1.1 root 1: #ifndef lint
2: static char sccsid[] = "@(#)ns_init.c 4.3 (Berkeley) 6/4/86";
3: #endif
4:
5: /*
6: * Copyright (c) 1986 Regents of the University of California
7: * All Rights Reserved
8: */
9:
10: #include <sys/types.h>
11: #include <sys/socket.h>
12: #include <sys/time.h>
13: #include <netinet/in.h>
14: #include <stdio.h>
15: #include <errno.h>
16: #include <signal.h>
17: #include <syslog.h>
18: #include <ctype.h>
19: #include <arpa/nameser.h>
20: #include "ns.h"
21: #include "db.h"
22:
23: struct zoneinfo zones[MAXZONES]; /* zone information */
24: int nzones; /* number of zones in use */
25:
26: /*
27: * Read boot file for configuration info.
28: */
29: ns_init(bootfile)
30: char *bootfile;
31: {
32: register struct zoneinfo *zp;
33: char buf[BUFSIZ];
34: char *tm;
35: FILE *fp;
36: int type, first = 1;
37: time_t next_refresh;
38: struct itimerval ival;
39:
40: #ifdef DEBUG
41: if (debug >= 3)
42: fprintf(ddt,"ns_init(%s)\n", bootfile);
43: #endif
44:
45: if ((fp = fopen(bootfile, "r")) == NULL) {
46: syslog(LOG_ERR, "%s: %m", bootfile);
47: exit(1);
48: }
49:
50: /* allocate root hash table */
51: hashtab = savehash((struct hashbuf *)NULL);
52:
53: /* init zone data */
54: nzones = 1; /* zone zero is cache data */
55: while (getword(buf, sizeof(buf), fp)) {
56: /* read 'primary', 'secondary', 'cache' or 'domain' */
57: top:
58: if (cistrcmp(buf, "cache") == 0) {
59: type = Z_CACHE;
60: zp = zones;
61: } else {
62: if (cistrcmp(buf, "primary") == 0)
63: type = Z_PRIMARY;
64: else if (cistrcmp(buf, "secondary") == 0)
65: type = Z_SECONDARY;
66: else if (cistrcmp(buf, "domain") == 0)
67: type = Z_DOMAIN;
68: else {
69: syslog(LOG_ERR, "%s: unknown type", buf);
70: exit(1);
71: }
72: if (nzones >= MAXZONES) {
73: syslog(LOG_ERR, "too many zones");
74: exit(1);
75: }
76: zp = &zones[nzones++];
77: }
78: zp->z_type = type;
79: zp->z_addrcnt = 0;
80: /*
81: * read zone origin
82: */
83: (void) getword(buf, sizeof(buf), fp);
84: if (buf[0] == '.')
85: buf[0] = '\0';
86: zp->z_origin = savestr(buf);
87: /*
88: * read source file or host address
89: */
90: if (type != Z_DOMAIN) {
91: (void) getword(buf, sizeof(buf), fp);
92: zp->z_source = savestr(buf);
93: #ifdef DEBUG
94: if (debug) {
95: fprintf(ddt,"zone found (%d): ", zp->z_type);
96: if (zp->z_origin[0] == '\0')
97: fprintf(ddt,"'.'");
98: else
99: fprintf(ddt,"'%s'", zp->z_origin);
100: fprintf(ddt,", source = %s", zp->z_source);
101: }
102: #endif
103: }
104: #ifdef DEBUG
105: else if (debug)
106: fprintf(ddt,"zone found (%d): domain name = '%s'",
107: zp->z_type, zp->z_origin);
108: #endif
109: switch (zp->z_type) {
110: case Z_PRIMARY:
111: case Z_CACHE:
112: #ifdef DEBUG
113: if (debug)
114: fprintf(ddt,"\n");
115: #endif
116: (void) db_load(zp->z_source, zp->z_origin, zp - zones);
117: break;
118:
119: case Z_SECONDARY:
120: zp->z_addr[zp->z_addrcnt].s_addr =
121: inet_addr(zp->z_source);
122: if (zp->z_addr[zp->z_addrcnt].s_addr != (unsigned)-1)
123: zp->z_addrcnt++;
124: while (getword(buf, sizeof(buf), fp)) {
125: tm = savestr(buf);
126: zp->z_addr[zp->z_addrcnt].s_addr =
127: inet_addr(tm);
128: if (zp->z_addr[zp->z_addrcnt].s_addr ==
129: (unsigned)-1) {
130: #ifdef DEBUG
131: if (debug)
132: fprintf(ddt," (addrcnt) = %d\n",
133: zp->z_addrcnt);
134: #endif
135: zoneinit(zp);
136: if (first) {
137: next_refresh = zp->z_time;
138: first = 0;
139: } else
140: if (next_refresh > zp->z_time)
141: next_refresh = zp->z_time;
142: goto top;
143: }
144: #ifdef DEBUG
145: if (debug)
146: fprintf(ddt,", %s",buf);
147: #endif
148: if (++zp->z_addrcnt >= MAXNS) {
149: zp->z_addrcnt = MAXNS;
150: #ifdef DEBUG
151: if (debug)
152: fprintf(ddt,
153: "\nns.h MAXNS reached\n");
154: #endif
155: break;
156: }
157: }
158: #ifdef DEBUG
159: if (debug)
160: fprintf(ddt," addrcnt = %d\n", zp->z_addrcnt);
161: #endif
162: zoneinit(zp);
163: if (first) {
164: next_refresh = zp->z_time;
165: first = 0;
166: } else
167: if (next_refresh > zp->z_time)
168: next_refresh = zp->z_time;
169: break;
170:
171: case Z_DOMAIN:
172: while (getword(buf, sizeof(buf), fp)) {
173: tm = savestr(buf);
174: zp->z_addr[zp->z_addrcnt].s_addr =
175: inet_addr(tm);
176: if (zp->z_addr[zp->z_addrcnt].s_addr ==
177: (unsigned)-1) {
178: #ifdef DEBUG
179: if (debug)
180: fprintf(ddt," addrcnt = %d\n",
181: zp->z_addrcnt);
182: #endif
183: goto top;
184: }
185: #ifdef DEBUG
186: if (debug)
187: fprintf(ddt,", %s",buf);
188: #endif
189: if (++zp->z_addrcnt >= MAXNS) {
190: zp->z_addrcnt = MAXNS;
191: #ifdef DEBUG
192: if (debug)
193: fprintf(ddt,"\nns.h MAXNS reached\n");
194: #endif
195: break;
196: }
197: }
198: #ifdef DEBUG
199: if (debug)
200: fprintf(ddt," addrcnt = %d\n",
201: zp->z_addrcnt);
202: #endif
203: break;
204:
205: }
206: }
207: (void) fclose(fp);
208: if (!first) {
209: if (gettimeofday(&tt, (struct timezone *)0) < 0) {
210: syslog(LOG_ERR, "gettimeofday failed: %m");
211: ival.it_value.tv_sec = 5 * 60;
212: } else {
213: bzero((char *)&ival, sizeof(ival));
214: ival.it_value.tv_sec = next_refresh - tt.tv_sec;
215: if (ival.it_value.tv_sec < 0)
216: ival.it_value.tv_sec = 60;
217: }
218: } else
219: ival.it_value.tv_sec = 0;
220: (void) setitimer(ITIMER_REAL, &ival, (struct itimerval *)NULL);
221: #if DEBUG
222: if (debug)
223: fprintf(ddt,"exit ns_init() Next interupt in %d sec\n",
224: ival.it_value.tv_sec);
225: #endif
226: }
227:
228: zoneinit(zp)
229: struct zoneinfo *zp;
230: {
231: struct sockaddr_in sin;
232: HEADER *hp;
233: char buf[PACKETSZ];
234: u_short len;
235: char *cp;
236: char *tmp;
237: int s, n, l;
238: int cnt, soacnt, error = 0;
239: int zone = zp - zones;
240: u_long serial;
241: struct itimerval ival;
242: struct itimerval zeroival;
243: extern struct sockaddr_in nsaddr;
244: extern int errno;
245: extern int read_alarm();
246: struct sigvec sv, osv;
247: extern int read_interrupted;
248:
249: #ifdef DEBUG
250: if (debug)
251: fprintf(ddt,"zoneinit()\n");
252: #endif
253:
254: bzero((char *)&zeroival, sizeof(zeroival));
255: ival = zeroival;
256: ival.it_value.tv_sec = 2 * 60;
257: sv.sv_handler = read_alarm;
258: sv.sv_onstack = 0;
259: sv.sv_mask = ~0;
260: (void) sigvec(SIGALRM, &sv, &osv);
261:
262: for( cnt = 0; cnt < zp->z_addrcnt; cnt++) {
263: error = 0;
264: bzero((char *)&sin, sizeof(sin));
265: sin.sin_family = AF_INET;
266: sin.sin_port = nsaddr.sin_port;
267: sin.sin_addr = zp->z_addr[cnt];
268: if ((n = res_mkquery(QUERY, zp->z_origin, C_IN, T_AXFR,
269: (char *)NULL, 0, NULL, buf, sizeof(buf))) < 0) {
270: syslog(LOG_ERR, "zoneinit: res_mkquery failed");
271: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0);
272: return;
273: }
274: if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
275: syslog(LOG_ERR, "zoneref: socket: %m");
276: exit(1);
277: }
278: #ifdef DEBUG
279: if (debug >= 2) {
280: fprintf(ddt,"connecting to server #%d %s, %d (%d)\n",
281: cnt+1, inet_ntoa(sin.sin_addr),
282: ntohs(sin.sin_port), n);
283: }
284: #endif
285: if (connect(s, &sin, sizeof(sin)) < 0) {
286: (void) close(s);
287: error++;
288: #ifdef DEBUG
289: if (debug >= 2)
290: fprintf(ddt,"connect failed\n");
291: #endif
292: continue;
293: }
294: /*
295: * Send length & message for zone transfer
296: */
297: if (writemsg(s, buf, n) < 0) {
298: (void) close(s);
299: error++;
300: #ifdef DEBUG
301: if (debug >= 2)
302: fprintf(ddt,"writemsg failed\n");
303: #endif
304: continue;
305: }
306:
307: hp = (HEADER *) buf;
308: soacnt = 0;
309:
310: for (;;) {
311: /*
312: * Receive length & response
313: */
314: cp = buf;
315: l = sizeof(u_short);
316: read_interrupted = 0;
317: while (l > 0) {
318: (void) setitimer(ITIMER_REAL, &ival,
319: (struct itimerval *)NULL);
320: if ((n = recv(s, cp, l, 0)) > 0) {
321: cp += n;
322: l -= n;
323: } else {
324: if (errno == EINTR && !read_interrupted)
325: continue;
326: error++;
327: break;
328: }
329: }
330: (void) setitimer(ITIMER_REAL, &zeroival,
331: (struct itimerval *)NULL);
332: if (error)
333: break;
334: if ((len = htons(*(u_short *)buf)) == 0)
335: break;
336: l = len;
337: cp = buf;
338: while (l > 0) {
339: (void) setitimer(ITIMER_REAL, &ival,
340: (struct itimerval *)NULL);
341: if ((n = recv(s, cp, l, 0)) > 0) {
342: cp += n;
343: l -= n;
344: } else {
345: if (errno == EINTR && !read_interrupted)
346: continue;
347: error++;
348: break;
349: }
350: }
351: (void) setitimer(ITIMER_REAL, &zeroival,
352: (struct itimerval *)NULL);
353: if (error)
354: break;
355: #ifdef DEBUG
356: if (debug >= 3) {
357: fprintf(ddt,"len = %d\n", len);
358: fp_query(buf, ddt);
359: }
360: #endif
361: cp = buf + sizeof(HEADER);
362: if (hp->qdcount)
363: cp += dn_skip(cp) + QFIXEDSZ;
364: tmp = cp + dn_skip(cp);
365: n = doupdate(buf, sizeof(buf), cp, zone, 0);
366: if ((cp - buf) + n != len) {
367: #ifdef DEBUG
368: if (debug)
369: fprintf(ddt,"zoneinit: doupdate failed (%d, %d)\n",
370: cp - buf, n);
371: #endif
372: error++;
373: break;
374: }
375: if ((getshort(tmp)) == T_SOA) {
376: if (soacnt == 0) {
377: soacnt++;
378: tmp += 3 * sizeof(u_short)
379: + sizeof(u_long);
380: tmp += dn_skip(tmp);
381: tmp += dn_skip(tmp);
382: serial = getlong(tmp);
383: continue;
384: }
385: soa_zinfo(zp, tmp);
386: if (serial != zp->z_serial)
387: soacnt = 0;
388: else {
389: break;
390: }
391: }
392: }
393: (void) close(s);
394: if ( error == 0) {
395: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0);
396: return;
397: }
398: #ifdef DEBUG
399: if (debug >= 2)
400: fprintf(ddt,"error reciving zone transfer\n");
401: #endif
402: }
403: /*
404: * Freedom at last!!
405: *
406: * The land where all repressed slaves dream of.
407: *
408: * Can't find a master to talk to.
409: * syslog it and hope we can find a master during maintenance
410: */
411: if (error)
412: syslog(LOG_ERR, "zoneinit: Can't find Master for secondary zone %s",
413: zp->z_origin);
414: /*
415: * Set zone to be refreshed in 5 min.
416: * maybe by then we can refresh it.
417: */
418: zp->z_refresh = 300; /* 300 seconds = 5 Min. */
419: zp->z_retry = 300;
420: if (gettimeofday(&tt, (struct timezone *)0) < 0)
421: syslog(LOG_ERR, "gettimeofday failed: %m");
422: zp->z_time = tt.tv_sec + 300;
423: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0);
424: return;
425: }
426: #ifdef notdef
427: /*
428: * Look for an authoritative zone that matches the RHS of dname
429: * and return is zone # or zero if not found.
430: */
431: findzone(dname, class)
432: char *dname;
433: int class;
434: {
435: register struct zoneinfo *zp;
436: register char *d1, *d2;
437: register int c;
438: char *end;
439:
440: end = dname + strlen(dname);
441: for (zp = &zones[1]; zp < &zones[nzones]; zp++) {
442: d1 = end;
443: d2 = zp->z_origin + strlen(zp->z_origin);
444: while (d2 > zp->z_origin) {
445: if ((c*--
446: }
447: return (zp - zones);
448: }
449: return (0);
450: }
451: #endif
452:
453: soa_zinfo(zp, cp)
454: struct zoneinfo *zp;
455: char *cp;
456: {
457: cp += 3 * sizeof(u_short);
458: cp += sizeof(u_long);
459: cp += dn_skip(cp);
460: cp += dn_skip(cp);
461: zp->z_serial = getlong(cp);
462: cp += sizeof(u_long);
463: zp->z_refresh = getlong(cp);
464: if (gettimeofday(&tt, (struct timezone *)0) < 0)
465: syslog(LOG_ERR, "gettimeofday failed: %m");
466: zp->z_time = tt.tv_sec + zp->z_refresh;
467: cp += sizeof(u_long);
468: zp->z_retry = getlong(cp);
469: cp += sizeof(u_long);
470: zp->z_expire = getlong(cp);
471: cp += sizeof(u_long);
472: zp->z_minimum = getlong(cp);
473: cp += sizeof(u_long);
474: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.