]> git.ozlabs.org Git - ppp.git/blobdiff - pppd/main.c
Update to state of pppd-new directory
[ppp.git] / pppd / main.c
index c580f7c6e23d618e0ff7544b2083a25d5c3683d4..51b5535b4102a8494166b779e0cd168cc1005f6a 100644 (file)
  */
 
 #ifndef lint
-static char rcsid[] = "$Id: main.c,v 1.19 1994/09/21 06:47:37 paulus Exp $";
+static char rcsid[] = "$Id: main.c,v 1.23.2.1 1995/06/01 07:01:31 paulus Exp $";
 #endif
 
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 #include <signal.h>
 #include <errno.h>
@@ -64,38 +65,41 @@ int ifunit;                 /* Interface unit number */
 
 char *progname;                        /* Name of this program */
 char hostname[MAXNAMELEN];     /* Our hostname */
-static char pidfilename[MAXPATHLEN];
-
+static char pidfilename[MAXPATHLEN];   /* name of pid file */
+static char default_devnam[MAXPATHLEN];        /* name of default device */
 static pid_t   pid;            /* Our pid */
 static pid_t   pgrpid;         /* Process Group ID */
 static uid_t uid;              /* Our real user-id */
 
 int fd = -1;                   /* Device file descriptor */
-int s;                         /* Socket file descriptor */
 
 int phase;                     /* where the link is at */
 int kill_link;
 int open_ccp_flag;
 
 static int initfdflags = -1;   /* Initial file descriptor flags */
+static int loop_fd = -1;       /* fd for loopback device */
 
 u_char outpacket_buf[PPP_MRU+PPP_HDRLEN]; /* buffer for outgoing packet */
-static u_char inpacket_buf[PPP_MRU+PPP_HDRLEN]; /* buffer for incoming packet */
+u_char inpacket_buf[PPP_MRU+PPP_HDRLEN]; /* buffer for incoming packet */
 
 int hungup;                    /* terminal has been hung up */
 static int n_children;         /* # child processes still running */
 
 int baud_rate;
 
+static int locked;
+
 /* prototypes */
 static void hup __P((int));
 static void term __P((int));
 static void chld __P((int));
 static void toggle_debug __P((int));
 static void open_ccp __P((int));
+static void holdoff_end __P((void *));
 
 static void get_input __P((void));
-void establish_ppp __P((void));
+void establish_ppp __P((int));
 void calltimeout __P((void));
 struct timeval *timeleft __P((struct timeval *));
 void reap_kids __P((void));
@@ -112,6 +116,11 @@ void pr_log __P((void *, char *, ...));
 extern char    *ttyname __P((int));
 extern char    *getlogin __P((void));
 
+#ifdef ultrix
+#undef O_NONBLOCK
+#define        O_NONBLOCK      O_NDELAY
+#endif
+
 /*
  * PPP Data Link Layer "protocol" table.
  * One entry per supported protocol.
@@ -155,6 +164,7 @@ main(argc, argv)
     p = ttyname(0);
     if (p)
        strcpy(devnam, p);
+    strcpy(default_devnam, devnam);
 
     if (gethostname(hostname, MAXNAMELEN) < 0 ) {
        perror("couldn't get hostname");
@@ -187,12 +197,27 @@ main(argc, argv)
     check_auth_options();
     setipdefault();
 
+    /*
+     * If the user has specified the default device name explicitly,
+     * pretend they hadn't.
+     */
+    if (!default_device && strcmp(devnam, default_devnam) == 0)
+       default_device = 1;
+
     /*
      * Initialize system-dependent stuff and magic number package.
      */
     sys_init();
     magic_init();
 
+    /*
+     * For dial-on-demand, we need to know the remote address.
+     */
+    if (demand && ipcp_wantoptions[0].hisaddr == 0) {
+       fprintf(stderr, "Remote IP address must be specified for dial-on-demand\n");
+       exit(1);
+    }
+
     /*
      * Detach ourselves from the terminal, if required,
      * and identify who is running us.
@@ -212,12 +237,6 @@ main(argc, argv)
     }
     syslog(LOG_NOTICE, "pppd %s.%d started by %s, uid %d",
           VERSION, PATCHLEVEL, p, uid);
-
-    /* Get an internet socket for doing socket ioctl's on. */
-    if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
-       syslog(LOG_ERR, "Couldn't create IP socket: %m");
-       die(1);
-    }
   
     /*
      * Compute mask of all interesting signals and install signal handlers
@@ -249,13 +268,72 @@ main(argc, argv)
     signal(SIGUSR2, open_ccp);         /* Reopen CCP */
 
     /*
-     * Lock the device if we've been asked to.
+     * If we're doing dial-on-demand, set up the interface now.
      */
-    if (lockflag && !default_device)
-       if (lock(devnam) < 0)
-           die(1);
+    if (demand) {
+       /*
+        * Open the loopback channel and set it up to be the ppp interface.
+        */
+       loop_fd = open_loopback();
+       establish_ppp(loop_fd);
+
+       syslog(LOG_INFO, "Using interface ppp%d", ifunit);
+       (void) sprintf(ifname, "ppp%d", ifunit);
 
-    do {
+       /* write pid to file */
+       (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);
+           pidfilename[0] = 0;
+       }
+
+       /*
+        * Configure the interface and mark it up, etc.
+        */
+       demand_conf();
+    }
+
+    for (;;) {
+
+       if (demand) {
+           /*
+            * Don't do anything until we see some activity.
+            */
+           phase = PHASE_DORMANT;
+           fd = loop_fd;
+           kill_link = 0;
+           demand_unblock();
+           for (;;) {
+               wait_loop_output(timeleft(&timo));
+               calltimeout();
+               if (kill_link) {
+                   if (!persist)
+                       die(0);
+                   kill_link = 0;
+               }
+               if (get_loop_output())
+                   break;
+               reap_kids();
+           }
+
+           /*
+            * Now we want to bring up the link.
+            */
+           demand_block();
+           syslog(LOG_INFO, "Starting link");
+       }
+
+       /*
+        * Lock the device if we've been asked to.
+        */
+       if (lockflag && !default_device) {
+           if (lock(devnam) < 0)
+               goto fail;
+           locked = 1;
+       }
 
        /*
         * Open the serial device and set it up to be the ppp interface.
@@ -266,7 +344,7 @@ main(argc, argv)
        nonblock = (connector || !modem)? O_NONBLOCK: 0;
        if ((fd = open(devnam, nonblock | O_RDWR, 0)) < 0) {
            syslog(LOG_ERR, "Failed to open %s: %m", devnam);
-           die(1);
+           goto fail;
        }
        if ((initfdflags = fcntl(fd, F_GETFL)) == -1) {
            syslog(LOG_ERR, "Couldn't get device fd flags: %m");
@@ -296,32 +374,16 @@ main(argc, argv)
            if (device_script(connector, fd, fd) < 0) {
                syslog(LOG_ERR, "Connect script failed");
                setdtr(fd, FALSE);
-               die(1);
+               goto fail;
            }
 
-           syslog(LOG_INFO, "Connected...");
+           syslog(LOG_INFO, "Serial connection established.");
            sleep(1);           /* give it time to set up its terminal */
        }
   
        /* set line speed, flow control, etc.; clear CLOCAL if modem option */
        set_up_tty(fd, 0);
 
-       /* set up the serial device as a ppp interface */
-       establish_ppp();
-
-       syslog(LOG_INFO, "Using interface ppp%d", ifunit);
-       (void) sprintf(ifname, "ppp%d", ifunit);
-
-       /* write pid to file */
-       (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);
-           pidfilename[0] = 0;
-       }
-
        /*
         * Set device for non-blocking reads.
         */
@@ -330,8 +392,33 @@ main(argc, argv)
            die(1);
        }
   
+       if (!demand) {
+           /* set up the serial device as a ppp interface */
+           establish_ppp(fd);
+           
+           syslog(LOG_INFO, "Using interface ppp%d", ifunit);
+           (void) sprintf(ifname, "ppp%d", ifunit);
+           
+           /* write pid to file */
+           (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);
+               pidfilename[0] = 0;
+           }
+
+       } else {
+           /*
+            * Transfer the PPP unit over to the real serial device.
+            */
+           transfer_ppp(fd);
+       }
+
        /*
-        * Block all signals, start opening the connection, and wait for
+        * Start opening the connection and wait for
         * incoming events (reply, timeout, etc.).
         */
        syslog(LOG_NOTICE, "Connect: %s <--> %s", ifname, devnam);
@@ -356,30 +443,79 @@ main(argc, argv)
        }
 
        /*
-        * Run disconnector script, if requested
+        * If we may want to bring the link up again, transfer
+        * the ppp unit back to the loopback.  Set the
+        * real serial device back to its normal mode of operation.
         */
-       if (disconnector) {
+       clean_check();
+       if (demand) {
+           transfer_ppp(loop_fd);
+       } else {
+           disestablish_ppp(fd);
+       }
+
+       /*
+        * Run disconnector script, if requested.
+        * First we need to reset non-blocking mode.
+        * XXX we may not be able to do this if the line has hung up!
+        */
+       if (initfdflags != -1 && fcntl(fd, F_SETFL, initfdflags) >= 0)
+           initfdflags = -1;
+       if (disconnector && !hungup) {
+           set_up_tty(fd, 1);
            if (device_script(disconnector, fd, fd) < 0) {
                syslog(LOG_WARNING, "disconnect script failed");
-               die(1);
+           } else {
+               syslog(LOG_INFO, "Serial link disconnected.");
            }
-
-           syslog(LOG_INFO, "Disconnected...");
        }
 
+    fail:
        close_fd();
-       if (unlink(pidfilename) < 0 && errno != ENOENT) 
-           syslog(LOG_WARNING, "unable to delete pid file: %m");
-       pidfilename[0] = 0;
+       if (locked) {
+           unlock();
+           locked = 0;
+       }
 
-    } while (persist);
+       if (!demand) {
+           if (unlink(pidfilename) < 0 && errno != ENOENT) 
+               syslog(LOG_WARNING, "unable to delete pid file: %m");
+           pidfilename[0] = 0;
+       }
 
-    if (lockflag && !default_device)
-       unlock();
+       if (!persist)
+           break;
+
+       demand_discard();
+       if (holdoff > 0) {
+           phase = PHASE_HOLDOFF;
+           TIMEOUT(holdoff_end, NULL, holdoff);
+           do {
+               wait_time(timeleft(&timo));
+               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);
+       }
+    }
 
-    exit(0);
+    die(0);
 }
 
+/*
+ * holdoff_end - called via a timeout when the holdoff period ends.
+ */
+static void
+holdoff_end(arg)
+    void *arg;
+{
+    phase = PHASE_DORMANT;
+}
 
 /*
  * get_input - called when incoming data is available.
@@ -391,61 +527,58 @@ get_input()
     u_char *p;
     u_short protocol;
 
-    for (;;) {                 /* Read all available packets */
-       p = inpacket_buf;       /* point to beginning of packet buffer */
-
-       len = read_packet(inpacket_buf);
-       if (len < 0)
-           return;
+    p = inpacket_buf;  /* point to beginning of packet buffer */
 
-       if (len == 0) {
-           MAINDEBUG((LOG_DEBUG, "End of file on fd!"));
-           hungup = 1;
-           lcp_lowerdown(0);   /* serial link is no longer available */
-           phase = PHASE_DEAD;
-           return;
-       }
+    len = read_packet(inpacket_buf);
+    if (len < 0)
+       return;
 
-       if (debug /*&& (debugflags & DBG_INPACKET)*/)
-           log_packet(p, len, "rcvd ");
+    if (len == 0) {
+       syslog(LOG_NOTICE, "Modem hangup");
+       hungup = 1;
+       lcp_lowerdown(0);       /* serial link is no longer available */
+       phase = PHASE_DEAD;
+       return;
+    }
 
-       if (len < PPP_HDRLEN) {
-           MAINDEBUG((LOG_INFO, "io(): Received short packet."));
-           return;
-       }
+    if (debug /*&& (debugflags & DBG_INPACKET)*/)
+       log_packet(p, len, "rcvd ");
 
-       p += 2;                         /* Skip address and control */
-       GETSHORT(protocol, p);
-       len -= PPP_HDRLEN;
+    if (len < PPP_HDRLEN) {
+       MAINDEBUG((LOG_INFO, "io(): Received short packet."));
+       return;
+    }
 
-       /*
-        * Toss all non-LCP packets unless LCP is OPEN.
-        */
-       if (protocol != PPP_LCP && lcp_fsm[0].state != OPENED) {
-           MAINDEBUG((LOG_INFO,
-                      "io(): Received non-LCP packet when LCP not open."));
-           return;
-       }
+    p += 2;                            /* Skip address and control */
+    GETSHORT(protocol, p);
+    len -= PPP_HDRLEN;
 
-       /*
-        * Upcall the proper protocol input routine.
-        */
-       for (i = 0; i < sizeof (prottbl) / sizeof (struct protent); i++)
-           if (prottbl[i].protocol == protocol) {
-               (*prottbl[i].input)(0, p, len);
-               break;
-           } else if (protocol == (prottbl[i].protocol & ~0x8000)
-                      && prottbl[i].datainput != NULL) {
-               (*prottbl[i].datainput)(0, p, len);
-               break;
-           }
+    /*
+     * Toss all non-LCP packets unless LCP is OPEN.
+     */
+    if (protocol != PPP_LCP && lcp_fsm[0].state != OPENED) {
+       MAINDEBUG((LOG_INFO,
+                  "io(): Received non-LCP packet when LCP not open."));
+       return;
+    }
 
-       if (i == sizeof (prottbl) / sizeof (struct protent)) {
-           if (debug)
-               syslog(LOG_WARNING, "Unknown protocol (0x%x) received",
-                      protocol);
-           lcp_sprotrej(0, p - PPP_HDRLEN, len + PPP_HDRLEN);
+    /*
+     * Upcall the proper protocol input routine.
+     */
+    for (i = 0; i < sizeof (prottbl) / sizeof (struct protent); i++)
+       if (prottbl[i].protocol == protocol) {
+           (*prottbl[i].input)(0, p, len);
+           break;
+       } else if (protocol == (prottbl[i].protocol & ~0x8000)
+                  && prottbl[i].datainput != NULL) {
+           (*prottbl[i].datainput)(0, p, len);
+           break;
        }
+
+    if (i == sizeof (prottbl) / sizeof (struct protent)) {
+       if (debug)
+           syslog(LOG_WARNING, "Unknown protocol (0x%x) received", protocol);
+       lcp_sprotrej(0, p - PPP_HDRLEN, len + PPP_HDRLEN);
     }
 }
 
@@ -512,8 +645,11 @@ cleanup(status, arg)
        syslog(LOG_WARNING, "unable to delete pid file: %m");
     pidfilename[0] = 0;
 
-    if (lockflag && !default_device)
+    if (locked)
        unlock();
+
+    if (demand)
+       demand_reset();
 }
 
 /*
@@ -530,7 +666,7 @@ close_fd()
        syslog(LOG_WARNING, "Couldn't restore device fd flags: %m");
     initfdflags = -1;
 
-    disestablish_ppp();
+    disestablish_ppp(fd);
 
     restore_tty();
 
@@ -563,8 +699,8 @@ timeout(func, arg, time)
 {
     struct callout *newp, *p, **pp;
   
-    MAINDEBUG((LOG_DEBUG, "Timeout %x:%x in %d seconds.",
-              (int) func, (int) arg, time));
+    MAINDEBUG((LOG_DEBUG, "Timeout %lx:%lx in %d seconds.",
+              (long) func, (long) arg, time));
   
     /*
      * Allocate timeout.
@@ -583,9 +719,9 @@ timeout(func, arg, time)
      * Find correct place and link it in.
      */
     for (pp = &callout; (p = *pp); pp = &p->c_next)
-       if (p->c_time.tv_sec < newp->c_time.tv_sec
-           || (p->c_time.tv_sec == newp->c_time.tv_sec
-               && p->c_time.tv_usec <= newp->c_time.tv_sec))
+       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))
            break;
     newp->c_next = p;
     *pp = newp;
@@ -604,7 +740,7 @@ untimeout(func, arg)
     struct callout **copp, *freep;
     int reschedule = 0;
   
-    MAINDEBUG((LOG_DEBUG, "Untimeout %x:%x.", (int) func, (int) arg));
+    MAINDEBUG((LOG_DEBUG, "Untimeout %lx:%lx.", (long) func, (long) arg));
   
     /*
      * Find first matching timeout and remove it from the list.
@@ -754,12 +890,7 @@ device_script(program, in, out)
 {
     int pid;
     int status;
-    sigset_t mask;
-
-    sigemptyset(&mask);
-    sigaddset(&mask, SIGINT);
-    sigaddset(&mask, SIGHUP);
-    sigprocmask(SIG_BLOCK, &mask, &mask);
+    int errfd;
 
     pid = fork();
 
@@ -769,11 +900,14 @@ device_script(program, in, out)
     }
 
     if (pid == 0) {
-       setreuid(getuid(), getuid());
-       setregid(getgid(), getgid());
-       sigprocmask(SIG_SETMASK, &mask, NULL);
+       sys_close();
        dup2(in, 0);
        dup2(out, 1);
+       errfd = open(_PATH_CONNERRS, O_WRONLY | O_APPEND | O_CREAT, 0644);
+       if (errfd >= 0)
+           dup2(errfd, 2);
+       setuid(getuid());
+       setgid(getgid());
        execl("/bin/sh", "sh", "-c", program, (char *)0);
        syslog(LOG_ERR, "could not exec /bin/sh: %m");
        _exit(99);
@@ -786,7 +920,6 @@ device_script(program, in, out)
        syslog(LOG_ERR, "error waiting for (dis)connection process: %m");
        die(1);
     }
-    sigprocmask(SIG_SETMASK, &mask, NULL);
 
     return (status == 0 ? 0 : -1);
 }
@@ -805,6 +938,7 @@ run_program(prog, args, must_exist)
     int must_exist;
 {
     int pid;
+    char *nullenv[1];
 
     pid = fork();
     if (pid == -1) {
@@ -812,20 +946,22 @@ run_program(prog, args, must_exist)
        return -1;
     }
     if (pid == 0) {
-        int new_fd;
+       int new_fd;
 
        /* Leave the current location */
        (void) setsid();    /* No controlling tty. */
-       (void) umask (0);   /* no umask. Must change in script. */
+       (void) umask (S_IRWXG|S_IRWXO);
        (void) chdir ("/"); /* no current directory. */
+       setuid(geteuid());
+       setgid(getegid());
 
        /* Ensure that nothing of our device environment is inherited. */
+       sys_close();
        close (0);
        close (1);
        close (2);
-       close (s);   /* Socket interface to the ppp device */
        close (fd);  /* tty interface to the ppp device */
-       
+
         /* Don't pass handles to the PPP device, even by accident. */
        new_fd = open (_PATH_DEVNULL, O_RDWR);
        if (new_fd >= 0) {
@@ -837,14 +973,17 @@ run_program(prog, args, must_exist)
            dup2 (0, 2); /* stderr -> /dev/null */
        }
 
+#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"); 
+#endif
 
        /* SysV recommends a second fork at this point. */
 
-       /* run the program */
-       execv(prog, args);
+       /* run the program; give it a null environment */
+       nullenv[0] = NULL;
+       execve(prog, args, nullenv);
        if (must_exist || errno != ENOENT)
            syslog(LOG_WARNING, "Can't execute %s: %m", prog);
        _exit(-1);