projects / unix-history / blobdiff
? search:
summary | tags | clone url | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
add lint entry; fix depend entry
[unix-history] / usr / src / sbin / init / init.c
diff --git a/usr/src/sbin/init/init.c b/usr/src/sbin/init/init.c
index 9b36c65..35f3cd4 100644 (file)
--- a/usr/src/sbin/init/init.c
+++ b/usr/src/sbin/init/init.c
@@ -1,8 +1,14 @@
+#ifndef lint
+static char *sccsid = "@(#)init.c      4.12 (Berkeley) %G%";
+#endif
+
 #include <signal.h>
 #include <sys/types.h>
 #include <utmp.h>
 #include <setjmp.h>
 #include <sys/reboot.h>
 #include <signal.h>
 #include <sys/types.h>
 #include <utmp.h>
 #include <setjmp.h>
 #include <sys/reboot.h>
+#include <errno.h>
+#include <sys/file.h>
 
 #define        LINSIZ  sizeof(wtmp.ut_line)
 #define        TABSIZ  100
 
 #define        LINSIZ  sizeof(wtmp.ut_line)
 #define        TABSIZ  100
@@ -10,6 +16,7 @@
 #define        EVER    ;;
 #define SCPYN(a, b)    strncpy(a, b, sizeof(a))
 #define SCMPN(a, b)    strncmp(a, b, sizeof(a))
 #define        EVER    ;;
 #define SCPYN(a, b)    strncpy(a, b, sizeof(a))
 #define SCMPN(a, b)    strncmp(a, b, sizeof(a))
+#define        mask(s) (1 << ((s)-1))
 
 char   shell[] = "/bin/sh";
 char   getty[]  = "/etc/getty";
 
 char   shell[] = "/bin/sh";
 char   getty[]  = "/etc/getty";
@@ -34,33 +41,66 @@ struct      tab
        char    comn;
        char    xflag;
        int     pid;
        char    comn;
        char    xflag;
        int     pid;
+       time_t  gettytime;
+       int     gettycnt;
 } itab[TABSIZ];
 
 int    fi;
 int    mergflag;
 char   tty[20];
 } itab[TABSIZ];
 
 int    fi;
 int    mergflag;
 char   tty[20];
-jmp_buf        sjbuf;
+jmp_buf        sjbuf, shutpass;
+time_t time0;
 
 int    reset();
 
 int    reset();
+int    idle();
 char   *strcpy(), *strcat();
 long   lseek();
 
 char   *strcpy(), *strcat();
 long   lseek();
 
+struct sigvec rvec = { reset, mask(SIGHUP), 0 };
+
+#ifdef vax
 main()
 {
        register int r11;               /* passed thru from boot */
 main()
 {
        register int r11;               /* passed thru from boot */
+#else
+main(argc, argv)
+       char **argv;
+{
+#endif
        int howto, oldhowto;
 
        int howto, oldhowto;
 
+       time0 = time(0);
+#ifdef vax
        howto = r11;
        howto = r11;
-       setjmp(sjbuf);
-       signal(SIGTERM, reset);
+#else
+       if (argc > 1 && argv[1][0] == '-') {
+               char *cp;
+
+               howto = 0;
+               cp = &argv[1][1];
+               while (*cp) switch (*cp++) {
+               case 'a':
+                       howto |= RB_ASKNAME;
+                       break;
+               case 's':
+                       howto |= RB_SINGLE;
+                       break;
+               }
+       } else {
+               howto = RB_SINGLE;
+       }
+#endif
+       sigvec(SIGTERM, &rvec, (struct sigvec *)0);
+       signal(SIGTSTP, idle);
        signal(SIGSTOP, SIG_IGN);
        signal(SIGSTOP, SIG_IGN);
-       signal(SIGTSTP, SIG_IGN);
        signal(SIGTTIN, SIG_IGN);
        signal(SIGTTOU, SIG_IGN);
        signal(SIGTTIN, SIG_IGN);
        signal(SIGTTOU, SIG_IGN);
-       for(EVER) {
+       (void) setjmp(sjbuf);
+       for (EVER) {
                oldhowto = howto;
                howto = RB_SINGLE;
                oldhowto = howto;
                howto = RB_SINGLE;
-               shutdown();
+               if (setjmp(shutpass) == 0)
+                       shutdown();
                if (oldhowto & RB_SINGLE)
                        single();
                if (runcom(oldhowto) == 0) 
                if (oldhowto & RB_SINGLE)
                        single();
                if (runcom(oldhowto) == 0) 
@@ -70,6 +110,8 @@ main()
        }
 }
 
        }
 }
 
+int    shutreset();
+
 shutdown()
 {
        register i;
 shutdown()
 {
        register i;
@@ -77,42 +119,79 @@ shutdown()
 
        close(creat(utmp, 0644));
        signal(SIGHUP, SIG_IGN);
 
        close(creat(utmp, 0644));
        signal(SIGHUP, SIG_IGN);
-       for(ALL) {
+       for (ALL) {
                term(p);
                p->line[0] = 0;
        }
                term(p);
                p->line[0] = 0;
        }
-       signal(SIGALRM, reset);
-       alarm(60);
-       for(i=0; i<5; i++)
+       signal(SIGALRM, shutreset);
+       alarm(30);
+       for (i = 0; i < 5; i++)
                kill(-1, SIGKILL);
                kill(-1, SIGKILL);
-       while(wait((int *)0) != -1)
+       while (wait((int *)0) != -1)
                ;
        alarm(0);
                ;
        alarm(0);
+       shutend();
+}
+
+char shutfailm[] = "WARNING: Something is hung (wont die); ps axl advised\n";
+
+shutreset()
+{
+       int status;
+
+       if (fork() == 0) {
+               int ct = open(ctty, 1);
+               write(ct, shutfailm, sizeof (shutfailm));
+               sleep(5);
+               exit(1);
+       }
+       sleep(5);
+       shutend();
+       longjmp(shutpass, 1);
+}
+
+shutend()
+{
+       register i, f;
+
+       acct(0);
        signal(SIGALRM, SIG_DFL);
        signal(SIGALRM, SIG_DFL);
-       for(i=0; i<10; i++)
+       for (i = 0; i < 10; i++)
                close(i);
                close(i);
+       f = open(wtmpf, O_WRONLY|O_APPEND);
+       if (f >= 0) {
+               SCPYN(wtmp.ut_line, "~");
+               SCPYN(wtmp.ut_name, "shutdown");
+               SCPYN(wtmp.ut_host, "");
+               time(&wtmp.ut_time);
+               write(f, (char *)&wtmp, sizeof(wtmp));
+               close(f);
+       }
+       return (1);
 }
 
 single()
 {
        register pid;
 }
 
 single()
 {
        register pid;
-
-       pid = fork();
-       if(pid == 0) {
-/*
-               alarm(300);
-*/
-               signal(SIGTERM, SIG_DFL);
-               signal(SIGHUP, SIG_DFL);
-               signal(SIGALRM, SIG_DFL);
-               open(ctty, 2);
-               dup(0);
-               dup(0);
-               execl(shell, minus, (char *)0);
-               exit(0);
-       }
-       while(wait((int *)0) != pid)
-               ;
+       register xpid;
+       extern  errno;
+
+       do {
+               pid = fork();
+               if (pid == 0) {
+                       signal(SIGTERM, SIG_DFL);
+                       signal(SIGHUP, SIG_DFL);
+                       signal(SIGALRM, SIG_DFL);
+                       (void) open(ctty, O_RDWR);
+                       dup2(0, 1);
+                       dup2(0, 2);
+                       execl(shell, minus, (char *)0);
+                       exit(0);
+               }
+               while ((xpid = wait((int *)0)) != pid)
+                       if (xpid == -1 && errno == ECHILD)
+                               break;
+       } while (xpid == -1);
 }
 
 runcom(oldhowto)
 }
 
 runcom(oldhowto)
@@ -122,68 +201,117 @@ runcom(oldhowto)
        int status;
 
        pid = fork();
        int status;
 
        pid = fork();
-       if(pid == 0) {
-               open("/", 0);
-               dup(0);
-               dup(0);
+       if (pid == 0) {
+               (void) open("/", O_RDONLY);
+               dup2(0, 1);
+               dup2(0, 2);
                if (oldhowto & RB_SINGLE)
                        execl(shell, shell, runc, (char *)0);
                else
                        execl(shell, shell, runc, "autoboot", (char *)0);
                exit(1);
        }
                if (oldhowto & RB_SINGLE)
                        execl(shell, shell, runc, (char *)0);
                else
                        execl(shell, shell, runc, "autoboot", (char *)0);
                exit(1);
        }
-       while(wait(&status) != pid)
+       while (wait(&status) != pid)
                ;
                ;
-       if(status)
-               return(0);
-       f = open(wtmpf, 1);
+       if (status)
+               return (0);
+       f = open(wtmpf, O_WRONLY|O_APPEND);
        if (f >= 0) {
        if (f >= 0) {
-               lseek(f, 0L, 2);
                SCPYN(wtmp.ut_line, "~");
                SCPYN(wtmp.ut_name, "reboot");
                SCPYN(wtmp.ut_line, "~");
                SCPYN(wtmp.ut_name, "reboot");
-               time(&wtmp.ut_time);
+               SCPYN(wtmp.ut_host, "");
+               if (time0) {
+                       wtmp.ut_time = time0;
+                       time0 = 0;
+               } else
+                       time(&wtmp.ut_time);
                write(f, (char *)&wtmp, sizeof(wtmp));
                close(f);
        }
                write(f, (char *)&wtmp, sizeof(wtmp));
                close(f);
        }
-       return(1);
-}
-
-setmerge()
-{
-
-       signal(SIGHUP, setmerge);
-       mergflag = 1;
+       return (1);
 }
 
 }
 
+struct sigvec  mvec = { merge, mask(SIGTERM), 0 };
+/*
+ * Multi-user.  Listen for users leaving, SIGHUP's
+ * which indicate ttys has changed, and SIGTERM's which
+ * are used to shutdown the system.
+ */
 multiple()
 {
        register struct tab *p;
        register pid;
 
 multiple()
 {
        register struct tab *p;
        register pid;
 
-loop:
-       mergflag = 0;
-       signal(SIGHUP, setmerge);
-       for(EVER) {
+       sigvec(SIGHUP, &mvec, (struct sigvec *)0);
+       for (EVER) {
                pid = wait((int *)0);
                pid = wait((int *)0);
-               if(mergflag) {
-                       merge();
-                       goto loop;
-               }
-               if(pid == -1)
+               if (pid == -1)
                        return;
                        return;
-               for(ALL)
-                       if(p->pid == pid || p->pid == -1) {
+               for (ALL)
+                       if (p->pid == pid || p->pid == -1) {
                                rmut(p);
                                dfork(p);
                        }
        }
 }
 
                                rmut(p);
                                dfork(p);
                        }
        }
 }
 
+/*
+ * Merge current contents of ttys file
+ * into in-core table of configured tty lines.
+ * Entered as signal handler for SIGHUP.
+ */
+#define        FOUND   1
+#define        CHANGE  2
+
+merge()
+{
+       register struct tab *p;
+
+       fi = open(ifile, 0);
+       if (fi < 0)
+               return;
+       for (ALL)
+               p->xflag = 0;
+       while (rline()) {
+               for (ALL) {
+                       if (SCMPN(p->line, line.line))
+                               continue;
+                       p->xflag |= FOUND;
+                       if (line.comn != p->comn) {
+                               p->xflag |= CHANGE;
+                               p->comn = line.comn;
+                       }
+                       goto contin1;
+               }
+               for (ALL) {
+                       if (p->line[0] != 0)
+                               continue;
+                       SCPYN(p->line, line.line);
+                       p->xflag |= FOUND|CHANGE;
+                       p->comn = line.comn;
+                       goto contin1;
+               }
+       contin1:
+               ;
+       }
+       close(fi);
+       for (ALL) {
+               if ((p->xflag&FOUND) == 0) {
+                       term(p);
+                       p->line[0] = 0;
+               }
+               if (p->xflag&CHANGE) {
+                       term(p);
+                       dfork(p);
+               }
+       }
+}
+
 term(p)
 term(p)
-register struct tab *p;
+       register struct tab *p;
 {
 
 {
 
-       if(p->pid != 0) {
+       if (p->pid != 0) {
                rmut(p);
                kill(p->pid, SIGKILL);
        }
                rmut(p);
                kill(p->pid, SIGKILL);
        }
@@ -196,110 +324,117 @@ rline()
 
 loop:
        c = get();
 
 loop:
        c = get();
-       if(c < 0)
+       if (c < 0)
                return(0);
                return(0);
-       if(c == 0)
+       if (c == 0)
                goto loop;
        line.flag = c;
        c = get();
                goto loop;
        line.flag = c;
        c = get();
-       if(c <= 0)
+       if (c <= 0)
                goto loop;
        line.comn = c;
        SCPYN(line.line, "");
                goto loop;
        line.comn = c;
        SCPYN(line.line, "");
-       for (i=0; i<LINSIZ; i++) {
+       for (i = 0; i < LINSIZ; i++) {
                c = get();
                c = get();
-               if(c <= 0)
+               if (c <= 0)
                        break;
                line.line[i] = c;
        }
                        break;
                line.line[i] = c;
        }
-       while(c > 0)
+       while (c > 0)
                c = get();
                c = get();
-       if(line.line[0] == 0)
+       if (line.line[0] == 0)
                goto loop;
                goto loop;
-       if(line.flag == '0')
+       if (line.flag == '0')
                goto loop;
        strcpy(tty, dev);
        strncat(tty, line.line, LINSIZ);
                goto loop;
        strcpy(tty, dev);
        strncat(tty, line.line, LINSIZ);
-       if(access(tty, 06) < 0)
+       if (access(tty, 06) < 0)
                goto loop;
                goto loop;
-       return(1);
+       return (1);
 }
 
 get()
 {
        char b;
 
 }
 
 get()
 {
        char b;
 
-       if(read(fi, &b, 1) != 1)
-               return(-1);
-       if(b == '\n')
-               return(0);
-       return(b);
+       if (read(fi, &b, 1) != 1)
+               return (-1);
+       if (b == '\n')
+               return (0);
+       return (b);
 }
 
 }
 
-#define        FOUND   1
-#define        CHANGE  2
-
-merge()
-{
-       register struct tab *p;
-
-       fi = open(ifile, 0);
-       if(fi < 0)
-               return;
-       for(ALL)
-               p->xflag = 0;
-       while(rline()) {
-               for(ALL) {
-                       if (SCMPN(p->line, line.line))
-                               continue;
-                       p->xflag |= FOUND;
-                       if(line.comn != p->comn) {
-                               p->xflag |= CHANGE;
-                               p->comn = line.comn;
-                       }
-                       goto contin1;
-               }
-               for(ALL) {
-                       if(p->line[0] != 0)
-                               continue;
-                       SCPYN(p->line, line.line);
-                       p->xflag |= FOUND|CHANGE;
-                       p->comn = line.comn;
-                       goto contin1;
-               }
-       contin1:
-               ;
-       }
-       close(fi);
-       for(ALL) {
-               if((p->xflag&FOUND) == 0) {
-                       term(p);
-                       p->line[0] = 0;
-               }
-               if((p->xflag&CHANGE) != 0) {
-                       term(p);
-                       dfork(p);
-               }
-       }
-}
+#include <sys/ioctl.h>
 
 dfork(p)
 
 dfork(p)
-struct tab *p;
+       struct tab *p;
 {
        register pid;
 {
        register pid;
-
+       time_t t;
+       int dowait = 0;
+       extern char *sys_errlist[];
+
+       time(&t);
+       p->gettycnt++;
+       if ((t - p->gettytime) >= 60) {
+               p->gettytime = t;
+               p->gettycnt = 1;
+       } else {
+               if (p->gettycnt >= 5) {
+                       dowait = 1;
+                       p->gettytime = t;
+                       p->gettycnt = 1;
+               }
+       }
        pid = fork();
        pid = fork();
-       if(pid == 0) {
+       if (pid == 0) {
+               int oerrno, f;
+               extern int errno;
+
                signal(SIGTERM, SIG_DFL);
                signal(SIGHUP, SIG_IGN);
                strcpy(tty, dev);
                strncat(tty, p->line, LINSIZ);
                signal(SIGTERM, SIG_DFL);
                signal(SIGHUP, SIG_IGN);
                strcpy(tty, dev);
                strncat(tty, p->line, LINSIZ);
+               if (dowait) {
+                       f = open("/dev/console", O_WRONLY);
+                       write(f, "init: ", 6);
+                       write(f, tty, strlen(tty));
+                       write(f, ": getty failing, sleeping\n\r", 27);
+                       close(f);
+                       sleep(30);
+                       if ((f = open("/dev/tty", O_RDWR)) >= 0) {
+                               ioctl(f, TIOCNOTTY, 0);
+                               close(f);
+                       }
+               }
                chown(tty, 0, 0);
                chmod(tty, 0622);
                chown(tty, 0, 0);
                chmod(tty, 0622);
-               open(tty, 2);
+               if (open(tty, O_RDWR) < 0) {
+                       int repcnt = 0;
+                       do {
+                               oerrno = errno;
+                               if (repcnt % 10 == 0) {
+                                       f = open("/dev/console", O_WRONLY);
+                                       write(f, "init: ", 6);
+                                       write(f, tty, strlen(tty));
+                                       write(f, ": ", 2);
+                                       write(f, sys_errlist[oerrno],
+                                               strlen(sys_errlist[oerrno]));
+                                       write(f, "\n", 1);
+                                       close(f);
+                                       if ((f = open("/dev/tty", 2)) >= 0) {
+                                               ioctl(f, TIOCNOTTY, 0);
+                                               close(f);
+                                       }
+                               }
+                               repcnt++;
+                               sleep(60);
+                       } while (open(tty, O_RDWR) < 0);
+                       exit(0);        /* have wrong control tty, start over */
+               }
                vhangup();
                signal(SIGHUP, SIG_DFL);
                vhangup();
                signal(SIGHUP, SIG_DFL);
-               open(tty, 2);
+               (void) open(tty, O_RDWR);
                close(0);
                dup(1);
                dup(0);
                close(0);
                dup(1);
                dup(0);
@@ -311,37 +446,74 @@ struct tab *p;
        p->pid = pid;
 }
 
        p->pid = pid;
 }
 
+/*
+ * Remove utmp entry.
+ */
 rmut(p)
 rmut(p)
-register struct tab *p;
+       register struct tab *p;
 {
        register f;
 {
        register f;
+       int found = 0;
 
 
-       f = open(utmp, 2);
-       if(f >= 0) {
-               while(read(f, (char *)&wtmp, sizeof(wtmp)) == sizeof(wtmp)) {
-                       if (SCMPN(wtmp.ut_line, p->line))
+       f = open(utmp, O_RDWR);
+       if (f >= 0) {
+               while (read(f, (char *)&wtmp, sizeof(wtmp)) == sizeof(wtmp)) {
+                       if (SCMPN(wtmp.ut_line, p->line) || wtmp.ut_name[0]==0)
                                continue;
                        lseek(f, -(long)sizeof(wtmp), 1);
                        SCPYN(wtmp.ut_name, "");
                                continue;
                        lseek(f, -(long)sizeof(wtmp), 1);
                        SCPYN(wtmp.ut_name, "");
+                       SCPYN(wtmp.ut_host, "");
                        time(&wtmp.ut_time);
                        write(f, (char *)&wtmp, sizeof(wtmp));
                        time(&wtmp.ut_time);
                        write(f, (char *)&wtmp, sizeof(wtmp));
+                       found++;
                }
                close(f);
        }
                }
                close(f);
        }
-       f = open(wtmpf, 1);
-       if (f >= 0) {
-               SCPYN(wtmp.ut_line, p->line);
-               SCPYN(wtmp.ut_name, "");
-               time(&wtmp.ut_time);
-               lseek(f, (long)0, 2);
-               write(f, (char *)&wtmp, sizeof(wtmp));
-               close(f);
+       if (found) {
+               f = open(wtmpf, O_WRONLY|O_APPEND);
+               if (f >= 0) {
+                       SCPYN(wtmp.ut_line, p->line);
+                       SCPYN(wtmp.ut_name, "");
+                       SCPYN(wtmp.ut_host, "");
+                       time(&wtmp.ut_time);
+                       write(f, (char *)&wtmp, sizeof(wtmp));
+                       close(f);
+               }
        }
 }
 
 reset()
 {
        }
 }
 
 reset()
 {
+
        longjmp(sjbuf, 1);
 }
 
        longjmp(sjbuf, 1);
 }
 
+jmp_buf        idlebuf;
+
+idlehup()
+{
+
+       longjmp(idlebuf, 1);
+}
+
+idle()
+{
+       register struct tab *p;
+       register pid;
 
 
+       signal(SIGHUP, idlehup);
+       for (;;) {
+               if (setjmp(idlebuf))
+                       return;
+               pid = wait((int *) 0);
+               if (pid == -1) {
+                       sigpause(0);
+                       continue;
+               }
+               for (ALL)
+                       if (p->pid == pid) {
+                               rmut(p);
+                               p->pid = -1;
+                       }
+       }
+}
Continuous source code history from original PDP-7 UNIX to FreeBSD 2, the first fully unencumbered FreeBSD release.