]> git.ozlabs.org Git - ppp.git/blobdiff - pppd/main.c
use strlcpy, strlcat, slprintf everywhere
[ppp.git] / pppd / main.c
index 7072d0a871fabcf9b615e3df1b179ff41ae2aa1d..37ad65f5a4c7ae50000175368c2d79f92998bec8 100644 (file)
@@ -18,7 +18,7 @@
  */
 
 #ifndef lint
-static char rcsid[] = "$Id: main.c,v 1.50 1998/09/13 23:38:49 paulus Exp $";
+static char rcsid[] = "$Id: main.c,v 1.58 1999/03/12 06:07:18 paulus Exp $";
 #endif
 
 #include <stdio.h>
@@ -33,6 +33,7 @@ static char rcsid[] = "$Id: main.c,v 1.50 1998/09/13 23:38:49 paulus Exp $";
 #include <netdb.h>
 #include <utmp.h>
 #include <pwd.h>
+#include <setjmp.h>
 #include <sys/param.h>
 #include <sys/types.h>
 #include <sys/wait.h>
@@ -91,6 +92,9 @@ int phase;                    /* where the link is at */
 int kill_link;
 int open_ccp_flag;
 
+static int waiting;
+static sigjmp_buf sigjmp;
+
 char **script_env;             /* Env. variable values for scripts */
 int s_env_nalloc;              /* # words avail at script_env */
 
@@ -103,6 +107,9 @@ static int locked;          /* lock() has succeeded */
 
 char *no_ppp_msg = "Sorry - this system lacks PPP kernel support\n";
 
+GIDSET_TYPE groups[NGROUPS_MAX];/* groups the user is in */
+int ngroups;                   /* How many groups valid in groups */
+
 /* Prototypes for procedures local to this file. */
 
 static void create_pidfile __P((void));
@@ -177,8 +184,8 @@ main(argc, argv)
     phase = PHASE_INITIALIZE;
     p = ttyname(0);
     if (p)
-       strcpy(devnam, p);
-    strcpy(default_devnam, devnam);
+       strlcpy(devnam, sizeof(devnam), p);
+    strlcpy(default_devnam, sizeof(default_devnam), devnam);
 
     script_env = NULL;
 
@@ -192,7 +199,7 @@ main(argc, argv)
 
     if (gethostname(hostname, MAXNAMELEN) < 0 ) {
        option_error("Couldn't get hostname: %m");
-       die(1);
+       exit(1);
     }
     hostname[MAXNAMELEN-1] = 0;
 
@@ -201,6 +208,8 @@ main(argc, argv)
     sprintf(numbuf, "%d", uid);
     script_setenv("ORIG_UID", numbuf);
 
+    ngroups = getgroups(NGROUPS_MAX, groups);
+
     /*
      * Initialize to the standard option set, then parse, in order,
      * the system options file, the user's options file,
@@ -225,7 +234,7 @@ main(argc, argv)
     if (geteuid() != 0) {
        option_error("must be root to run %s, since it is not setuid-root",
                     argv[0]);
-       die(1);
+       exit(1);
     }
 
     if (!ppp_available()) {
@@ -236,13 +245,14 @@ main(argc, argv)
     /*
      * Check that the options given are valid and consistent.
      */
-    sys_check_options();
+    if (!sys_check_options())
+       exit(1);
     auth_check_options();
     for (i = 0; (protp = protocols[i]) != NULL; ++i)
        if (protp->check_options != NULL)
            (*protp->check_options)();
     if (demand && connector == 0) {
-       option_error("connect script required for demand-dialling\n");
+       option_error("connect script is required for demand-dialling\n");
        exit(1);
     }
 
@@ -271,7 +281,7 @@ main(argc, argv)
      * Detach ourselves from the terminal, if required,
      * and identify who is running us.
      */
-    if (nodetach == 0)
+    if (!nodetach && !updetach)
        detach();
     pid = getpid();
     p = getlogin();
@@ -295,14 +305,13 @@ main(argc, argv)
     sigaddset(&mask, SIGINT);
     sigaddset(&mask, SIGTERM);
     sigaddset(&mask, SIGCHLD);
+    sigaddset(&mask, SIGUSR2);
 
-#define SIGNAL(s, handler)     { \
+#define SIGNAL(s, handler)     do { \
        sa.sa_handler = handler; \
-       if (sigaction(s, &sa, NULL) < 0) { \
-           syslog(LOG_ERR, "Couldn't establish signal handler (%d): %m", s); \
-           die(1); \
-       } \
-    }
+       if (sigaction(s, &sa, NULL) < 0) \
+           fatal("Couldn't establish signal handler (%d): %m", s); \
+    } while (0)
 
     sa.sa_mask = mask;
     sa.sa_flags = 0;
@@ -360,6 +369,8 @@ main(argc, argv)
      */
     signal(SIGPIPE, SIG_IGN);
 
+    waiting = 0;
+
     /*
      * If we're doing dial-on-demand, set up the interface now.
      */
@@ -389,27 +400,39 @@ main(argc, argv)
            /*
             * Don't do anything until we see some activity.
             */
-           phase = PHASE_DORMANT;
            kill_link = 0;
+           phase = PHASE_DORMANT;
            demand_unblock();
            for (;;) {
-               wait_loop_output(timeleft(&timo));
+               if (sigsetjmp(sigjmp, 1) == 0) {
+                   sigprocmask(SIG_BLOCK, &mask, NULL);
+                   if (kill_link) {
+                       sigprocmask(SIG_UNBLOCK, &mask, NULL);
+                   } else {
+                       waiting = 1;
+                       sigprocmask(SIG_UNBLOCK, &mask, NULL);
+                       wait_loop_output(timeleft(&timo));
+                   }
+               }
+               waiting = 0;
                calltimeout();
                if (kill_link) {
                    if (!persist)
-                       die(0);
+                       break;
                    kill_link = 0;
                }
                if (get_loop_output())
                    break;
                reap_kids();
            }
+           if (kill_link && !persist)
+               break;
 
            /*
             * Now we want to bring up the link.
             */
            demand_block();
-           syslog(LOG_INFO, "Starting link");
+           info("Starting link");
        }
 
        /*
@@ -428,27 +451,33 @@ main(argc, argv)
         * out and we want to use the modem lines, we reopen it later
         * in order to wait for the carrier detect signal from the modem.
         */
-       while ((ttyfd = open(devnam, O_NONBLOCK | O_RDWR, 0)) < 0) {
+       hungup = 0;
+       kill_link = 0;
+       for (;;) {
+           /* If the user specified the device name, become the
+              user before opening it. */
+           if (!devnam_info.priv)
+               seteuid(uid);
+           ttyfd = open(devnam, O_NONBLOCK | O_RDWR, 0);
+           if (!devnam_info.priv)
+               seteuid(0);
+           if (ttyfd >= 0)
+               break;
            if (errno != EINTR)
-               syslog(LOG_ERR, "Failed to open %s: %m", devnam);
+               error("Failed to open %s: %m", devnam);
            if (!persist || errno != EINTR)
                goto fail;
        }
        if ((fdflags = fcntl(ttyfd, F_GETFL)) == -1
            || fcntl(ttyfd, F_SETFL, fdflags & ~O_NONBLOCK) < 0)
-           syslog(LOG_WARNING,
-                  "Couldn't reset non-blocking mode on device: %m");
-
-       hungup = 0;
-       kill_link = 0;
+           warn("Couldn't reset non-blocking mode on device: %m");
 
        /*
         * Do the equivalent of `mesg n' to stop broadcast messages.
         */
        if (fstat(ttyfd, &statbuf) < 0
            || fchmod(ttyfd, statbuf.st_mode & ~(S_IWGRP | S_IWOTH)) < 0) {
-           syslog(LOG_WARNING,
-                  "Couldn't restrict write permissions to %s: %m", devnam);
+           warn("Couldn't restrict write permissions to %s: %m", devnam);
        } else
            tty_mode = statbuf.st_mode;
 
@@ -456,6 +485,11 @@ main(argc, argv)
        if (connector && connector[0]) {
            MAINDEBUG((LOG_INFO, "Connecting with <%s>", connector));
 
+           if (!default_device && modem) {
+               hangup_modem(ttyfd);    /* in case modem is off hook */
+               sleep(1);
+           }
+
            /*
             * Set line speed, flow control, etc.
             * On most systems we set CLOCAL for now so that we can talk
@@ -463,25 +497,16 @@ main(argc, argv)
             * side effect that we might miss it if CD drops before we
             * get to clear CLOCAL below.  On systems where we can talk
             * successfully to the modem with CLOCAL clear and CD down,
-            * we can clear CLOCAL at this point.
+            * we could clear CLOCAL at this point.
             */
            set_up_tty(ttyfd, 1);
 
-           /* drop dtr to hang up in case modem is off hook */
-           if (!default_device && modem) {
-               setdtr(ttyfd, FALSE);
-               sleep(1);
-               setdtr(ttyfd, TRUE);
-           }
-
            if (device_script(connector, ttyfd, ttyfd) < 0) {
-               syslog(LOG_ERR, "Connect script failed");
-               setdtr(ttyfd, FALSE);
+               error("Connect script failed");
                goto fail;
            }
 
-
-           syslog(LOG_INFO, "Serial connection established.");
+           info("Serial connection established.");
            sleep(1);           /* give it time to set up its terminal */
        }
 
@@ -490,9 +515,16 @@ main(argc, argv)
 
        /* reopen tty if necessary to wait for carrier */
        if (connector == NULL && modem) {
-           while ((i = open(devnam, O_RDWR)) < 0) {
+           for (;;) {
+               if (!devnam_info.priv)
+                   seteuid(uid);
+               i = open(devnam, O_RDWR);
+               if (!devnam_info.priv)
+                   seteuid(0);
+               if (i >= 0)
+                   break;
                if (errno != EINTR)
-                   syslog(LOG_ERR, "Failed to reopen %s: %m", devnam);
+                   error("Failed to reopen %s: %m", devnam);
                if (!persist || errno != EINTR || hungup || kill_link)
                    goto fail;
            }
@@ -502,7 +534,7 @@ main(argc, argv)
        /* run welcome script, if any */
        if (welcomer && welcomer[0]) {
            if (device_script(welcomer, ttyfd, ttyfd) < 0)
-               syslog(LOG_WARNING, "Welcome script failed");
+               warn("Welcome script failed");
        }
 
        /* set up the serial device as a ppp interface */
@@ -510,7 +542,7 @@ main(argc, argv)
 
        if (!demand) {
            
-           syslog(LOG_INFO, "Using interface ppp%d", ifunit);
+           info("Using interface ppp%d", ifunit);
            (void) sprintf(ifname, "ppp%d", ifunit);
            script_setenv("IFNAME", ifname);
 
@@ -521,17 +553,30 @@ main(argc, argv)
         * Start opening the connection and wait for
         * incoming events (reply, timeout, etc.).
         */
+       if (kill_link)
+           goto fail;
        syslog(LOG_NOTICE, "Connect: %s <--> %s", ifname, devnam);
        lcp_lowerup(0);
        lcp_open(0);            /* Start protocol */
+       open_ccp_flag = 0;
        for (phase = PHASE_ESTABLISH; phase != PHASE_DEAD; ) {
-           wait_input(timeleft(&timo));
+           if (sigsetjmp(sigjmp, 1) == 0) {
+               sigprocmask(SIG_BLOCK, &mask, NULL);
+               if (kill_link || open_ccp_flag) {
+                   sigprocmask(SIG_UNBLOCK, &mask, NULL);
+               } else {
+                   waiting = 1;
+                   sigprocmask(SIG_UNBLOCK, &mask, NULL);
+                   wait_input(timeleft(&timo));
+               }
+           }
+           waiting = 0;
            calltimeout();
-           get_input();
            if (kill_link) {
                lcp_close(0, "User request");
                kill_link = 0;
            }
+           get_input();
            if (open_ccp_flag) {
                if (phase == PHASE_NETWORK) {
                    ccp_fsm[0].flags = OPT_RESTART; /* clears OPT_SILENT */
@@ -559,9 +604,9 @@ main(argc, argv)
        if (disconnector && !hungup) {
            set_up_tty(ttyfd, 1);
            if (device_script(disconnector, ttyfd, ttyfd) < 0) {
-               syslog(LOG_WARNING, "disconnect script failed");
+               warn("disconnect script failed");
            } else {
-               syslog(LOG_INFO, "Serial link disconnected.");
+               info("Serial link disconnected.");
            }
        }
 
@@ -576,32 +621,47 @@ main(argc, argv)
        if (!demand) {
            if (pidfilename[0] != 0
                && unlink(pidfilename) < 0 && errno != ENOENT) 
-               syslog(LOG_WARNING, "unable to delete pid file: %m");
+               warn("unable to delete pid file: %m");
            pidfilename[0] = 0;
        }
 
        if (!persist)
-           die(1);
+           break;
 
+       kill_link = 0;
        if (demand)
            demand_discard();
        if (holdoff > 0 && need_holdoff) {
            phase = PHASE_HOLDOFF;
            TIMEOUT(holdoff_end, NULL, holdoff);
            do {
-               wait_time(timeleft(&timo));
+               if (sigsetjmp(sigjmp, 1) == 0) {
+                   sigprocmask(SIG_BLOCK, &mask, NULL);
+                   if (kill_link) {
+                       sigprocmask(SIG_UNBLOCK, &mask, NULL);
+                   } else {
+                       waiting = 1;
+                       sigprocmask(SIG_UNBLOCK, &mask, NULL);
+                       wait_time(timeleft(&timo));
+                   }
+               }
+               waiting = 0;
                calltimeout();
                if (kill_link) {
-                   if (!persist)
-                       die(0);
                    kill_link = 0;
                    phase = PHASE_DORMANT; /* allow signal to end holdoff */
                }
                reap_kids();
            } while (phase == PHASE_HOLDOFF);
+           if (!persist)
+               break;
        }
     }
 
+    /* Wait for scripts to finish */
+    while (n_children > 0)
+       reap_kids();
+
     die(0);
     return 0;
 }
@@ -632,15 +692,18 @@ static void
 create_pidfile()
 {
     FILE *pidfile;
+    char numbuf[16];
 
     (void) sprintf(pidfilename, "%s%s.pid", _PATH_VARRUN, ifname);
     if ((pidfile = fopen(pidfilename, "w")) != NULL) {
        fprintf(pidfile, "%d\n", pid);
        (void) fclose(pidfile);
     } else {
-       syslog(LOG_ERR, "Failed to create pid file %s: %m", pidfilename);
+       error("Failed to create pid file %s: %m", pidfilename);
        pidfilename[0] = 0;
     }
+    sprintf(numbuf, "%d", pid);
+    script_setenv("PPPD_PID", numbuf);
 }
 
 /*
@@ -671,7 +734,7 @@ get_input()
        return;
 
     if (len == 0) {
-       syslog(LOG_NOTICE, "Modem hangup");
+       notice("Modem hangup");
        hungup = 1;
        lcp_lowerdown(0);       /* serial link is no longer available */
        link_terminated(0);
@@ -727,7 +790,7 @@ get_input()
     }
 
     if (debug)
-       syslog(LOG_WARNING, "Unsupported protocol (0x%x) received", protocol);
+       warn("Unsupported protocol (0x%x) received", protocol);
     lcp_sprotrej(0, p - PPP_HDRLEN, len + PPP_HDRLEN);
 }
 
@@ -766,7 +829,7 @@ cleanup()
        close_tty();
 
     if (pidfilename[0] != 0 && unlink(pidfilename) < 0 && errno != ENOENT) 
-       syslog(LOG_WARNING, "unable to delete pid file: %m");
+       warn("unable to delete pid file: %m");
     pidfilename[0] = 0;
 
     if (locked)
@@ -782,8 +845,8 @@ close_tty()
     disestablish_ppp(ttyfd);
 
     /* drop dtr to hang up */
-    if (modem) {
-       setdtr(ttyfd, FALSE);
+    if (!default_device && modem) {
+       hangup_modem(ttyfd);
        /*
         * This sleep is in case the serial port has CLOCAL set by default,
         * and consequently will reassert DTR when we close the device.
@@ -793,13 +856,26 @@ close_tty()
 
     restore_tty(ttyfd);
 
-    if (tty_mode != (mode_t) -1)
-       chmod(devnam, tty_mode);
+    if (tty_mode != (mode_t) -1) {
+       if (fchmod(ttyfd, tty_mode) != 0) {
+           /* XXX if devnam is a symlink, this will change the link */
+           chmod(devnam, tty_mode);
+       }
+    }
 
     close(ttyfd);
     ttyfd = -1;
 }
 
+/*
+ * hangup_modem - hang up the modem by clearing DTR.
+ */
+void hangup_modem(ttyfd)
+    int ttyfd;
+{
+    setdtr(ttyfd, 0);
+}
+
 
 struct callout {
     struct timeval     c_time;         /* time at which to call routine */
@@ -831,10 +907,8 @@ timeout(func, arg, time)
     /*
      * Allocate timeout.
      */
-    if ((newp = (struct callout *) malloc(sizeof(struct callout))) == NULL) {
-       syslog(LOG_ERR, "Out of memory in timeout()!");
-       die(1);
-    }
+    if ((newp = (struct callout *) malloc(sizeof(struct callout))) == NULL)
+       fatal("Out of memory in timeout()!");
     newp->c_arg = arg;
     newp->c_func = func;
     gettimeofday(&timenow, NULL);
@@ -847,7 +921,7 @@ timeout(func, arg, time)
     for (pp = &callout; (p = *pp); pp = &p->c_next)
        if (newp->c_time.tv_sec < p->c_time.tv_sec
            || (newp->c_time.tv_sec == p->c_time.tv_sec
-               && newp->c_time.tv_usec < p->c_time.tv_sec))
+               && newp->c_time.tv_usec < p->c_time.tv_usec))
            break;
     newp->c_next = p;
     *pp = newp;
@@ -889,10 +963,8 @@ calltimeout()
     while (callout != NULL) {
        p = callout;
 
-       if (gettimeofday(&timenow, NULL) < 0) {
-           syslog(LOG_ERR, "Failed to get time of day: %m");
-           die(1);
-       }
+       if (gettimeofday(&timenow, NULL) < 0)
+           fatal("Failed to get time of day: %m");
        if (!(p->c_time.tv_sec < timenow.tv_sec
              || (p->c_time.tv_sec == timenow.tv_sec
                  && p->c_time.tv_usec <= timenow.tv_usec)))
@@ -958,11 +1030,13 @@ static void
 hup(sig)
     int sig;
 {
-    syslog(LOG_INFO, "Hangup (SIGHUP)");
+    info("Hangup (SIGHUP)");
     kill_link = 1;
     if (conn_running)
        /* Send the signal to the [dis]connector process(es) also */
        kill_my_pg(sig);
+    if (waiting)
+       siglongjmp(sigjmp, 1);
 }
 
 
@@ -976,12 +1050,14 @@ static void
 term(sig)
     int sig;
 {
-    syslog(LOG_INFO, "Terminating on signal %d.", sig);
+    info("Terminating on signal %d.", sig);
     persist = 0;               /* don't try to restart */
     kill_link = 1;
     if (conn_running)
        /* Send the signal to the [dis]connector process(es) also */
        kill_my_pg(sig);
+    if (waiting)
+       siglongjmp(sigjmp, 1);
 }
 
 
@@ -993,7 +1069,8 @@ static void
 chld(sig)
     int sig;
 {
-    reap_kids();
+    if (waiting)
+       siglongjmp(sigjmp, 1);
 }
 
 
@@ -1027,6 +1104,8 @@ open_ccp(sig)
     int sig;
 {
     open_ccp_flag = 1;
+    if (waiting)
+       siglongjmp(sigjmp, 1);
 }
 
 
@@ -1042,7 +1121,7 @@ bad_signal(sig)
     if (crashed)
        _exit(127);
     crashed = 1;
-    syslog(LOG_ERR, "Fatal signal %d", sig);
+    error("Fatal signal %d", sig);
     if (conn_running)
        kill_my_pg(SIGTERM);
     die(1);
@@ -1067,8 +1146,7 @@ device_script(program, in, out)
 
     if (pid < 0) {
        conn_running = 0;
-       syslog(LOG_ERR, "Failed to create child process: %m");
-       die(1);
+       fatal("Failed to create child process: %m");
     }
 
     if (pid == 0) {
@@ -1092,7 +1170,7 @@ device_script(program, in, out)
                close(out);
            }
        }
-       if (nodetach == 0) {
+       if (!nodetach && !updetach) {
            close(2);
            errfd = open(_PATH_CONNERRS, O_WRONLY | O_APPEND | O_CREAT, 0600);
            if (errfd >= 0 && errfd != 2) {
@@ -1100,19 +1178,22 @@ device_script(program, in, out)
                close(errfd);
            }
        }
-       setuid(getuid());
+       setuid(uid);
+       if (getuid() != uid) {
+           syslog(LOG_ERR, "setuid failed");
+           exit(1);
+       }
        setgid(getgid());
        execl("/bin/sh", "sh", "-c", program, (char *)0);
        syslog(LOG_ERR, "could not exec /bin/sh: %m");
-       _exit(99);
+       exit(99);
        /* NOTREACHED */
     }
 
     while (waitpid(pid, &status, 0) < 0) {
        if (errno == EINTR)
            continue;
-       syslog(LOG_ERR, "error waiting for (dis)connection process: %m");
-       die(1);
+       fatal("error waiting for (dis)connection process: %m");
     }
     conn_running = 0;
 
@@ -1120,33 +1201,67 @@ device_script(program, in, out)
 }
 
 
+/*
+ * We maintain a list of child process pids and
+ * functions to call when they exit.
+ */
+struct subprocess {
+    pid_t      pid;
+    char       *prog;
+    void       (*done) __P((void *));
+    void       *arg;
+    struct subprocess *next;
+};
+
+struct subprocess *children;
+
 /*
  * run-program - execute a program with given arguments,
  * but don't wait for it.
  * If the program can't be executed, logs an error unless
  * must_exist is 0 and the program file doesn't exist.
+ * Returns -1 if it couldn't fork, 0 if the file doesn't exist
+ * or isn't an executable plain file, or the process ID of the child.
+ * If done != NULL, (*done)(arg) will be called later (within
+ * reap_kids) iff the return value is > 0.
  */
-int
-run_program(prog, args, must_exist)
+pid_t
+run_program(prog, args, must_exist, done, arg)
     char *prog;
     char **args;
     int must_exist;
+    void (*done) __P((void *));
+    void *arg;
 {
     int pid;
+    struct subprocess *chp;
+    struct stat sbuf;
 
-    pid = fork();
-    if (pid == -1) {
-       syslog(LOG_ERR, "Failed to create child process for %s: %m", prog);
-       return -1;
+    /*
+     * First check if the file exists and is executable.
+     * We don't use access() because that would use the
+     * real user-id, which might not be root, and the script
+     * might be accessible only to root.
+     */
+    errno = EINVAL;
+    if (stat(prog, &sbuf) < 0 || !S_ISREG(sbuf.st_mode)
+       || (sbuf.st_mode & (S_IXUSR|S_IXGRP|S_IXOTH)) == 0) {
+       if (must_exist || errno != ENOENT)
+           warn("Can't execute %s: %m", prog);
+       return 0;
     }
+
+    pid = fork();
+    if (pid == -1)
+       fatal("Failed to create child process for %s: %m", prog);
     if (pid == 0) {
        int new_fd;
 
        /* Leave the current location */
-       (void) setsid();    /* No controlling tty. */
+       (void) setsid();        /* No controlling tty. */
        (void) umask (S_IRWXG|S_IRWXO);
-       (void) chdir ("/"); /* no current directory. */
-       setuid(geteuid());
+       (void) chdir ("/");     /* no current directory. */
+       setuid(0);              /* set real UID = root */
        setgid(getegid());
 
        /* Ensure that nothing of our device environment is inherited. */
@@ -1171,20 +1286,35 @@ run_program(prog, args, must_exist)
 #ifdef BSD
        /* Force the priority back to zero if pppd is running higher. */
        if (setpriority (PRIO_PROCESS, 0, 0) < 0)
-           syslog (LOG_WARNING, "can't reset priority to 0: %m"); 
+           syslog(LOG_WARNING, "can't reset priority to 0: %m"); 
 #endif
 
        /* SysV recommends a second fork at this point. */
 
-       /* run the program; give it a null environment */
+       /* run the program */
        execve(prog, args, script_env);
        if (must_exist || errno != ENOENT)
            syslog(LOG_WARNING, "Can't execute %s: %m", prog);
        _exit(-1);
     }
-    MAINDEBUG((LOG_DEBUG, "Script %s started; pid = %d", prog, pid));
+
+    if (debug)
+       dbglog("Script %s started; pid = %d", prog, pid);
     ++n_children;
-    return 0;
+
+    chp = (struct subprocess *) malloc(sizeof(struct subprocess));
+    if (chp == NULL) {
+       warn("losing track of %s process", prog);
+    } else {
+       chp->pid = pid;
+       chp->prog = prog;
+       chp->done = done;
+       chp->arg = arg;
+       chp->next = children;
+       children = chp;
+    }
+
+    return pid;
 }
 
 
@@ -1196,21 +1326,27 @@ static void
 reap_kids()
 {
     int pid, status;
+    struct subprocess *chp, **prevp;
 
     if (n_children == 0)
        return;
-    if ((pid = waitpid(-1, &status, WNOHANG)) == -1) {
-       if (errno != ECHILD)
-           syslog(LOG_ERR, "Error waiting for child process: %m");
-       return;
-    }
-    if (pid > 0) {
+    while ((pid = waitpid(-1, &status, WNOHANG)) != -1 && pid != 0) {
        --n_children;
+       for (prevp = &children; (chp = *prevp) != NULL; prevp = &chp->next)
+           if (chp->pid == pid)
+               break;
+       if (debug)
+           dbglog("process %d (%s) finished, status = 0x%x",
+                  pid, (chp? chp->prog: "??"), status);
        if (WIFSIGNALED(status)) {
-           syslog(LOG_WARNING, "Child process %d terminated with signal %d",
-                  pid, WTERMSIG(status));
+           warn("Child process %s (pid %d) terminated with signal %d",
+                (chp? chp->prog: "??"), pid, WTERMSIG(status));
        }
+       if (chp && chp->done)
+           (*chp->done)(chp->arg);
     }
+    if (pid == -1 && errno != ECHILD)
+       error("Error waiting for child process: %m");
 }
 
 
@@ -1228,7 +1364,7 @@ log_packet(p, len, prefix, level)
     char *prefix;
     int level;
 {
-    strcpy(line, prefix);
+    strlcpy(line, sizeof(line), prefix);
     linep = line + strlen(line);
     format_packet(p, len, pr_log, NULL);
     if (linep != line)
@@ -1269,10 +1405,12 @@ format_packet(p, len, printer, arg)
        }
     }
 
-    for (; len > 0; --len) {
+    for (i = 0; i < len && i < 32; ++i) {
        GETCHAR(x, p);
        printer(arg, " %.2x", x);
     }
+    if (i < len)
+       printer(arg, " ...");
 }
 
 static void
@@ -1292,14 +1430,14 @@ pr_log __V((void *arg, char *fmt, ...))
     fmt = va_arg(pvar, char *);
 #endif
 
-    n = vfmtmsg(buf, sizeof(buf), fmt, pvar);
+    n = vslprintf(buf, sizeof(buf), fmt, pvar);
     va_end(pvar);
 
     if (linep + n + 1 > line + sizeof(line)) {
        syslog(LOG_DEBUG, "%s", line);
        linep = line;
     }
-    strcpy(linep, buf);
+    strlcpy(linep, line + sizeof(line) - linep, buf);
     linep += n;
 }
 
@@ -1349,19 +1487,19 @@ void
 novm(msg)
     char *msg;
 {
-    syslog(LOG_ERR, "Virtual memory exhausted allocating %s\n", msg);
-    die(1);
+    fatal("Virtual memory exhausted allocating %s\n", msg);
 }
 
 /*
- * fmtmsg - format a message into a buffer.  Like sprintf except we
+ * slprintf - format a message into a buffer.  Like sprintf except we
  * also specify the length of the output buffer, and we handle
- * %r (recursive format), %m (error message) and %I (IP address) formats.
+ * %r (recursive format), %m (error message), %v (visible string),
+ * %q (quoted string), %t (current time) and %I (IP address) formats.
  * Doesn't do floating-point formats.
  * Returns the number of chars put into buf.
  */
 int
-fmtmsg __V((char *buf, int buflen, char *fmt, ...))
+slprintf __V((char *buf, int buflen, char *fmt, ...))
 {
     va_list args;
     int n;
@@ -1377,18 +1515,18 @@ fmtmsg __V((char *buf, int buflen, char *fmt, ...))
     buflen = va_arg(args, int);
     fmt = va_arg(args, char *);
 #endif
-    n = vfmtmsg(buf, buflen, fmt, args);
+    n = vslprintf(buf, buflen, fmt, args);
     va_end(args);
     return n;
 }
 
 /*
- * vfmtmsg - like fmtmsg, takes a va_list instead of a list of args.
+ * vslprintf - like slprintf, takes a va_list instead of a list of args.
  */
 #define OUTCHAR(c)     (buflen > 0? (--buflen, *buf++ = (c)): 0)
 
 int
-vfmtmsg(buf, buflen, fmt, args)
+vslprintf(buf, buflen, fmt, args)
     char *buf;
     int buflen;
     char *fmt;
@@ -1492,10 +1630,10 @@ vfmtmsg(buf, buflen, fmt, args)
        case 'r':
            f = va_arg(args, char *);
 #ifndef __powerpc__
-           n = vfmtmsg(buf, buflen + 1, f, va_arg(args, va_list));
+           n = vslprintf(buf, buflen + 1, f, va_arg(args, va_list));
 #else
            /* On the powerpc, a va_list is an array of 1 structure */
-           n = vfmtmsg(buf, buflen + 1, f, va_arg(args, void *));
+           n = vslprintf(buf, buflen + 1, f, va_arg(args, void *));
 #endif
            buf += n;
            buflen -= n;
@@ -1610,16 +1748,14 @@ void
 script_setenv(var, value)
     char *var, *value;
 {
-    int vl = strlen(var);
+    size_t vl = strlen(var) + strlen(value) + 2;
     int i;
     char *p, *newstring;
 
-    newstring = (char *) malloc(vl + strlen(value) + 2);
+    newstring = (char *) malloc(vl);
     if (newstring == 0)
        return;
-    strcpy(newstring, var);
-    newstring[vl] = '=';
-    strcpy(newstring+vl+1, value);
+    slprintf(newstring, vl, "%s=%s", var, value);
 
     /* check if this variable is already set */
     if (script_env != 0) {
@@ -1676,3 +1812,170 @@ script_unsetenv(var)
        }
     }
 }
+
+/*
+ * strlcpy - like strcpy/strncpy, doesn't overflow destination buffer,
+ * always leaves destination null-terminated (for len > 0).
+ */
+void
+strlcpy(char *dest, size_t len, const char *src)
+{
+    if (len == 0)
+       return;
+    if (strlen(src) < len)
+       strcpy(dest, src);
+    else {
+       strncpy(dest, src, len - 1);
+       dest[len-1] = 0;
+    }
+}
+
+/*
+ * strlcat - like strcat/strncat, doesn't overflow destination buffer,
+ * always leaves destination null-terminated (for len > 0).
+ */
+void
+strlcat(char *dest, size_t len, const char *src)
+{
+    size_t dlen;
+
+    if (len == 0)
+       return;
+    dlen = strlen(dest);
+    if (dlen < len - 1)
+       strlcpy(dest + dlen, len - dlen, src);
+}
+
+/*
+ * fatal - log an error message and die horribly.
+ */
+void
+fatal __V((char *fmt, ...))
+{
+    va_list pvar;
+
+#if __STDC__
+    va_start(pvar, fmt);
+#else
+    char *fmt;
+    va_start(pvar);
+    fmt = va_arg(pvar, char *);
+#endif
+
+    vslprintf(line, sizeof(line), fmt, pvar);
+    va_end(pvar);
+
+    syslog(LOG_ERR, "%s", line);
+
+    die(1);                    /* as promised */
+}
+
+/*
+ * error - log an error message.
+ */
+void
+error __V((char *fmt, ...))
+{
+    va_list pvar;
+
+#if __STDC__
+    va_start(pvar, fmt);
+#else
+    char *fmt;
+    va_start(pvar);
+    fmt = va_arg(pvar, char *);
+#endif
+
+    vslprintf(line, sizeof(line), fmt, pvar);
+    va_end(pvar);
+
+    syslog(LOG_ERR, "%s", line);
+}
+
+/*
+ * warn - log a warning message.
+ */
+void
+warn __V((char *fmt, ...))
+{
+    va_list pvar;
+
+#if __STDC__
+    va_start(pvar, fmt);
+#else
+    char *fmt;
+    va_start(pvar);
+    fmt = va_arg(pvar, char *);
+#endif
+
+    vslprintf(line, sizeof(line), fmt, pvar);
+    va_end(pvar);
+
+    syslog(LOG_WARNING, "%s", line);
+}
+
+/*
+ * notice - log a notice-level message.
+ */
+void
+notice __V((char *fmt, ...))
+{
+    va_list pvar;
+
+#if __STDC__
+    va_start(pvar, fmt);
+#else
+    char *fmt;
+    va_start(pvar);
+    fmt = va_arg(pvar, char *);
+#endif
+
+    vslprintf(line, sizeof(line), fmt, pvar);
+    va_end(pvar);
+
+    syslog(LOG_NOTICE, "%s", line);
+}
+
+/*
+ * info - log an informational message.
+ */
+void
+info __V((char *fmt, ...))
+{
+    va_list pvar;
+
+#if __STDC__
+    va_start(pvar, fmt);
+#else
+    char *fmt;
+    va_start(pvar);
+    fmt = va_arg(pvar, char *);
+#endif
+
+    vslprintf(line, sizeof(line), fmt, pvar);
+    va_end(pvar);
+
+    syslog(LOG_INFO, "%s", line);
+}
+
+/*
+ * dbglog - log a debug message.
+ */
+void
+dbglog __V((char *fmt, ...))
+{
+    va_list pvar;
+
+#if __STDC__
+    va_start(pvar, fmt);
+#else
+    char *fmt;
+    va_start(pvar);
+    fmt = va_arg(pvar, char *);
+#endif
+
+    vslprintf(line, sizeof(line), fmt, pvar);
+    va_end(pvar);
+
+    syslog(LOG_DEBUG, "%s", line);
+}