* This generates the zone files necessary to load a hesiod server.
* The following zones are generated: passwd, uid, pobox, group,
* grplist, gid, filsys, cluster, pcap, sloc, service.
+ *
+ * (c) Copyright 1988 by the Massachusetts Institute of Technology.
+ * For copying and distribution information, please see the file
+ * <mit-copyright.h>.
*/
+#include <mit-copyright.h>
#include <stdio.h>
#include <sms.h>
#include <sms_app.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/time.h>
+#include <ctype.h>
+
#define HESIOD_DIR "/u1/sms/dcm/hesiod"
#define min(x,y) ((x) < (y) ? (x) : (y))
+struct hash *machines = NULL;
+struct hash *users = NULL;
+char *whoami = "hesiod.gen";
+
+struct grp {
+ struct grp *next;
+ int id;
+};
+struct user {
+ char name[9];
+ struct grp *lists;
+};
char *malloc(), *strsave();
char *ingres_date_and_time(), *ingres_time(), *ingres_date();
char cmd[64];
struct stat sb;
int changed = 0;
+ int ingerr();
if (argc > 2) {
fprintf(stderr, "usage: %s [outfile]\n", argv[0]);
exit(SMS_ARGS);
}
+ IIseterr(ingerr);
+
## ingres sms
-## set lockmode session where readlock = nolock
changed = do_passwd();
changed += do_pobox();
}
if (argc == 2) {
+ fprintf(stderr, "Building tar file.\n");
sprintf(cmd, "cd %s; tar cf %s .", HESIOD_DIR, argv[1]);
if (system(cmd))
exit(SMS_TAR_FAIL);
}
+/*
+ * ingerr: (supposedly) called when Ingres indicates an error.
+ * I have not yet been able to get this to work to intercept a
+ * database open error.
+ */
+#define INGRES_DEADLOCK 4700
+
+static int ingerr(num)
+ int *num;
+{
+ char buf[256];
+ int ingres_errno;
+
+ switch (*num) {
+ case INGRES_DEADLOCK:
+ ingres_errno = SMS_DEADLOCK;
+ break;
+ default:
+ ingres_errno = SMS_INGRES_ERR;
+ }
+ com_err(whoami, SMS_INGRES_ERR, " code %d\n", *num);
+ critical_alert("DCM", "Hesiod build encountered INGRES ERROR %d", *num);
+ exit(ingres_errno);
+}
+
+
+get_mach()
+##{
+## int id;
+## char name[33];
+
+ if (machines)
+ return;
+
+ machines = create_hash(1000);
+## retrieve (name = machine.#name, id = machine.mach_id) {
+ hash_store(machines, id, strsave(strtrim(name)));
+## }
+##}
+
+
do_passwd()
##{
FILE *pout, *uout;
char poutf[64], uoutf[64], poutft[64], uoutft[64];
struct stat psb, usb;
time_t ftime;
+ struct user *u;
## char login[9], shell[33], fullname[33], oa[17], op[13], hp[17], *filetime;
-## int uid, flag;
+## char nn[17];
+## int uid, flag, id;
sprintf(poutf, "%s/passwd.db", HESIOD_DIR);
sprintf(uoutf, "%s/uid.db", HESIOD_DIR);
fprintf(stderr, "Building passwd.db and uid.db\n");
+ users = create_hash(10000);
## range of u is users
## retrieve (login = u.#login, uid = u.#uid, shell = u.#shell,
-## fullname = u.#fullname, oa = u.office_addr,
-## op = u.office_phone, hp = u.home_phone)
-## where u.status = 1 sort by #login {
- trim(login);
- trim(fullname);
- trim(oa);
- trim(op);
- trim(hp);
- trim(shell);
- fprintf(pout, "%s.passwd\tHS UNSPECA \"%s:*:%d:101:%s,%s,%s,%s:/mit/%s:%s\"\n",
- login, login, uid, fullname, oa, op, hp, login, shell);
+## fullname = u.#fullname, nn = u.nickname, oa = u.office_addr,
+## op = u.office_phone, hp = u.home_phone, id = u.users_id)
+## where u.status = 1 {
+ strtrim(login);
+ dequote(fullname);
+ dequote(nn);
+ dequote(oa);
+ dequote(op);
+ dequote(hp);
+ dequote(shell);
+ u = (struct user *) malloc(sizeof(struct user));
+ strcpy(u->name, login);
+ u->lists = NULL;
+ hash_store(users, id, u);
+ fprintf(pout, "%s.passwd\tHS UNSPECA \"%s:*:%d:101:%s,%s,%s,%s,%s:/mit/%s:%s\"\n",
+ login, login, uid, fullname, nn, oa, op, hp, login, shell);
fprintf(uout, "%d.uid\tHS CNAME %s.passwd\n", uid, login);
## }
do_pobox()
##{
FILE *out;
- char outf[64], outft[64];
+ char outf[64], outft[64], *mach;
struct stat sb;
time_t ftime;
-## char login[9], mach[33], *filetime;
-## int flag1, flag2;
+## char login[9], *filetime;
+## int flag1, flag2, id;
sprintf(outf, "%s/pobox.db", HESIOD_DIR);
}
fprintf(stderr, "Building pobox.db\n");
+ get_mach();
## range of u is users
-## range of m is machine
-## retrieve (login = u.#login, mach = m.#name)
-## where u.status = 1 and u.potype = "POP" and m.mach_id = u.pop_id {
- trim(login);
- trim(mach);
- fprintf(out, "%s.pobox\tHS UNSPECA \"POP %s %s\"\n",
- login, mach, login);
+## retrieve (login = u.#login, id = u.pop_id)
+## where u.status = 1 and u.potype = "POP" {
+ strtrim(login);
+ if (mach = hash_lookup(machines, id))
+ fprintf(out, "%s.pobox\tHS UNSPECA \"POP %s %s\"\n",
+ login, mach, login);
## }
if (fclose(out)) {
do_groups()
##{
FILE *iout, *gout, *lout;
- char ioutf[64], goutf[64], loutf[64], buf[256];
- char **groups;
+ char ioutf[64], goutf[64], loutf[64], buf[512], *l;
+ struct hash *groups;
+ register struct bucket *b, **p;
+ struct grp *g;
+ struct user *u;
struct stat isb, gsb, lsb;
time_t ftime;
register struct save_queue *sq;
struct save_queue *sq_create();
- register int first, i;
- register char **p;
+ register int i;
## char name[33], *filetime;
## int gid, id, lid, flag1, flag2, flag3, maxid;
fprintf(stderr, "Building gid.db, group.db, and grplist.db\n");
/* make space for group list */
-## range of l is list
-## retrieve (maxid = max(l.#list_id))
- groups = (char **)malloc((maxid + 1) * sizeof(char *));
- if (groups == NULL) {
- fprintf(stderr, "unable to malloc space for groups\n");
- exit(1);
- }
- bzero(groups, (maxid + 1) * sizeof(char *));
+ groups = create_hash(15000);
/* retrieve simple groups */
+## range of l is list
+## begin transaction
## retrieve (name = l.#name, gid = l.#gid, lid = l.list_id)
## where l.group != 0 and l.active != 0 {
- trim(name);
+ strtrim(name);
sprintf(buf, "%s:%d", name, gid);
- groups[lid] = strsave(buf);
+ hash_store(groups, lid, strsave(buf));
fprintf(iout, "%d.gid\tHS CNAME %s.group\n", gid, name);
fprintf(gout, "%s.group\tHS UNSPECA \"%s:*:%d:\"\n",
name, name, gid);
sq = sq_create();
## range of m is members
## retrieve (name = list.#name, gid = list.#gid, lid = l.list_id)
-## where l.group = 0 and m.member_type = "LIST" and
+## where l.active != 0 and list.active != 0 and m.member_type = "LIST" and
## m.member_id = l.list_id and m.list_id = list.list_id and
## list.group != 0 {
- trim(name);
- if (groups[lid]) {
- sprintf(buf, "%s:%s:%d", groups[lid], name, gid);
- free(groups[lid]);
+ strtrim(name);
+ if (l = hash_lookup(groups, lid)) {
+ sprintf(buf, "%s:%s:%d", l, name, gid);
+ free(l);
} else {
sprintf(buf, "%s:%d", name, gid);
}
- groups[lid] = strsave(buf);
- sq_save_data(sq, lid);
+ hash_store(groups, lid, strsave(buf));
+ sq_save_unique_data(sq, lid);
## }
while (sq_get_data(sq, &id)) {
-## repeat retrieve (name = l.#name, gid = l.#gid, lid = l.list_id)
-## where l.group = 0 and m.member_type = "LIST" and
-## m.member_id = l.list_id and m.list_id = @id {
- trim(name);
- sprintf(buf, "%s:%d", name, gid);
- groups[lid] = strsave(buf);
+## repeat retrieve (lid = l.list_id) where m.member_type = "LIST" and
+## m.list_id = @id and m.member_id = l.list_id and l.active != 0 {
+ if (l = hash_lookup(groups, lid)) {
+ sprintf(buf, "%s:%s", l, hash_lookup(groups, id));
+ free(l);
+ l = strsave(buf);
+ } else {
+ l = hash_lookup(groups, id);
+ }
+ hash_store(groups, lid, l);
sq_save_unique_data(sq, lid);
## }
}
sq_destroy(sq);
/* now do grplists */
- sq = sq_create();
-## range of u is users
-## retrieve (id = u.users_id) where u.status = 1 {
- sq_save_data(sq, id);
+ if (users == NULL) {
+ users = create_hash(10000);
+## range of u is users
+## retrieve (id = u.users_id, name = u.login) where u.status = 1 {
+ u = (struct user *) malloc(sizeof(struct user));
+ strcpy(u->name, strtrim(name));
+ u->lists = NULL;
+ hash_store(users, id, u);
+## }
+ }
+
+## repeat retrieve (lid = m.list_id, id = m.member_id)
+## where m.member_type = "USER" {
+ if ((u = (struct user *) hash_lookup(users, id)) &&
+ (hash_lookup(groups, lid) != NULL)) {
+ g = (struct grp *) malloc(sizeof(struct grp));
+ g->next = u->lists;
+ u->lists = g;
+ g->id = lid;
+ }
## }
- while (sq_get_data(sq, &id)) {
- first = 1;
-## repeat retrieve (lid = m.list_id, name = u.login)
-## where m.member_type = "USER" and m.member_id = @id and
-## u.users_id = @id {
- if (groups[lid]) {
- if (first) {
- trim(name);
- fprintf(lout, "%s.grplist\tHS UNSPECA \"%s",
- name, groups[lid]);
- } else
- fprintf(lout, ":%s", groups[lid]);
- first = 0;
+## end transaction
+
+ for (p = &(users->data[users->size - 1]); p >= users->data; p--) {
+ for (b = *p; b; b = b->next) {
+ i = 0;
+ sprintf(buf, "%s.grplist\tHS UNSPECA \"",
+ ((struct user *)b->data)->name);
+ for (g = ((struct user *)b->data)->lists; g; g = g->next)
+ if (l = hash_lookup(groups, g->id)) {
+ i++;
+ strcat(buf, l);
+ if (g->next)
+ strcat(buf, ":");
+ }
+ strcat(buf, "\"\n");
+ /* Do duplicate detection here */
+ if (i > 1) {
+ remove_duplicate_groups(buf);
}
-## }
- if (!first)
- fprintf(lout, "\"\n");
+ fputs(buf, lout);
+ }
}
+
#ifdef notdef
/* This is commented out because it takes on the order of 30 minutes to
* run. Instead, we never free the memory, but the program will exit
* shortly anyway.
*/
sq_destroy(sq);
- for (p = &groups[maxid-1]; p >= groups; p--)
- if (*p)
- free(*p);
+ {
+ register char **p;
+ for (p = &groups[maxid-1]; p >= groups; p--)
+ if (*p)
+ free(*p);
+ }
free(groups);
#endif
##}
+#define MAXGROUPS 256
+
+remove_duplicate_groups(p)
+register char *p;
+{
+ register char *pp;
+ char *index();
+ register int *mp;
+ int memory[MAXGROUPS], i, *mg = &memory[MAXGROUPS-1];
+
+ bzero(memory, MAXGROUPS * sizeof(int));
+ while (p = index(p, ':')) {
+ i = atoi(++p);
+ for (mp = memory; *mp && mp < mg; mp++)
+ if (*mp == i) {
+ if (p = index(p, ':'))
+ strcpy(pp, ++p);
+ else {
+ strcpy(--pp, "\"\n");
+ }
+ p = pp;
+ break;
+ }
+ if (*mp == i)
+ continue;
+ *mp = i;
+ if (!(p = index(p, ':')))
+ return;
+ pp = ++p;
+ }
+}
+
+
do_filsys()
##{
FILE *out;
- char outf[64], outft[64];
+ char outf[64], outft[64], *mach, machbuf[128], *group;
+ register char *p;
struct stat sb;
time_t ftime;
-## char name[33], type[9], loc[33], mach[33], access[2], mount[33], trans[257];
+ struct save_queue *sq, *sq_create();
+## char name[33], type[9], loc[33], access[2], mount[33], trans[257];
## char *filetime, comments[65];
-## int flag1, flag2, flag3;
+## int flag1, flag2, flag3, flag4, id, fid;
sprintf(outf, "%s/filsys.db", HESIOD_DIR);
## where tblstats.table = "machine"
## retrieve (flag3 = int4(interval("min", tblstats.modtime - filetime)))
## where tblstats.table = "alias"
- if (flag1 < 0 && flag2 < 0 && flag3 < 0) {
+## retrieve (flag4 = int4(interval("min", tblstats.modtime - filetime)))
+## where tblstats.table = "fsgroup"
+ if (flag1 < 0 && flag2 < 0 && flag3 < 0 && flag4 < 0) {
fprintf(stderr, "File filsys.db does not need to be rebuilt.\n");
return(0);
}
}
fprintf(stderr, "Building filsys.db\n");
+ get_mach();
+ sq = sq_create();
## range of f is filesys
-## range of m is machine
-## retrieve (name = f.label, type = f.#type, loc = f.#name, mach = m.#name,
-## access = f.#access, mount = f.#mount, comments = f.#comments)
-## where m.mach_id = f.mach_id {
- trim(name);
- trim(type);
- if (strcmp(type, "ERR")) {
- trim(loc);
- trim(mach);
- trim(access);
- trim(mount);
- fprintf(out, "%s.filsys\tHS UNSPECA \"%s %s %s %s %s\"\n",
- name, type, loc, mach, access, mount);
- } else {
- trim(comments);
- fprintf(out, "%s.filsys\tHS UNSPECA \"%s %s\"\n",
- name, type, comments);
+## retrieve (name = f.label, type = f.#type, loc = f.#name, id = f.mach_id,
+## access = f.#access, mount = f.#mount, comments = f.#comments,
+## fid = f.filsys_id) {
+ strtrim(name);
+ strtrim(type);
+ if (!strcmp(type, "NFS") || !strcmp(type, "RVD")) {
+ strtrim(loc);
+ strtrim(access);
+ strtrim(mount);
+ if (mach = hash_lookup(machines, id)) {
+ for (p = machbuf; *mach && *mach != '.'; mach++) {
+ if (isupper(*mach))
+ *p++ = tolower(*mach);
+ else
+ *p++ = *mach;
+ *p = 0;
+ }
+ fprintf(out, "%s.filsys\tHS UNSPECA \"%s %s %s %s %s\"\n",
+ name, type, loc, machbuf, access, mount);
+ }
+ } else if (!strcmp(type, "ERR")) {
+ strtrim(comments);
+ fprintf(out, "%s.filsys\tHS UNSPECA \"ERR %s\"\n",
+ name, comments);
+ } else if (!strcmp(type, "FSGROUP")) {
+ sprintf(trans, "%s:%d", name, fid);
+ sq_save_data(sq, strsave(trans));
}
## }
+## range of g is fsgroup
+ while (sq_get_data(sq, &group)) {
+ fid = atoi(index(group, ':')+1);
+ *index(group, ':') = 0;
+## retrieve (type = f.#type, loc = f.#name, id = f.mach_id,
+## access = f.#access, mount = f.#mount, comments = f.#comments,
+## name = f.#label, trans = g.#key)
+## where f.filsys_id = g.filsys_id and g.group_id = fid
+## sort by #trans, #name {
+ strtrim(type);
+ if (!strcmp(type, "NFS") || !strcmp(type, "RVD")) {
+ strtrim(loc);
+ strtrim(access);
+ strtrim(mount);
+ if (mach = hash_lookup(machines, id)) {
+ for (p = machbuf; *mach && *mach != '.'; mach++) {
+ if (isupper(*mach))
+ *p++ = tolower(*mach);
+ else
+ *p++ = *mach;
+ *p = 0;
+ }
+ fprintf(out, "%s.filsys\tHS UNSPECA \"%s %s %s %s %s\"\n",
+ group, type, loc, machbuf, access, mount);
+ }
+ } else if (!strcmp(type, "ERR")) {
+ strtrim(comments);
+ fprintf(out, "%s.filsys\tHS UNSPECA \"ERR %s\"\n",
+ group, comments);
+ }
+## }
+ free(group);
+ }
+ sq_destroy(sq);
+
## range of a is alias
## retrieve (name = a.#name, trans = a.#trans) where a.#type = "FILESYS" {
- trim(name);
- trim(trans);
+ strtrim(name);
+ strtrim(trans);
fprintf(out, "%s.filsys\tHS CNAME %s.filsys\n", name, trans);
## }
do_cluster()
##{
FILE *out;
- char outf[64], outft[64];
+ char outf[64], outft[64], *mach, machbuf[33], *p;
struct stat sb;
time_t ftime;
## int flag1, flag2, flag3, flag4, maxmach, maxclu, mid, cid, id;
-## char name[33], label[17], data[33], mach[33], *filetime;
+## char name[33], label[17], data[33], *filetime;
set_mask **machs, *ms, *ps;
sprintf(outf, "%s/cluster.db", HESIOD_DIR);
}
fprintf(stderr, "Building cluster.db\n");
+ get_mach();
## range of c is cluster
+## begin transaction
## retrieve (maxclu = max(c.clu_id))
+ maxclu++;
setsize = howmany(maxclu, NSETBITS);
## range of m is machine
## retrieve (maxmach = max(m.mach_id))
+ maxmach++;
machs = (set_mask **)malloc((maxmach + 1) * sizeof(set_mask **));
bzero(machs, (maxmach + 1) * sizeof(int));
if (SET_ISSET(cid, ms)) {
## repeat retrieve (label = d.serv_label, data = d.serv_cluster)
## where d.clu_id = @cid {
- trim(label);
- trim(data);
+ strtrim(label);
+ strtrim(data);
fprintf(out,
"smsinternal-%d.cluster\tHS UNSPECA \"%s %s\"\n",
mid, label, data);
}
}
-## repeat retrieve (mach = m.#name) where m.mach_id = @mid
- trim(mach);
- fprintf(out, "%s.cluster\tHS CNAME smsinternal-%d.cluster\n",
- mach, mid);
+ if (mach = hash_lookup(machines, mid)) {
+ for (p = machbuf; *mach && *mach != '.'; mach++)
+ *p++ = *mach;
+ *p = 0;
+ fprintf(out, "%s.cluster\tHS CNAME smsinternal-%d.cluster\n",
+ machbuf, mid);
+ }
for (id = mid + 1; id < maxmach; id++) {
if ((ps = machs[id]) && !SET_CMP(ms, ps)) {
free(ps);
machs[id] = NULL;
-## repeat retrieve (mach = m.#name) where m.mach_id = @id
- trim(mach);
- fprintf(out, "%s.cluster\tHS CNAME smsinternal-%d.cluster\n",
- mach, mid);
+ if (mach = hash_lookup(machines, id)) {
+ for (p = machbuf; *mach && *mach != '.'; mach++)
+ *p++ = *mach;
+ *p = 0;
+ fprintf(out,"%s.cluster\tHS CNAME smsinternal-%d.cluster\n",
+ machbuf, mid);
+ }
}
}
free(ms);
machs[mid] = NULL;
}
- free(machs);
## retrieve (name = c.#name, label = d.serv_label, data = d.serv_cluster)
## where c.clu_id = d.clu_id {
- trim(name);
- trim(label);
- trim(data);
+ strtrim(name);
+ strtrim(label);
+ strtrim(data);
fprintf(out, "%s.cluster\tHS UNSPECA \"%s %s\"\n",
name, label, data);
## }
+## end transaction
+ free(machs);
if (fclose(out)) {
fprintf(stderr, "Unsuccessful close of cluster.db\n");
char outf[64], outft[64];
struct stat sb;
time_t ftime;
-## char name[33], pcap[513], *filetime;
+## char name[17], rp[17], sd[33], rm[33], *filetime;
## int flag;
sprintf(outf, "%s/printcap.db", HESIOD_DIR);
fprintf(stderr, "Building printcap.db\n");
## range of p is printcap
-## retrieve (name = p.#name, pcap = p.#pcap) {
- trim(name);
- trim(pcap);
- fprintf(out, "%s.pcap\tHS UNSPECA \"%s\"\n", name, pcap);
+## retrieve (name = p.#name, rp = p.#rp, sd = p.dir, rm = machine.#name)
+## where machine.mach_id = p.mach_id {
+ strtrim(name);
+ strtrim(rp);
+ strtrim(sd);
+ strtrim(rm);
+ fprintf(out, "%s.pcap\tHS UNSPECA \"%s:rp=%s:rm=%s:sd=%s\"\n",
+ name, name, rp, rm, sd);
## }
if (fclose(out)) {
do_sloc()
##{
FILE *out, *old, *new;
- char outf[64], outft[64];
+ char outf[64], outft[64], *mach;
struct stat sb;
time_t ftime;
register int c;
-## char mach[33], service[17], *filetime;
-## int port, flag1, flag2;
+## char service[17], *filetime;
+## int port, flag1, flag2, id;
sprintf(outf, "%s/sloc.db", HESIOD_DIR);
}
fprintf(stderr, "Building sloc.db\n");
+ get_mach();
## range of s is serverhosts
-## range of m is machine
-## retrieve (service = s.#service, mach = m.name)
-## where m.mach_id = s.mach_id sort by #service {
- trim(service);
- trim(mach);
- fprintf(out, "%s.sloc\tHS UNSPECA %s\n", service, mach);
+## retrieve (service = s.#service, id = s.mach_id)
+## sort by #service {
+ strtrim(service);
+ if (mach = hash_lookup(machines, id))
+ fprintf(out, "%s.sloc\tHS UNSPECA %s\n", service, mach);
## }
if (fclose(out)) {
exit(SMS_CCONFIG);
}
- /* diff outf & outft. If they are the same, report "nothing changed" */
- old = fopen(outf, "r");
- new = fopen(outft, "r");
- while ((c = getc(old)) != EOF)
- if (c != getc(new))
- break;
- if (c != EOF || !feof(new)) {
- fix_file(outf);
- fclose(old);
- fclose(new);
- return(1);
- } else {
- fprintf(stderr, "Nothing in sloc.db has changed.\n");
- fclose(old);
- fclose(new);
- unlink(outft);
- return(0);
- }
+ fix_file(outf);
+ return(1);
##}
do_service()
## range of s is services
## retrieve (service = s.name, protocol = lowercase(s.#protocol),
## port = s.#port) {
- trim(service);
- trim(protocol);
+ strtrim(service);
+ strtrim(protocol);
fprintf(out, "%s.service\tHS UNSPECA \"%s %s %d\"\n",
service, service, protocol, port);
## }
## range of a is alias
## retrieve (service = a.name, altserv = a.trans) where a.type = "SERVICE" {
- trim(service);
- trim(altserv);
+ strtrim(service);
+ strtrim(altserv);
fprintf(out, "%s.service\tHS CNAME %s.service\n", service, altserv);
## }