2.11BSD/src/usr.sbin/named/named/db_load.c
/*
* Copyright (c) 1986 Regents of the University of California.
* All rights reserved.
*
* Redistribution and use in source and binary forms are permitted
* provided that this notice is preserved and that due credit is given
* to the University of California at Berkeley. The name of the University
* may not be used to endorse or promote products derived from this
* software without specific prior written permission. This software
* is provided ``as is'' without express or implied warranty.
*/
#ifndef lint
static char sccsid[] = "@(#)db_load.c 4.26 (Berkeley) 2/28/88";
#endif /* not lint */
/*
* Load data base from ascii backupfile. Format similar to RFC 883.
*/
#include <sys/param.h>
#include <sys/time.h>
#include <sys/stat.h>
#include <netinet/in.h>
#include <stdio.h>
#include <syslog.h>
#include <ctype.h>
#include <netdb.h>
#include <arpa/nameser.h>
#include "ns.h"
#include "db.h"
extern char *index();
u_long getnum();
extern u_long net_mask();
extern u_long max_cache_ttl;
/*
* Map class and type names to number
*/
struct map {
char token[8];
int val;
};
struct map m_class[] = {
"in", C_IN,
#ifdef notdef
"any", C_ANY, /* any is a QCLASS, not CLASS */
#endif
"chaos", C_CHAOS,
};
#define NCLASS (sizeof(m_class)/sizeof(struct map))
struct map m_type[] = {
"a", T_A,
"ns", T_NS,
"cname", T_CNAME,
"soa", T_SOA,
"mb", T_MB,
"mg", T_MG,
"mr", T_MR,
"null", T_NULL,
"wks", T_WKS,
"ptr", T_PTR,
"hinfo", T_HINFO,
"minfo", T_MINFO,
"mx", T_MX,
"uinfo", T_UINFO,
"uid", T_UID,
"gid", T_GID,
#ifdef notdef
"any", T_ANY, /* any is a QTYPE, not TYPE */
#endif
#ifdef ALLOW_T_UNSPEC
"unspec", T_UNSPEC,
#endif ALLOW_T_UNSPEC
};
#define NTYPE (sizeof(m_type)/sizeof(struct map))
/*
* Parser token values
*/
#define CURRENT 1
#define DOT 2
#define AT 3
#define DNAME 4
#define INCLUDE 5
#define ORIGIN 6
#define ERROR 7
int lineno; /* current line number */
struct valuelist {
struct valuelist *next, *prev;
char *name;
char *proto;
short port;
} *servicelist, *protolist;
/*
* Load the database from 'filename'. Origin is appended to all domain
* names in the file.
*/
db_load(filename, in_origin, zp)
char *filename, *in_origin;
struct zoneinfo *zp;
{
register u_char *cp;
register struct map *mp;
char domain[MAXDNAME];
char origin[MAXDNAME];
char tmporigin[MAXDNAME];
u_char buf[BUFSIZ];
u_char data[MAXDATA];
char *op;
int c;
int class, type, dbflags, dataflags;
u_long ttl;
struct databuf *dp;
FILE *fp;
int slineno, i, errs = 0, didinclude = 0;
register u_long n;
struct stat sb;
#ifdef DEBUG
if (debug)
fprintf(ddt,"db_load(%s, %s, %d)\n",
filename, in_origin, zp - zones);
#endif
(void) strcpy(origin, in_origin);
if ((fp = fopen(filename, "r")) == NULL) {
if (zp->z_type != Z_SECONDARY)
syslog(LOG_ERR, "%s: %m", filename);
#ifdef DEBUG
if (debug)
fprintf(ddt,"db_load: error opening file %s\n", filename);
#endif
return (-1);
}
if (zp->z_type == Z_CACHE) {
dbflags = DB_NODATA | DB_NOHINTS;
dataflags = DB_F_HINT;
} else {
dbflags = DB_NODATA;
dataflags = 0;
}
gettime(&tt);
if (fstat(fileno(fp), &sb) < 0) {
syslog(LOG_ERR, "%s: %m", filename);
sb.st_mtime = (int)tt.tv_sec;
}
slineno = lineno;
lineno = 1;
domain[0] = '\0';
class = C_IN;
while ((c = gettoken(fp)) != EOF) {
switch (c) {
case INCLUDE:
if (!getword(buf, sizeof(buf), fp)) /* file name */
break;
if (!getword(tmporigin, sizeof(tmporigin), fp))
strcpy(tmporigin, origin);
else {
makename(tmporigin, origin);
endline(fp);
}
didinclude = 1;
errs += db_load(buf, tmporigin, zp);
continue;
case ORIGIN:
(void) strcpy(buf, origin);
if (!getword(origin, sizeof(origin), fp))
break;
#ifdef DEBUG
if (debug > 3)
fprintf(ddt,"db_load: origin %s, buf %s\n",
origin, buf);
#endif
makename(origin, buf);
#ifdef DEBUG
if (debug > 3)
fprintf(ddt,"db_load: origin now %s\n", origin);
#endif
continue;
case DNAME:
if (!getword(domain, sizeof(domain), fp))
break;
n = strlen(domain) - 1;
if (domain[n] == '.')
domain[n] = '\0';
else if (*origin) {
(void) strcat(domain, ".");
(void) strcat(domain, origin);
}
goto gotdomain;
case AT:
(void) strcpy(domain, origin);
goto gotdomain;
case DOT:
domain[0] = '\0';
/* fall thru ... */
case CURRENT:
gotdomain:
if (!getword(buf, sizeof(buf), fp)) {
if (c == CURRENT)
continue;
break;
}
cp = buf;
ttl = 0;
if (isdigit(*cp)) {
n = 0;
do
n = n * 10 + (*cp++ - '0');
while (isdigit(*cp));
if (zp->z_type == Z_CACHE) {
/* this allows the cache entry to age */
/* while sitting on disk (powered off) */
if (n > max_cache_ttl)
n = max_cache_ttl;
n += sb.st_mtime;
}
ttl = n;
if (!getword(buf, sizeof(buf), fp))
break;
}
for (mp = m_class; mp < m_class+NCLASS; mp++)
if (!strcasecmp(buf, mp->token)) {
class = mp->val;
(void) getword(buf, sizeof(buf), fp);
break;
}
for (mp = m_type; mp < m_type+NTYPE; mp++)
if (!strcasecmp(buf, mp->token)) {
type = mp->val;
goto fndtype;
}
#ifdef DEBUG
if (debug)
fprintf(ddt,"Line %d: Unknown type: %s.\n",
lineno, buf);
#endif
errs++;
syslog(LOG_ERR, "Line %d: Unknown type: %s.\n",
lineno, buf);
break;
fndtype:
#ifdef ALLOW_T_UNSPEC
/* Don't do anything here for T_UNSPEC...
* read input separately later
*/
if (type != T_UNSPEC) {
#endif ALLOW_T_UNSPEC
if (!getword(buf, sizeof(buf), fp))
break;
#ifdef DEBUG
if (debug >= 3)
fprintf(ddt,
"d='%s', c=%d, t=%d, ttl=%ld, data='%s'\n",
domain, class, type, ttl, buf);
#endif
#ifdef ALLOW_T_UNSPEC
}
#endif ALLOW_T_UNSPEC
/*
* Convert the ascii data 'buf' to the proper format
* based on the type and pack into 'data'.
*/
switch (type) {
case T_A:
n = ntohl((u_long)inet_addr((char *)buf));
cp = data;
PUTLONG(n, cp);
n = sizeof(u_long);
break;
case T_HINFO:
n = strlen(buf);
if (n > 255) {
syslog(LOG_WARNING,
"%s: line %d: CPU type too long",
filename, lineno);
n = 255;
}
data[0] = n;
bcopy(buf, (char *)data + 1, (int)n);
n++;
if (!getword(buf, sizeof(buf), fp))
break;
i = strlen(buf);
if (i > 255) {
syslog(LOG_WARNING,
"%s: line %d: OS type too long",
filename, lineno);
i = 255;
}
data[n] = i;
bcopy(buf, (char *)data + n + 1, i);
n += i + 1;
endline(fp);
break;
case T_SOA:
case T_MINFO:
(void) strcpy(data, buf);
makename(data, origin);
cp = data + strlen(data) + 1;
if (!getword(cp, sizeof(data) - (cp - data),fp)) {
n = cp - data;
break;
}
makename(cp, origin);
cp += strlen(cp) + 1;
if (type == T_MINFO) {
n = cp - data;
break;
}
if (getnonblank(fp) != '(')
goto err;
zp->z_serial = getnum(fp);
n = (u_long) zp->z_serial;
PUTLONG(n, cp);
zp->z_refresh = getnum(fp);
n = (u_long) zp->z_refresh;
PUTLONG(n, cp);
zp->z_time = sb.st_mtime + zp->z_refresh;
zp->z_retry = getnum(fp);
n = (u_long) zp->z_retry;
PUTLONG(n, cp);
zp->z_expire = getnum(fp);
n = (u_long) zp->z_expire;
PUTLONG (n, cp);
zp->z_minimum = getnum(fp);
n = (u_long) zp->z_minimum;
PUTLONG (n, cp);
n = cp - data;
if (getnonblank(fp) != ')')
goto err;
endline(fp);
break;
case T_UID:
case T_GID:
n = 0;
cp = buf;
while (isdigit(*cp))
n = n * 10 + (*cp++ - '0');
if (cp == buf)
goto err;
cp = data;
PUTLONG(n, cp);
n = sizeof(long);
break;
case T_WKS:
/* Address */
n = ntohl((u_long)inet_addr((char *)buf));
cp = data;
PUTLONG(n, cp);
*cp = getprotocol(fp, filename);
/* Protocol */
n = sizeof(u_long) + sizeof(char);
/* Services */
n = getservices((int)n, data, fp, filename);
break;
case T_NS:
case T_CNAME:
case T_MB:
case T_MG:
case T_MR:
case T_PTR:
(void) strcpy(data, buf);
makename(data, origin);
n = strlen(data) + 1;
break;
case T_UINFO:
cp = (u_char *)index(buf, '&');
bzero(data, sizeof(data));
if ( cp != NULL) {
(void) strncpy(data, buf, cp - buf);
op = index(domain, '.');
if ( op != NULL)
(void) strncat(data,
domain,op-domain);
else
(void) strcat(data, domain);
(void) strcat(data, ++cp);
} else
(void) strcpy(data, buf);
n = strlen(data) + 1;
break;
case T_MX:
n = 0;
cp = buf;
while (isdigit(*cp))
n = n * 10 + (*cp++ - '0');
/* catch bad values */
if ((cp == buf) || (n > 64535))
goto err;
cp = data;
PUTSHORT((u_short)n, cp);
if (!getword(buf, sizeof(buf), fp))
break;
(void) strcpy(cp,buf);
makename(cp, origin);
/* get pointer to place in data */
cp += strlen(cp) +1;
/* now save length */
n = (cp - data);
break;
#ifdef ALLOW_T_UNSPEC
case T_UNSPEC:
{
int rcode;
fgets(buf, sizeof(buf), fp);
#ifdef DEBUG
if (debug)
fprintf(ddt, "loading T_UNSPEC\n");
#endif DEBUG
if (rcode = atob(buf, strlen(buf), data, MAXDATA, &n)) {
if (rcode == CONV_OVERFLOW) {
#ifdef DEBUG
if (debug)
fprintf(ddt,
"Load T_UNSPEC: input buffer overflow\n");
#endif DEBUG
errs++;
syslog(LOG_ERR,
"Load T_UNSPEC: input buffer overflow");
} else {
#ifdef DEBUG
if (debug)
fprintf(ddt,
"Load T_UNSPEC: Data in bad atob format\n");
#endif DEBUG
errs++;
syslog(LOG_ERR,
"Load T_UNSPEC: Data in bad atob format");
}
}
}
break;
#endif ALLOW_T_UNSPEC
default:
goto err;
}
dp = savedata(class, type, (u_long)ttl, data, (int)n);
dp->d_zone = zp - zones;
dp->d_flags = dataflags;
if ((c = db_update(domain, dp, dp, dbflags,
(zp->z_type == Z_CACHE)? fcachetab : hashtab)) < 0) {
#ifdef DEBUG
if (debug && (c != DATAEXISTS))
fprintf(ddt,"update failed\n");
#endif
}
continue;
case ERROR:
break;
}
err:
errs++;
syslog(LOG_ERR, "%s: line %d: database format error (%s)",
filename, lineno, buf);
#ifdef DEBUG
if (debug)
fprintf(ddt,"%s: line %d: database format error ('%s', %d)\n",
filename, lineno, buf, n);
#endif
while ((c = getc(fp)) != EOF && c != '\n')
;
if (c == '\n')
lineno++;
}
(void) fclose(fp);
if (didinclude)
zp->z_ftime = 0;
else
zp->z_ftime = sb.st_mtime;
zp->z_lastupdate = sb.st_mtime;
lineno = slineno;
return (errs);
}
int gettoken(fp)
register FILE *fp;
{
register int c;
char op[32];
for (;;) {
c = getc(fp);
top:
switch (c) {
case EOF:
return (EOF);
case '$':
if (getword(op, sizeof(op), fp)) {
if (!strcasecmp("include", op))
return (INCLUDE);
if (!strcasecmp("origin", op))
return (ORIGIN);
}
#ifdef DEBUG
if (debug)
fprintf(ddt,"Line %d: Unknown $ option: $%s\n",
lineno, op);
#endif
syslog(LOG_ERR,"Line %d: Unknown $ option: $%s\n",
lineno, op);
return (ERROR);
case ';':
while ((c = getc(fp)) != EOF && c != '\n')
;
goto top;
case ' ':
case '\t':
return (CURRENT);
case '.':
return (DOT);
case '@':
return (AT);
case '\n':
lineno++;
continue;
default:
(void) ungetc(c, fp);
return (DNAME);
}
}
}
/*
* Get next word, skipping blanks & comments.
*/
getword(buf, size, fp)
char *buf;
int size;
FILE *fp;
{
register char *cp;
register int c;
for (cp = buf; (c = getc(fp)) != EOF; ) {
if (c == ';') {
while ((c = getc(fp)) != EOF && c != '\n')
;
c = '\n';
}
if (c == '\n') {
if (cp != buf)
ungetc(c, fp);
else
lineno++;
break;
}
if (isspace(c)) {
while (isspace(c = getc(fp)) && c != '\n')
;
ungetc(c, fp);
if (cp != buf) /* Trailing whitespace */
break;
continue; /* Leading whitespace */
}
if (c == '"') {
while ((c = getc(fp)) != EOF && c != '"' && c != '\n') {
if (c == '\\') {
if ((c = getc(fp)) == EOF)
c = '\\';
if (c == '\n')
lineno++;
}
if (cp >= buf+size-1)
break;
*cp++ = c;
}
if (c == '\n') {
lineno++;
break;
}
continue;
}
if (c == '\\') {
if ((c = getc(fp)) == EOF)
c = '\\';
if (c == '\n')
lineno++;
}
if (cp >= buf+size-1)
break;
*cp++ = c;
}
*cp = '\0';
return (cp != buf);
}
u_long
getnum(fp)
FILE *fp;
{
register int c;
u_long n;
int seendigit = 0;
int seendecimal = 0;
for (n = 0; (c = getc(fp)) != EOF; ) {
if (isspace(c)) {
if (c == '\n')
lineno++;
if (seendigit)
break;
continue;
}
if (c == ';') {
while ((c = getc(fp)) != EOF && c != '\n')
;
if (c == '\n')
lineno++;
if (seendigit)
break;
continue;
}
if (!isdigit(c)) {
if (seendecimal || c != '.') {
syslog(LOG_ERR, "line %d: expected a number",
lineno);
#ifdef DEBUG
if (debug)
fprintf(ddt,"line %d: expected a number",
lineno);
#endif
exit(1);
} else {
if (!seendigit)
n = 1;
n = n * 1000 ;
seendigit = 1;
seendecimal = 1;
}
continue;
}
n = n * 10 + (c - '0');
seendigit = 1;
}
return (n);
}
getnonblank(fp)
FILE *fp;
{
register int c;
while ( (c = getc(fp)) != EOF ) {
if (isspace(c)) {
if (c == '\n')
lineno++;
continue;
}
if (c == ';') {
while ((c = getc(fp)) != EOF && c != '\n')
;
if (c == '\n')
lineno++;
continue;
}
return(c);
}
syslog(LOG_ERR, "line %d: unexpected EOF", lineno);
#ifdef DEBUG
if (debug)
fprintf(ddt, "line %d: unexpected EOF", lineno);
#endif
return (EOF);
}
/*
* Take name and fix it according to following rules:
* "." means root.
* "@" means current origin.
* "name." means no changes.
* "name" means append origin.
*/
makename(name, origin)
char *name, *origin;
{
int n;
if (origin[0] == '.')
origin++;
n = strlen(name);
if (n == 1) {
if (name[0] == '.') {
name[0] = '\0';
return;
}
if (name[0] == '@') {
(void) strcpy(name, origin);
return;
}
}
if (n > 0) {
if (name[n - 1] == '.')
name[n - 1] = '\0';
else if (origin[0] != '\0') {
name[n] = '.';
(void) strcpy(name + n + 1, origin);
}
}
}
endline(fp)
register FILE *fp;
{
register int c;
while (c = getc(fp))
if (c == '\n') {
(void) ungetc(c,fp);
break;
} else if (c == EOF)
break;
}
#define MAXPORT 256
#define MAXLEN 24
getprotocol(fp, src)
FILE *fp;
char *src;
{
int k;
char b[MAXLEN];
(void) getword(b, sizeof(b), fp);
k = findservice(b, &protolist);
if(k == -1) {
(void) sscanf(b,"%d",&k);
if(k <= 0)
syslog(LOG_ERR, "%s: line %d: unknown protocol: %s.",
src, lineno, b);
}
return(k);
}
int
getservices(n, data, fp, src)
int n;
char *data, *src;
FILE *fp;
{
int j, ch;
int k;
int maxl;
int bracket;
char b[MAXLEN];
char bm[MAXPORT/8];
for (j = 0; j < MAXPORT/8; j++)
bm[j] = 0;
maxl = 0;
bracket = 0;
while (getword(b, sizeof(b), fp) || bracket) {
if (feof(fp) || ferror(fp))
break;
if (strlen(b) == 0)
continue;
if ( b[0] == '(') {
bracket++;
continue;
}
if ( b[0] == ')') {
bracket = 0;
while ((ch = getc(fp)) != EOF && ch != '\n')
;
if (ch == '\n')
lineno++;
break;
}
k = findservice(b, &servicelist);
if (k == -1) {
(void) sscanf(b,"%d",&k);
if (k <= 0) {
syslog(LOG_WARNING,
"%s: line %d: Unknown service '%s'", src, lineno, b);
continue;
}
}
if ((k < MAXPORT) && (k)) {
bm[k/8] |= (0x80>>(k%8));
if (k > maxl)
maxl=k;
}
else {
syslog(LOG_WARNING,
"%s: line %d: port no. (%d) too big\n",
src, lineno, k);
#ifdef DEBUG
if (debug)
fprintf(ddt,
"%s: line %d: port no. (%d) too big\n",
src, lineno, k);
#endif
}
}
if (bracket)
syslog(LOG_WARNING, "%s: line %d: missing close paren\n",
src, lineno);
maxl = maxl/8+1;
bcopy(bm, data+n, maxl);
return(maxl+n);
}
get_sort_list(fp)
FILE *fp;
{
struct netinfo *tp;
struct netinfo *ntp = NULL;
struct netinfo *ntip = NULL;
char buf[BUFSIZ];
extern struct netinfo *fnettab;
#ifdef DEBUG
if (debug)
fprintf(ddt,"sortlist ");
#endif
if (fnettab) {
#ifdef DEBUG
/* We can only handle the sortlist at startup. see ns_main */
if (debug)
fprintf(ddt," (reloading, therefore ignored)\n");
#endif
(void) endline(fp);
return;
}
while (getword(buf, sizeof(buf), fp)) {
if (strlen(buf) == 0)
break;
#ifdef DEBUG
if (debug)
fprintf(ddt," %s",buf);
#endif
if (ntp == NULL)
ntp = (struct netinfo *)malloc(sizeof(struct netinfo));
ntp->my_addr.s_addr = inet_addr(buf);
if ( ntp->my_addr.s_addr == (unsigned)-1) {
/* resolve name to address - XXX */
continue;
}
ntp->next = NULL;
ntp->mask = net_mask(ntp->my_addr);
ntp->net = ntp->my_addr.s_addr & ntp->mask;
/* Check for duplicates, then add to linked list */
for (tp = fnettab; tp != NULL; tp = tp->next) {
if ((ntp->mask == tp->mask) &&
(ntp->net == tp->net))
continue;
}
if (fnettab == NULL)
fnettab = ntp;
else
ntip->next = ntp;
ntip = ntp;
ntp = NULL;
}
if (ntp)
free((char *)ntp);
#ifdef DEBUG
if (debug)
fprintf(ddt,"\n");
if (debug > 2)
for (ntp = fnettab; ntp != NULL; ntp = ntp->next) {
fprintf(ddt,"ntp x%x net x%lx mask x%lx", ntp,
ntp->net, ntp->mask);
fprintf(ddt," my_addr x%lx", ntp->my_addr);
fprintf(ddt," %s",inet_ntoa(ntp->my_addr));
fprintf(ddt," next x%x\n", ntp->next);
}
#endif
}
buildservicelist()
{
struct servent *sp;
struct valuelist *slp;
setservent(1);
while (sp = getservent()) {
slp = (struct valuelist *)malloc(sizeof(struct valuelist));
slp->name = savestr(sp->s_name);
slp->proto = savestr(sp->s_proto);
slp->port = ntohs((u_short)sp->s_port);
slp->next = servicelist;
slp->prev = NULL;
if (servicelist) {
servicelist->prev = slp;
}
servicelist = slp;
}
endservent();
}
buildprotolist()
{
struct protoent *pp;
struct valuelist *slp;
setprotoent(1);
while (pp = getprotoent()) {
slp = (struct valuelist *)malloc(sizeof(struct valuelist));
slp->name = savestr(pp->p_name);
slp->port = pp->p_proto;
slp->next = protolist;
slp->prev = NULL;
if (protolist) {
protolist->prev = slp;
}
protolist = slp;
}
endprotoent();
}
findservice(s, list)
register char *s;
register struct valuelist **list;
{
register struct valuelist *lp = *list;
for (; lp != NULL; lp = lp->next)
if (strcasecmp(lp->name, s) == 0) {
if (lp != *list) {
lp->prev->next = lp->next;
if (lp->next)
lp->next->prev = lp->prev;
(*list)->prev = lp;
lp->next = *list;
*list = lp;
}
return(lp->port);
}
return(-1);
}
struct servent *
cgetservbyport(port, proto)
u_short port;
char *proto;
{
register struct valuelist **list = &servicelist;
register struct valuelist *lp = *list;
static struct servent serv;
port = htons(port);
for (; lp != NULL; lp = lp->next) {
if (port != lp->port)
continue;
if (strcasecmp(lp->proto, proto) == 0) {
if (lp != *list) {
lp->prev->next = lp->next;
if (lp->next)
lp->next->prev = lp->prev;
(*list)->prev = lp;
lp->next = *list;
*list = lp;
}
serv.s_name = lp->name;
serv.s_port = htons((u_short)lp->port);
serv.s_proto = lp->proto;
return(&serv);
}
}
return(0);
}
struct protoent *
cgetprotobynumber(proto)
register int proto;
{
register struct valuelist **list = &protolist;
register struct valuelist *lp = *list;
static struct protoent prot;
for (; lp != NULL; lp = lp->next)
if (lp->port == proto) {
if (lp != *list) {
lp->prev->next = lp->next;
if (lp->next)
lp->next->prev = lp->prev;
(*list)->prev = lp;
lp->next = *list;
*list = lp;
}
prot.p_name = lp->name;
prot.p_proto = lp->port;
return(&prot);
}
return(0);
}