4.3BSD-Reno/src/usr.sbin/named/ns_init.c
/*-
* Copyright (c) 1986, 1990 The Regents of the University of California.
* All rights reserved.
*
* Redistribution and use in source and binary forms are permitted provided
* that: (1) source distributions retain this entire copyright notice and
* comment, and (2) distributions including binaries display the following
* acknowledgement: ``This product includes software developed by the
* University of California, Berkeley and its contributors'' in the
* documentation or other materials provided with the distribution and in
* all advertising materials mentioning features or use of this software.
* Neither the name of the University nor the names of its contributors may
* be used to endorse or promote products derived from this software without
* specific prior written permission.
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR IMPLIED
* WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES OF
* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
*/
#ifndef lint
static char sccsid[] = "@(#)ns_init.c 4.35 (Berkeley) 6/27/90";
#endif /* not lint */
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <sys/stat.h>
#include <netinet/in.h>
#include <stdio.h>
#include <errno.h>
#include <signal.h>
#include <syslog.h>
#include <ctype.h>
#include <string.h>
#include <arpa/nameser.h>
#include "pathnames.h"
#include "ns.h"
#include "db.h"
struct zoneinfo *zones; /* zone information */
int nzones; /* number of zones in use */
int forward_only = 0; /* run only as a slave */
char *cache_file;
char *localdomain; /* "default" for non-dotted names */
int maint_interval = 15*60; /* minimum ns_maint() interval */
extern int lineno;
/*
* Read boot file for configuration info.
*/
ns_init(bootfile)
char *bootfile;
{
register struct zoneinfo *zp;
struct zoneinfo *find_zone();
char buf[BUFSIZ], obuf[BUFSIZ], *source;
extern char *calloc();
FILE *fp;
int type;
extern int needmaint;
struct stat f_time;
static int loads = 0; /* number of times loaded */
static int tmpnum = 0; /* unique number for tmp zone files */
#ifdef ALLOW_UPDATES
char *cp, *flag;
#endif
#ifdef DEBUG
if (debug)
fprintf(ddt,"\nns_init(%s)\n", bootfile);
#endif
gettime(&tt);
if ((fp = fopen(bootfile, "r")) == NULL) {
syslog(LOG_ERR, "%s: %m", bootfile);
exit(1);
}
lineno = 0;
if (loads == 0) {
if ((zones =
(struct zoneinfo *)calloc(64, sizeof(struct zoneinfo)))
== NULL) {
syslog(LOG_ERR,
"Not enough memory to allocate initial zones array");
exit(1);
}
nzones = 1; /* zone zero is cache data */
/* allocate cache hash table, formerly the root hash table. */
hashtab = savehash((struct hashbuf *)NULL);
/* allocate root-hints/file-cache hash table */
fcachetab = savehash((struct hashbuf *)NULL);
/* init zone data */
zones[0].z_type = Z_CACHE;
} else {
/* Mark previous zones as not yet found in boot file. */
for (zp = &zones[1]; zp < &zones[nzones]; zp++)
zp->z_state &= ~Z_FOUND;
if (localdomain)
free(localdomain);
localdomain = NULL;
free_forwarders();
forward_only = 0;
}
#ifdef DEBUG
if (debug >= 3) {
fprintf(ddt,"\n content of zones before loading \n");
content_zone(nzones - 1);
}
#endif
while (!feof(fp) && !ferror(fp)) {
if (!getword(buf, sizeof(buf), fp))
continue;
/* read named.boot keyword and process args */
if (strcasecmp(buf, "directory") == 0) {
(void) getword(buf, sizeof(buf), fp);
if (chdir(buf) < 0) {
syslog(LOG_CRIT, "directory %s: %m\n",
buf);
exit(1);
}
continue;
} else if (strcasecmp(buf, "sortlist") == 0) {
get_sort_list(fp);
continue;
} else if (strcasecmp(buf, "forwarders") == 0) {
get_forwarders(fp);
continue;
} else if (strcasecmp(buf, "slave") == 0) {
forward_only++;
endline(fp);
continue;
} else if (strcasecmp(buf, "domain") == 0) {
if (getword(buf, sizeof(buf), fp))
localdomain = savestr(buf);
endline(fp);
continue;
} else if (strcasecmp(buf, "cache") == 0)
type = Z_CACHE;
else if (strcasecmp(buf, "primary") == 0)
type = Z_PRIMARY;
else if (strcasecmp(buf, "secondary") == 0)
type = Z_SECONDARY;
else {
syslog(LOG_ERR, "%s: line %d: unknown field '%s'\n",
bootfile, lineno, buf);
endline(fp);
continue;
}
/*
* read zone origin
*/
if (!getword(obuf, sizeof(obuf), fp)) {
syslog(LOG_ERR, "%s: line %d: missing origin\n",
bootfile, lineno);
continue;
}
#ifdef DEBUG
if (debug)
fprintf(ddt, "zone origin %s", obuf);
#endif
if (obuf[0] == '.' && obuf[1] == '\0')
obuf[0] = '\0';
/*
* read source file or host address
*/
if (!getword(buf, sizeof(buf), fp)) {
syslog(LOG_ERR,
"%s: line %d: missing source or addr\n",
bootfile, lineno);
continue;
}
/* check for previous instance of this zone (reload) */
if ((zp = find_zone(obuf, type)) == 0) {
if (type == Z_CACHE) {
zp = &zones[0];
zp->z_origin = "";
goto gotzone;
}
for (zp = &zones[1]; zp < &zones[nzones]; zp++)
if (zp->z_type == 0)
goto gotzone;
/*
* this code assume that nzones never decreases
*/
if (nzones % 64 == 0) {
#ifdef DEBUG
if (debug > 1)
fprintf(ddt, "Reallocating zones structure\n");
#endif DEBUG
/*
* Realloc() not used since it might damage zones
* if an error occurs
*/
if ((zp = (struct zoneinfo *)
malloc((64 + nzones) * sizeof(struct zoneinfo)))
== NULL) {
syslog(LOG_ERR, "no memory for more zones");
#ifdef DEBUG
if (debug)
fprintf(ddt,
"Out of memory for new zones\n");
#endif DEBUG
endline(fp);
continue;
}
bcopy((char *)zones, (char *)zp,
nzones * sizeof(struct zoneinfo));
bzero((char *)&zp[nzones],
64 * sizeof(struct zoneinfo));
free(zones);
zones = zp;
}
zp = &zones[nzones++];
gotzone:
zp->z_origin = savestr(obuf);
zp->z_type = type;
}
zp->z_addrcnt = 0;
switch (type) {
case Z_CACHE:
source = savestr(buf);
#ifdef DEBUG
if (debug)
fprintf(ddt,", source = %s\n", source);
#endif
zp->z_refresh = 0; /* by default, no dumping */
if (getword(buf, sizeof(buf), fp)) {
#ifdef notyet
zp->z_refresh = atoi(buf);
if (zp->z_refresh <= 0) {
syslog(LOG_ERR,
"%s: line %d: bad refresh time '%s', ignored\n",
bootfile, lineno, buf);
zp->z_refresh = 0;
} else if (cache_file == NULL)
cache_file = source;
#else
syslog(LOG_WARNING,
"%s: line %d: cache refresh ignored\n",
bootfile, lineno);
#endif
endline(fp);
}
/*
* If we've loaded this file, and the file has
* not been modified and contains no $include,
* then there's no need to reload.
*/
if (zp->z_source && strcmp(source, zp->z_source) == 0 &&
(zp->z_state & Z_INCLUDE) == 0 &&
stat(zp->z_source, &f_time) == 0 &&
zp->z_ftime == f_time.st_mtime) {
#ifdef DEBUG
if (debug)
fprintf(ddt, "cache is up to date\n");
#endif
break; /* zone is already up to date */
}
/* file has changed, or hasn't been loaded yet */
if (zp->z_source) {
free(zp->z_source);
remove_zone(fcachetab, 0);
}
zp->z_source = source;
#ifdef DEBUG
if (debug)
fprintf(ddt, "reloading zone\n");
#endif
(void) db_load(zp->z_source, zp->z_origin, zp, 0);
break;
case Z_PRIMARY:
source = savestr(buf);
#ifdef ALLOW_UPDATES
if (getword(buf, sizeof(buf), fp)) {
endline(fp);
flag = buf;
while (flag) {
cp = index(flag, ',');
if (cp)
*cp++ = 0;
if (strcasecmp(flag, "dynamic") == 0)
zp->z_state |= Z_DYNAMIC;
else if (strcasecmp(flag, "addonly") == 0)
zp->z_state |= Z_DYNADDONLY;
else {
syslog(LOG_ERR,
"%s: line %d: bad flag '%s'\n",
bootfile, lineno, flag);
}
flag = cp;
}
}
#else ALLOW_UPDATES
endline(fp);
#endif
#ifdef DEBUG
if (debug)
fprintf(ddt,", source = %s\n", source);
#endif
/*
* If we've loaded this file, and the file has
* not been modified and contains no $include,
* then there's no need to reload.
*/
if (zp->z_source && strcmp(source, zp->z_source) == 0 &&
(zp->z_state & Z_INCLUDE) == 0 &&
stat(zp->z_source, &f_time) == 0 &&
zp->z_ftime == f_time.st_mtime) {
#ifdef DEBUG
if (debug)
fprintf(ddt, "zone is up to date\n");
#endif
break; /* zone is already up to date */
}
if (zp->z_source) {
free(zp->z_source);
remove_zone(hashtab, zp - zones);
}
zp->z_source = source;
zp->z_auth = 0;
#ifdef DEBUG
if (debug)
fprintf(ddt, "reloading zone\n");
#endif
if (db_load(zp->z_source, zp->z_origin, zp, 0) == 0)
zp->z_auth = 1;
#ifdef ALLOW_UPDATES
/* Guarantee calls to ns_maint() */
zp->z_refresh = maint_interval;
#else ALLOW_UPDATES
zp->z_refresh = 0; /* no maintenance needed */
zp->z_time = 0;
#endif ALLOW_UPDATES
break;
case Z_SECONDARY:
source = 0;
#ifdef DEBUG
if (debug)
fprintf(ddt,"\n\taddrs: ");
#endif
do {
zp->z_addr[zp->z_addrcnt].s_addr =
inet_addr(buf);
if (zp->z_addr[zp->z_addrcnt].s_addr ==
(u_long)-1) {
source = savestr(buf);
endline(fp);
break;
}
#ifdef DEBUG
if (debug)
fprintf(ddt,"%s, ",buf);
#endif
if (++zp->z_addrcnt > NSMAX - 1) {
zp->z_addrcnt = NSMAX - 1;
#ifdef DEBUG
if (debug)
fprintf(ddt,
"\nns.h NSMAX reached\n");
#endif
}
} while (getword(buf, sizeof(buf), fp));
#ifdef DEBUG
if (debug)
fprintf(ddt,"addrcnt = %d\n", zp->z_addrcnt);
#endif
if (source == 0) {
/*
* We will always transfer this zone again
* after a reload.
*/
sprintf(buf, "/%s/NsTmp%d", _PATH_TMPDIR,
tmpnum++);
source = savestr(buf);
zp->z_state |= Z_TMP_FILE;
} else
zp->z_state &= ~Z_TMP_FILE;
/*
* If we had a backup file name, and it was changed,
* free old zone and start over. If we don't have
* current zone contents, try again now in case
* we have a new server on the list.
*/
if (zp->z_source && strcmp(source, zp->z_source)) {
#ifdef DEBUG
if (debug)
fprintf(ddt,"backup file changed\n");
#endif
free(zp->z_source);
zp->z_source = 0;
zp->z_auth = 0;
zp->z_serial = 0; /* force xfer */
remove_zone(hashtab, zp - zones);
}
if (zp->z_source)
free(source);
else
zp->z_source = source;
if (zp->z_auth == 0)
zoneinit(zp);
break;
}
zp->z_state |= Z_FOUND;
#ifdef DEBUG
if (debug)
fprintf(ddt,"zone[%d] type %d: '%s'",
zp-zones, type,
*(zp->z_origin) == '\0' ? "." : zp->z_origin);
#endif
if (zp->z_refresh && zp->z_time == 0)
zp->z_time = zp->z_refresh + tt.tv_sec;
if (zp->z_time <= tt.tv_sec)
needmaint = 1;
#ifdef DEBUG
if (debug)
fprintf(ddt, " z_time %d, z_refresh %d\n",
zp->z_time, zp->z_refresh);
#endif
}
(void) fclose(fp);
/* erase all old zones that were not found */
for (zp = &zones[1]; zp < &zones[nzones]; zp++)
if (zp->z_type && (zp->z_state & Z_FOUND) == 0) {
remove_zone(hashtab, zp - zones);
bzero((char *) zp, sizeof(*zp));
#ifdef DEBUG
if(debug >=2)
fprintf(ddt,"\n zone no %d was removed \n", zp - zones);
#endif
}
#ifdef DEBUG
if(debug >= 2) {
fprintf(ddt,"\n content of zones after loading \n");
content_zone(nzones-1);
}
#endif
/*
* Schedule calls to ns_maint().
*/
if (needmaint == 0)
sched_maint();
#ifdef DEBUG
if (debug)
fprintf(ddt,"exit ns_init()%s\n", needmaint ?
", need maintenance immediately" : "");
#endif
loads++;
}
zoneinit(zp)
register struct zoneinfo *zp;
{
extern int needmaint;
struct stat sb;
/*
* Try to load zone from backup file,
* if one was specified and it exists.
* If not, or if the data are out of date,
* we will refresh the zone from a primary
* immediately.
*/
if (zp->z_source == NULL)
return;
if (stat(zp->z_source, &sb) == -1 ||
db_load(zp->z_source, zp->z_origin, zp, 0) != 0) {
/*
* Set zone to be refreshed immediately.
*/
zp->z_refresh = INIT_REFRESH;
zp->z_retry = INIT_REFRESH;
zp->z_time = tt.tv_sec;
needmaint = 1;
} else
zp->z_auth = 1;
}
#ifdef ALLOW_UPDATES
/*
* Look for the authoritative zone with the longest matching RHS of dname
* and return its zone # or zero if not found.
*/
findzone(dname, class)
char *dname;
int class;
{
char *dZoneName, *zoneName, *index();
int dZoneNameLen, zoneNameLen;
int maxMatchLen = 0;
int maxMatchZoneNum = 0;
int zoneNum;
#ifdef DEBUG
if (debug >= 4)
fprintf(ddt, "findzone(dname=%s, class=%d)\n", dname, class);
if (debug >= 5) {
fprintf(ddt, "zone dump:\n");
for (zoneNum = 1; zoneNum < nzones; zoneNum++)
printzoneinfo(zoneNum);
}
#endif DEBUG
dZoneName = index(dname, '.');
if (dZoneName == NULL)
dZoneName = ""; /* root */
else
dZoneName++; /* There is a '.' in dname, so use remainder of
string as the zone name */
dZoneNameLen = strlen(dZoneName);
for (zoneNum = 1; zoneNum < nzones; zoneNum++) {
zoneName = (zones[zoneNum]).z_origin;
zoneNameLen = strlen(zoneName);
/* The zone name may or may not end with a '.' */
if (zoneName[zoneNameLen - 1] == '.')
zoneNameLen--;
if (dZoneNameLen != zoneNameLen)
continue;
#ifdef DEBUG
if (debug >= 5)
fprintf(ddt, "about to strncasecmp('%s', '%s', %d)\n",
dZoneName, zoneName, dZoneNameLen);
#endif
if (strncasecmp(dZoneName, zoneName, dZoneNameLen) == 0) {
#ifdef DEBUG
if (debug >= 5)
fprintf(ddt, "match\n");
#endif
/*
* See if this is as long a match as any so far.
* Check if "<=" instead of just "<" so that if
* root domain (whose name length is 0) matches,
* we use it's zone number instead of just 0
*/
if (maxMatchLen <= zoneNameLen) {
maxMatchZoneNum = zoneNum;
maxMatchLen = zoneNameLen;
}
}
#ifdef DEBUG
else
if (debug >= 5)
fprintf(ddt, "no match\n");
#endif
}
#ifdef DEBUG
if (debug >= 4)
fprintf(ddt, "findzone: returning %d\n", maxMatchZoneNum);
#endif DEBUG
return (maxMatchZoneNum);
}
#endif ALLOW_UPDATES
soa_zinfo(zp, cp, eom)
register struct zoneinfo *zp;
register u_char *cp;
u_char *eom;
{
cp += 3 * sizeof(u_short);
cp += sizeof(u_long);
cp += dn_skipname(cp, eom);
cp += dn_skipname(cp, eom);
GETLONG(zp->z_serial, cp);
GETLONG(zp->z_refresh, cp);
gettime(&tt);
zp->z_time = tt.tv_sec + zp->z_refresh;
GETLONG(zp->z_retry, cp);
GETLONG(zp->z_expire, cp);
GETLONG(zp->z_minimum, cp);
}
get_forwarders(fp)
FILE *fp;
{
char buf[BUFSIZ];
register struct fwdinfo *fip = NULL, *ftp = NULL;
extern struct sockaddr_in nsaddr;
extern struct fwdinfo *fwdtab;
#ifdef DEBUG
if (debug)
fprintf(ddt,"forwarders ");
#endif
/* on mulitple forwarder lines, move to end of the list */
if (fwdtab != NULL)
for (fip = fwdtab; fip->next != NULL; fip = fip->next)
;
while (getword(buf, sizeof(buf), fp)) {
if (strlen(buf) == 0)
break;
#ifdef DEBUG
if (debug)
fprintf(ddt," %s",buf);
#endif
if (ftp == NULL)
ftp = (struct fwdinfo *)malloc(sizeof(struct fwdinfo));
if (isdigit(buf[0]) &&
(ftp->fwdaddr.sin_addr.s_addr = inet_addr(buf)) !=
(u_long)-1) {
ftp->fwdaddr.sin_port = nsaddr.sin_port;
ftp->fwdaddr.sin_family = AF_INET;
} else {
syslog(LOG_ERR, "'%s' (ignored, NOT dotted quad)", buf);
#ifdef DEBUG
if (debug)
fprintf(ddt," (ignored, NOT dotted quad)");
#endif
continue;
}
ftp->next = NULL;
if (fwdtab == NULL)
fwdtab = ftp; /* First time only */
else
fip->next = ftp;
fip = ftp;
ftp = NULL;
}
if (ftp)
free((char *)ftp);
#ifdef DEBUG
if (debug)
fprintf(ddt,"\n");
if (debug > 2)
for (ftp = fwdtab; ftp != NULL; ftp = ftp->next)
fprintf(ddt,"ftp x%x %s next x%x\n", ftp,
inet_ntoa(ftp->fwdaddr.sin_addr), ftp->next);
#endif
}
free_forwarders()
{
extern struct fwdinfo *fwdtab;
register struct fwdinfo *ftp, *fnext;
for (ftp = fwdtab; ftp != NULL; ftp = fnext) {
fnext = ftp->next;
free((char *)ftp);
}
fwdtab = NULL;
}
struct zoneinfo *
find_zone(name, type)
char *name;
int type;
{
register struct zoneinfo *zp;
for (zp = &zones[1]; zp < &zones[nzones]; zp++)
if (zp->z_type == type && strcasecmp(name, zp->z_origin) == 0) {
#ifdef DEBUG
if (debug > 1)
fprintf(ddt, ", old zone (%d)", zp - zones);
#endif
return (zp);
}
#ifdef DEBUG
if(debug > 1)
fprintf(ddt, ", new zone");
#endif
return ((struct zoneinfo *)NULL);
}
/* prints out the content of zones */
content_zone(end)
int end;
{
int i;
for (i = 1; i <= end; i++)
printzoneinfo(i);
}