]> andersk Git - moira.git/blobdiff - gen/hesiod.qc
Used /bin/sh format instead of /bin/csh format, by accident.
[moira.git] / gen / hesiod.qc
index bcdc4eab1d1afb8734fb80428a59f10910c0a4fe..c56630aede5da6cf725b4b3384a6fbfa006a7747 100644 (file)
 
 #include <mit-copyright.h>
 #include <stdio.h>
-#include <sms.h>
-#include <sms_app.h>
+#include <moira.h>
+#include <moira_site.h>
 #include <sys/types.h>
 #include <sys/stat.h>
 #include <sys/time.h>
 #include <ctype.h>
 
 
-#define HESIOD_DIR     "/u1/sms/dcm/hesiod"
+#ifdef ATHENA
+#define HTYPE "UNSPECA"
+#else
+#define HTYPE "TXT"
+#endif
+
+char hesiod_dir[64];
 
 #define min(x,y)       ((x) < (y) ? (x) : (y))
 struct hash *machines = NULL;
@@ -28,7 +34,7 @@ char *whoami = "hesiod.gen";
 
 struct grp {
     struct grp *next;
-    int id;
+    char *lid;
 };
 struct user {
     char name[9];
@@ -49,18 +55,21 @@ char **argv;
 
     if (argc > 2) {
        fprintf(stderr, "usage: %s [outfile]\n", argv[0]);
-       exit(SMS_ARGS);
+       exit(MR_ARGS);
     }
 
     IIseterr(ingerr);
+    initialize_sms_error_table ();
+    sprintf(hesiod_dir, "%s/hesiod", DCM_DIR);
 
 ##  ingres sms
+##  set lockmode session where level = table
 
     changed = do_passwd();
-    changed += do_pobox();
     changed += do_filsys();
     changed += do_cluster();
-    changed += do_printers();
+    changed += do_printcap();
+    changed += do_palladium();
     changed += do_sloc();
     changed += do_service();
     changed += do_groups();
@@ -70,17 +79,17 @@ char **argv;
     if (!changed) {
        fprintf(stderr, "No files updated.\n");
        if (argc == 2 && stat(argv[1], &sb) == 0)
-         exit(SMS_NO_CHANGE);
+         exit(MR_NO_CHANGE);
     }
 
     if (argc == 2) {
        fprintf(stderr, "Building tar file.\n");
-       sprintf(cmd, "cd %s; tar cf %s .", HESIOD_DIR, argv[1]);
+       sprintf(cmd, "cd %s; tar cf %s .", hesiod_dir, argv[1]);
        if (system(cmd))
-         exit(SMS_TAR_FAIL);
+         exit(MR_TAR_FAIL);
     }
 
-    exit(SMS_SUCCESS);
+    exit(MR_SUCCESS);
 }
 
 
@@ -94,17 +103,16 @@ char **argv;
 static int ingerr(num)
     int *num;
 {
-    char buf[256];
     int ingres_errno;
 
     switch (*num) {
     case INGRES_DEADLOCK:
-       ingres_errno = SMS_DEADLOCK;
+       ingres_errno = MR_DEADLOCK;
        break;
     default:
-       ingres_errno = SMS_INGRES_ERR;
+       ingres_errno = MR_INGRES_ERR;
     }
-    com_err(whoami, SMS_INGRES_ERR, " code %d\n", *num);
+    com_err(whoami, MR_INGRES_ERR, " code %d\n", *num);
     critical_alert("DCM", "Hesiod build encountered INGRES ERROR %d", *num);
     exit(ingres_errno);
 }
@@ -127,25 +135,30 @@ get_mach()
 
 do_passwd()
 ##{
-    FILE *pout, *uout;
-    char poutf[64], uoutf[64], poutft[64], uoutft[64];
-    struct stat psb, usb;
+    FILE *pout, *uout, *bout;
+    char poutf[64], uoutf[64], poutft[64], uoutft[64], boutf[64], boutft[64];
+    struct stat psb, usb, bsb;
     time_t ftime;
     struct user *u;
+    char *mach;
 ##  char login[9], shell[33], fullname[33], oa[17], op[13], hp[17], *filetime;
-##  char nn[17];
-##  int uid, flagid;
+##  char nn[17], ptype[9];
+##  int uid, flag1, flag2, id, pid;
 
-    sprintf(poutf, "%s/passwd.db", HESIOD_DIR);
-    sprintf(uoutf, "%s/uid.db", HESIOD_DIR);
+    sprintf(poutf, "%s/passwd.db", hesiod_dir);
+    sprintf(uoutf, "%s/uid.db", hesiod_dir);
+    sprintf(boutf, "%s/pobox.db", hesiod_dir);
 
-    if (stat(poutf, &psb) == 0 && stat(uoutf, &usb) == 0) {
-       ftime = min(psb.st_mtime, usb.st_mtime);
+    if (stat(poutf, &psb) == 0 && stat(uoutf, &usb) == 0 &&
+       stat(boutf, &bsb) == 0) {
+       ftime = min(min(psb.st_mtime, usb.st_mtime), bsb.st_mtime);
        filetime = ingres_date_and_time(ftime);
-##     retrieve (flag = int4(interval("min", tblstats.modtime - filetime)))
+##     retrieve (flag1 = int4(interval("min", tblstats.modtime - filetime)))
 ##         where tblstats.table = "users"
-       if (flag < 0) {
-           fprintf(stderr, "Files passwd.db and uid.db do not need to be rebuilt.\n");
+##     retrieve (flag2 = int4(interval("min", tblstats.modtime - filetime)))
+##         where tblstats.table = "machine"
+       if (flag1 < 0 && flag2 < 0) {
+           fprintf(stderr, "Files passwd.db, uid.db, and pobox.db do not need to be rebuilt.\n");
            return(0);
       }
     }
@@ -154,22 +167,30 @@ do_passwd()
     pout = fopen(poutft, "w");
     if (!pout) {
        perror("cannot open passwd.db~ for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
     sprintf(uoutft, "%s~", uoutf);
     uout = fopen(uoutft, "w");
     if (!uout) {
        perror("cannot open uid.db~ for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
+    }
+    sprintf(boutft, "%s~", boutf);
+    bout = fopen(boutft, "w");
+    if (!bout) {
+       perror("cannot open pobox.db for write");
+       exit(MR_OCONFIG);
     }
 
-    fprintf(stderr, "Building passwd.db and uid.db\n");
+    fprintf(stderr, "Building passwd.db, uid.db, and pobox.db\n");
+    get_mach();
 
-    users = create_hash(10000);
+    users = create_hash(12001);
 ##  range of u is users
 ##  retrieve (login = u.#login, uid = u.#uid, shell = u.#shell,
 ##           fullname = u.#fullname, nn = u.nickname, oa = u.office_addr,
-##           op = u.office_phone, hp = u.home_phone, id = u.users_id)
+##           op = u.office_phone, hp = u.home_phone, id = u.users_id,
+##           pid = u.pop_id, ptype = u.potype)
 ##     where u.status = 1 {
            strtrim(login);
            dequote(fullname);
@@ -182,99 +203,43 @@ do_passwd()
            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(pout, "%s.passwd\tHS %s \"%s:*:%d:101:%s,%s,%s,%s,%s:/mit/%s:%s\"\n",
+                   login, HTYPE, login, uid, fullname, nn, oa, op, hp, login, shell);
            fprintf(uout, "%d.uid\tHS CNAME %s.passwd\n", uid, login);
+           if (ptype[0] == 'P' && (mach = hash_lookup(machines, pid))) {
+               fprintf(bout, "%s.pobox\tHS %s \"POP %s %s\"\n",
+                       login, HTYPE, mach, login);
+           }
 ##  }
 
-    if (fclose(pout) || fclose(uout)) {
-       fprintf(stderr, "Unsuccessful file close of passwd.db or uid.db\n");
-       exit(SMS_CCONFIG);
+    if (fclose(pout) || fclose(uout) || fclose(bout)) {
+       fprintf(stderr, "Unsuccessful file close of passwd.db, uid.db, or pobox.db\n");
+       exit(MR_CCONFIG);
     }
     fix_file(poutf);
     fix_file(uoutf);
+    fix_file(boutf);
     return(1);
 ##}
 
 
-do_pobox()
-##{
-    FILE *out;
-    char outf[64], outft[64], *mach;
-    struct stat sb;
-    time_t ftime;
-##  char login[9], *filetime;
-##  int flag1, flag2, id;
-
-    sprintf(outf, "%s/pobox.db", HESIOD_DIR);
-
-    if (stat(outf, &sb) == 0) {
-       ftime = sb.st_mtime;
-       filetime = ingres_date_and_time(ftime);
-##     retrieve (flag1 = int4(interval("min", tblstats.modtime - filetime)))
-##         where tblstats.table = "users"
-##     retrieve (flag2 = int4(interval("min", tblstats.modtime - filetime)))
-##         where tblstats.table = "machine"
-       if (flag1 < 0 && flag2 < 0) {
-           fprintf(stderr,"File pobox.db does not need to be rebuilt.\n");
-           return(0);
-      }
-    }
-
-    sprintf(outft, "%s~", outf);
-    out = fopen(outft, "w");
-    if (!out) {
-       perror("cannot open pobox.db for write");
-       exit(SMS_OCONFIG);
-    }
-
-    fprintf(stderr, "Building pobox.db\n");
-    get_mach();
-
-##  range of u is users
-##  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)) {
-       fprintf(stderr, "Unsuccessful close of pobox.db\n");
-       exit(SMS_CCONFIG);
-    }
-    fix_file(outf);
-    return(1);
-##}
-
-
-/************************************************************************
- * WARNING: this routine mallocs a large amount of memory which it never frees.
- * This is considered OK only because main has been arranged to call this
- * last, so the process will exit shortly after we return.
- */
-
 do_groups()
 ##{
     FILE *iout, *gout, *lout;
-    char ioutf[64], goutf[64], loutf[64], buf[512], *l;
+    char ioutf[64], goutf[64], loutf[64], buf[2048], *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 i;
 ##  char name[33], *filetime;
-##  int gid, id, lid, flag1, flag2, flag3, maxid;
+##  int gid, id, lid, flag1, flag2, flag3;
 
     /* open files */
-    sprintf(ioutf, "%s/gid.db", HESIOD_DIR);
-    sprintf(goutf, "%s/group.db", HESIOD_DIR);
-    sprintf(loutf, "%s/grplist.db", HESIOD_DIR);
+    sprintf(ioutf, "%s/gid.db", hesiod_dir);
+    sprintf(goutf, "%s/group.db", hesiod_dir);
+    sprintf(loutf, "%s/grplist.db", hesiod_dir);
 
     if (stat(ioutf, &isb) == 0 && stat(goutf, &gsb) == 0 && stat(loutf, &lsb) == 0) {
        ftime = min(isb.st_mtime, min(gsb.st_mtime, lsb.st_mtime));
@@ -284,7 +249,7 @@ do_groups()
 ##     retrieve (flag2 = int4(interval("min", tblstats.modtime - filetime)))
 ##         where tblstats.table = "list"
 ##     retrieve (flag3 = int4(interval("min", tblstats.modtime - filetime)))
-##         where tblstats.table = "members"
+##         where tblstats.table = "imembers"
        if (flag1 < 0 && flag2 < 0 && flag3 < 0) {
            fprintf(stderr, "Files gid.db, group.db and grplist.db do not need to be rebuilt.\n");
            return(0);
@@ -295,80 +260,50 @@ do_groups()
     iout = fopen(buf, "w");
     if (!iout) {
        perror("cannot open gid.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
     sprintf(buf, "%s~", goutf);
     gout = fopen(buf, "w");
     if (!gout) {
        perror("cannot open group.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
     sprintf(buf, "%s~", loutf);
     lout = fopen(buf, "w");
     if (!lout) {
        perror("cannot open grplist.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
 
     fprintf(stderr, "Building gid.db, group.db, and grplist.db\n");
 
     /* make space for group list */
-    groups = create_hash(15000);
+    groups = create_hash(15001);
 
     /* retrieve simple groups */
 ##  range of l is list
+##  range of m is imembers
 ##  begin transaction
+    /* get lock records */
+##  retrieve (name = l.modtime) where l.list_id = 0
+##  retrieve (name = users.modtime) where users.users_id = 0
+
 ##  retrieve (name = l.#name, gid = l.#gid, lid = l.list_id)
 ##     where l.group != 0 and l.active != 0 {
            strtrim(name);
            sprintf(buf, "%s:%d", name, gid);
            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);
+           fprintf(gout, "%s.group\tHS %s \"%s:*:%d:\"\n",
+                   name, HTYPE, name, gid);
 ##  }
 
     fflush(iout);
     fflush(gout);
 
-    /* get special cases: lists that aren't groups themselves but are
-     * members of groups. */
-    sq = sq_create();
-##  range of m is members
-##  retrieve (name = list.#name, gid = list.#gid, lid = l.list_id)
-##     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 {
-       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);
-       }
-       hash_store(groups, lid, strsave(buf));
-       sq_save_unique_data(sq, lid);
-##  }
-
-    while (sq_get_data(sq, &id)) {
-##     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 */
     if (users == NULL) {
-       users = create_hash(10000);
+       users = create_hash(12001);
 ##     range of u is users
 ##     retrieve (id = u.users_id, name = u.login) where u.status = 1 {
          u = (struct user *) malloc(sizeof(struct user));
@@ -380,55 +315,34 @@ do_groups()
 
 ##  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)) {
+      if (((l = hash_lookup(groups, lid)) != NULL) &&
+         (u = (struct user *) hash_lookup(users, id))) {
          g = (struct grp *) malloc(sizeof(struct grp));
          g->next = u->lists;
          u->lists = g;
-         g->id = lid;
+         g->lid = l;
       }
 ##  }
 ##  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 ((g = ((struct user *)b->data)->lists) == NULL)
+             continue;
+           fprintf(lout, "%s.grplist\tHS %s \"",
+                   ((struct user *)b->data)->name, HTYPE);
+           for (; g; g = g->next) {
+               fputs(g->lid, lout);
+               if (g->next)
+                 putc(':', lout);
            }
-           fputs(buf, lout);
+           fputs("\"\n", 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);
-    {
-       register char **p;
-       for (p = &groups[maxid-1]; p >= groups; p--)
-         if (*p)
-           free(*p);
-    }
-    free(groups);
-#endif
-
     if (fclose(iout) || fclose(gout) || fclose(lout)) {
        fprintf(stderr, "Unsuccessful close of gid.db, group.db, or grplist.db\n");
-       exit(SMS_CCONFIG);
+       exit(MR_CCONFIG);
     }
     fix_file(ioutf);
     fix_file(goutf);
@@ -437,39 +351,6 @@ do_groups()
 ##}
 
 
-#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;
@@ -478,11 +359,12 @@ do_filsys()
     struct stat sb;
     time_t ftime;
     struct save_queue *sq, *sq_create();
-##  char name[33], type[9], loc[33], access[2], mount[33], trans[257];
+##  char name[33], type[9], loc[81], access[2], mount[33], trans[257];
 ##  char *filetime, comments[65];
 ##  int flag1, flag2, flag3, flag4, id, fid;
+    char *index();
 
-    sprintf(outf, "%s/filsys.db", HESIOD_DIR);
+    sprintf(outf, "%s/filsys.db", hesiod_dir);
 
     if (stat(outf, &sb) == 0) {
        ftime = sb.st_mtime;
@@ -505,7 +387,7 @@ do_filsys()
     out = fopen(outft, "w");
     if (!out) {
        perror("cannot open filsys.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
 
     fprintf(stderr, "Building filsys.db\n");
@@ -516,29 +398,29 @@ do_filsys()
 ##  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);
+                   *p = 0;
+                   fprintf(out, "%s.filsys\tHS %s \"%s %s %s %s %s\"\n",
+                           strtrim(name), HTYPE, type, strtrim(loc), machbuf,
+                           strtrim(access), strtrim(mount));
                }
+           } else if (!strcmp(type, "AFS")) {
+               fprintf(out, "%s.filsys\tHS %s \"AFS %s %s %s\"\n",
+                       strtrim(name), HTYPE, strtrim(loc), strtrim(access),
+                       strtrim(mount));
            } else if (!strcmp(type, "ERR")) {
-               strtrim(comments);
-               fprintf(out, "%s.filsys\tHS UNSPECA \"ERR %s\"\n",
-                       name, comments);
+               fprintf(out, "%s.filsys\tHS %s \"ERR %s\"\n",
+                       name, HTYPE, strtrim(comments));
            } else if (!strcmp(type, "FSGROUP")) {
-               sprintf(trans, "%s:%d", name, fid);
+               sprintf(trans, "%s:%d", strtrim(name), fid);
                sq_save_data(sq, strsave(trans));
            }
 ##  }
@@ -554,24 +436,25 @@ do_filsys()
 ##           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);
+                   *p = 0;
+                   fprintf(out, "%s.filsys\tHS %s \"%s %s %s %s %s\"\n",
+                           group, HTYPE, type, strtrim(loc), machbuf,
+                           strtrim(access), strtrim(mount));
                }
+           } else if (!strcmp(type, "AFS")) {
+               fprintf(out, "%s.filsys\tHS %s \"AFS %s %s %s\"\n",
+                       group, HTYPE, strtrim(loc), strtrim(access),
+                       strtrim(mount));
            } else if (!strcmp(type, "ERR")) {
-               strtrim(comments);
-               fprintf(out, "%s.filsys\tHS UNSPECA \"ERR %s\"\n",
-                       group, comments);
+               fprintf(out, "%s.filsys\tHS %s \"ERR %s\"\n",
+                       group, HTYPE, strtrim(comments));
            }
 ##     }
        free(group);
@@ -580,14 +463,13 @@ do_filsys()
 
 ##  range of a is alias
 ##  retrieve (name = a.#name, trans = a.#trans) where a.#type = "FILESYS" {
-       strtrim(name);
-       strtrim(trans);
-       fprintf(out, "%s.filsys\tHS CNAME %s.filsys\n", name, trans);
+       fprintf(out, "%s.filsys\tHS CNAME %s.filsys\n",
+               strtrim(name), strtrim(trans));
 ##  }
 
     if (fclose(out)) {
        fprintf(stderr, "Unsuccessful close of filsys.db\n");
-       exit(SMS_CCONFIG);
+       exit(MR_CCONFIG);
     }
     fix_file(outf);
     return(1);
@@ -612,6 +494,18 @@ typedef long       set_mask;
 #define SET_ZERO(p)    bzero((char *)(p), setsize * sizeof(set_mask))
 #define SET_CMP(p1, p2) (bcmp((p1), (p2), setsize * sizeof(set_mask)))
 
+int nbitsset(set)
+set_mask *set;
+{
+    int i, ret;
+
+    ret = 0;
+    for (i = 0; i < setsize * NSETBITS; i++)
+      if (SET_ISSET(i, set))
+       ret++;
+    return(ret);
+}
+
 
 do_cluster()
 ##{
@@ -622,8 +516,9 @@ do_cluster()
 ##  int flag1, flag2, flag3, flag4, maxmach, maxclu, mid, cid, id;
 ##  char name[33], label[17], data[33], *filetime;
     set_mask **machs, *ms, *ps;
+    int oneclu;
 
-    sprintf(outf, "%s/cluster.db", HESIOD_DIR);
+    sprintf(outf, "%s/cluster.db", hesiod_dir);
 
     if (stat(outf, &sb) == 0) {
        ftime = sb.st_mtime;
@@ -646,7 +541,7 @@ do_cluster()
     out = fopen(outft, "w");
     if (!out) {
        perror("cannot open cluster.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
 
     fprintf(stderr, "Building cluster.db\n");
@@ -677,25 +572,38 @@ do_cluster()
        if (!machs[mid])
          continue;
        ms = machs[mid];
-       for (cid = 1; cid < maxclu; cid++) {
-           if (SET_ISSET(cid, ms)) {
-##             repeat retrieve (label = d.serv_label, data = d.serv_cluster)
+       if (nbitsset(ms) > 1) {
+           oneclu = 0;
+           for (cid = 1; cid < maxclu; cid++) {
+               if (SET_ISSET(cid, ms)) {
+##               repeat retrieve (label = d.serv_label, data = d.serv_cluster)
 ##                 where d.clu_id = @cid {
-                   strtrim(label);
-                   strtrim(data);
-                   fprintf(out,
-                           "smsinternal-%d.cluster\tHS UNSPECA \"%s %s\"\n",
-                           mid, label, data);
-##             }
+                     strtrim(label);
+                     strtrim(data);
+                     fprintf(out,
+                             "mrinternal-%d.cluster\tHS %s \"%s %s\"\n",
+                             mid, HTYPE, label, data);
+##               }
+               }
            }
+       } else {
+           oneclu = 1;
+           for (cid = 1; cid < maxclu; cid++)
+             if (SET_ISSET(cid, ms)) break;
+##         repeat retrieve (name = c.#name) where c.clu_id = @cid
+           strtrim(name);
        }
 
        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);
+           if (oneclu)
+             fprintf(out, "%s.cluster\tHS CNAME %s.cluster\n",
+                     machbuf, name);
+           else
+             fprintf(out, "%s.cluster\tHS CNAME mrinternal-%d.cluster\n",
+                     machbuf, mid);
        }
        for (id = mid + 1; id < maxmach; id++) {
            if ((ps = machs[id]) && !SET_CMP(ms, ps)) {
@@ -705,8 +613,13 @@ do_cluster()
                    for (p = machbuf; *mach && *mach != '.'; mach++)
                      *p++ = *mach;
                    *p = 0;
-                   fprintf(out,"%s.cluster\tHS CNAME smsinternal-%d.cluster\n",
-                           machbuf, mid);
+                   if (oneclu)
+                     fprintf(out, "%s.cluster\tHS CNAME %s.cluster\n",
+                             machbuf, name);
+                   else
+                     fprintf(out,
+                             "%s.cluster\tHS CNAME mrinternal-%d.cluster\n",
+                             machbuf, mid);
                }
            }
        }
@@ -719,31 +632,31 @@ do_cluster()
            strtrim(name);
            strtrim(label);
            strtrim(data);
-           fprintf(out, "%s.cluster\tHS UNSPECA \"%s %s\"\n",
-                   name, label, data);
+           fprintf(out, "%s.cluster\tHS %s \"%s %s\"\n",
+                   name, HTYPE, label, data);
 ##  }
 ##  end transaction
     free(machs);
 
     if (fclose(out)) {
        fprintf(stderr, "Unsuccessful close of cluster.db\n");
-       exit(SMS_CCONFIG);
+       exit(MR_CCONFIG);
     }
     fix_file(outf);
     return(1);
 ##}
 
 
-do_printers()
+do_printcap()
 ##{
     FILE *out;
     char outf[64], outft[64];
     struct stat sb;
     time_t ftime;
-##  char name[17], rp[17], sd[33], rm[33], *filetime;
-##  int flag;
+##  char name[17], rp[17], sd[33], rm[33], rq[33], *filetime;
+##  int flag, ka, pc;
 
-    sprintf(outf, "%s/printcap.db", HESIOD_DIR);
+    sprintf(outf, "%s/printcap.db", hesiod_dir);
 
     if (stat(outf, &sb) == 0) {
        ftime = sb.st_mtime;
@@ -760,25 +673,90 @@ do_printers()
     out = fopen(outft, "w");
     if (!out) {
        perror("cannot open printcap.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
 
     fprintf(stderr, "Building printcap.db\n");
 
 ##  range of p is printcap
-##  retrieve (name = p.#name, rp = p.#rp, sd = p.dir, rm = machine.#name)
-##    where machine.mach_id = p.mach_id {
+##  range of m is machine
+##  retrieve (name = p.#name, rp = p.#rp, sd = p.dir, rm = machine.#name,
+##           ka = p.auth, pc = p.price, rq = m.#name)
+##    where machine.mach_id = p.mach_id and m.mach_id = p.quotaserver {
        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);
+       strtrim(rq);
+       fprintf(out, "%s.pcap\tHS %s \"%s:rp=%s:rm=%s:sd=%s:ka#%d:pc#%d",
+               name, HTYPE, name, rp, rm, sd, ka, pc);
+       if (strcmp(rq, "[NONE]"))
+         fprintf(out, ":rq=%s\"\n", rq);
+       else
+         fputs("\"\n", out);
 ##  }
 
     if (fclose(out)) {
        fprintf(stderr, "Unsuccessful close of pcap.db\n");
-       exit(SMS_CCONFIG);
+       exit(MR_CCONFIG);
+    }
+    fix_file(outf);
+    return(1);
+##}
+
+
+do_palladium()
+##{
+    FILE *out;
+    char outf[64], outft[64];
+    struct stat sb;
+    time_t ftime;
+##  char name[33], rm[33], trans[129], *filetime;
+##  int flag, flag1, ident;
+
+    sprintf(outf, "%s/palladium.db", hesiod_dir);
+
+    if (stat(outf, &sb) == 0) {
+       ftime = sb.st_mtime;
+       filetime = ingres_date_and_time(ftime);
+##     retrieve (flag = int4(interval("min", tblstats.modtime - filetime)))
+##         where tblstats.table = "palladium"
+##     retrieve (flag1 = int4(interval("min", tblstats.modtime - filetime)))
+##         where tblstats.table = "alias"
+       if (flag < 0 && flag1 < 0) {
+           fprintf(stderr, "File palladium.db does not need to be rebuilt.\n");
+           return(0);
+      }
+    }
+
+    sprintf(outft, "%s~", outf);
+    out = fopen(outft, "w");
+    if (!out) {
+       perror("cannot open palladium.db for write");
+       exit(MR_OCONFIG);
+    }
+
+    fprintf(stderr, "Building palladium.db\n");
+
+##  range of p is palladium
+##  retrieve (name = p.#name, ident = p.#ident, rm = machine.#name)
+##    where machine.mach_id = p.mach_id {
+       strtrim(name);
+       strtrim(rm);
+       fprintf(out,
+               "%s.palladium\tHS %s \"%s %d %s interface directory\"\n",
+               name, HTYPE, rm, ident, name);
+##  }
+##  range of a is alias
+##  retrieve (name = a.#name, trans = a.#trans) where a.#type = "PALLADIUM" {
+       strtrim(name);
+       strtrim(trans);
+       fprintf(out, "%s.palladium\tHS %s \"%s\"\n", name, HTYPE, trans);
+##  }
+
+    if (fclose(out)) {
+       fprintf(stderr, "Unsuccessful close of palladium.db\n");
+       exit(MR_CCONFIG);
     }
     fix_file(outf);
     return(1);
@@ -787,15 +765,14 @@ do_printers()
 
 do_sloc()
 ##{
-    FILE *out, *old, *new;
+    FILE *out;
     char outf[64], outft[64], *mach;
     struct stat sb;
     time_t ftime;
-    register int c;
 ##  char service[17], *filetime;
-##  int port, flag1, flag2, id;
+##  int flag1, flag2, id;
 
-    sprintf(outf, "%s/sloc.db", HESIOD_DIR);
+    sprintf(outf, "%s/sloc.db", hesiod_dir);
 
     if (stat(outf, &sb) == 0) {
        ftime = sb.st_mtime;
@@ -814,7 +791,7 @@ do_sloc()
     out = fopen(outft, "w");
     if (!out) {
        perror("cannot open sloc.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
 
     fprintf(stderr, "Building sloc.db\n");
@@ -825,12 +802,12 @@ do_sloc()
 ##     sort by #service {
            strtrim(service);
            if (mach = hash_lookup(machines, id))
-             fprintf(out, "%s.sloc\tHS UNSPECA %s\n", service, mach);
+             fprintf(out, "%s.sloc\tHS %s %s\n", service, HTYPE, mach);
 ##  }
 
     if (fclose(out)) {
        fprintf(stderr, "Unsuccessful close of sloc.db\n");
-       exit(SMS_CCONFIG);
+       exit(MR_CCONFIG);
     }
 
     fix_file(outf);
@@ -843,10 +820,10 @@ do_service()
     char outf[64], outft[64];
     struct stat sb;
     time_t ftime;
-##  char mach[33], service[33], protocol[9], altserv[129], *filetime;
-##  int port, flag1, flag2;
+##  char service[33], protocol[9], altserv[129], *filetime;
+##  int port, flag1;
 
-    sprintf(outf, "%s/service.db", HESIOD_DIR);
+    sprintf(outf, "%s/service.db", hesiod_dir);
 
     if (stat(outf, &sb) == 0) {
        ftime = sb.st_mtime;
@@ -863,7 +840,7 @@ do_service()
     out = fopen(outft, "w");
     if (!out) {
        perror("cannot open service.db for write");
-       exit(SMS_OCONFIG);
+       exit(MR_OCONFIG);
     }
 
     fprintf(stderr, "Building service.db\n");
@@ -873,8 +850,8 @@ do_service()
 ##           port = s.#port) {
        strtrim(service);
        strtrim(protocol);
-       fprintf(out, "%s.service\tHS UNSPECA \"%s %s %d\"\n",
-               service, service, protocol, port);
+       fprintf(out, "%s.service\tHS %s \"%s %s %d\"\n",
+               service, HTYPE, service, protocol, port);
 ##  }
 
 ##  range of a is alias
@@ -886,7 +863,7 @@ do_service()
 
     if (fclose(out)) {
        fprintf(stderr, "Unsuccessful close of service.db\n");
-       exit(SMS_CCONFIG);
+       exit(MR_CCONFIG);
     }
     fix_file(outf);
     return(1);
This page took 0.079331 seconds and 4 git commands to generate.