/* * main.c - Point-to-Point Protocol main module * * Copyright (c) 1989 Carnegie Mellon University. * All rights reserved. * * Redistribution and use in source and binary forms are permitted * provided that the above copyright notice and this paragraph are * duplicated in all such forms and that any documentation, * advertising materials, and other materials related to such * distribution and use acknowledge that the software was developed * by Carnegie Mellon University. The name of the * University may not be used to endorse or promote products derived * from this software without specific prior written permission. * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE. */ #define SETSID #include #include #include #include #include #include #include #ifdef STREAMS #undef SGTTY #endif #ifdef SGTTY #include #else #ifndef sun #include #endif #include #endif #include #include #include #include #include #include "callout.h" #include #include #include #ifndef BSD #define BSD 43 #endif /*BSD*/ #include "ppp.h" #include "magic.h" #include "fsm.h" #include "lcp.h" #include "ipcp.h" #include "upap.h" #include "chap.h" #include "pppd.h" #include "pathnames.h" #include "patchlevel.h" #ifndef TRUE #define TRUE (1) #endif /*TRUE*/ #ifndef FALSE #define FALSE (0) #endif /*FALSE*/ #ifdef PIDPATH static char *pidpath = PIDPATH; /* filename in which pid will be stored */ #else static char *pidpath = _PATH_PIDFILE; #endif /* PIDFILE */ /* interface vars */ char ifname[IFNAMSIZ]; /* Interface name */ int ifunit; /* Interface unit number */ char *progname; /* Name of this program */ char hostname[MAXNAMELEN]; /* Our hostname */ char our_name[MAXNAMELEN]; char remote_name[MAXNAMELEN]; static pid_t pid; /* Our pid */ static pid_t pgrpid; /* Process Group ID */ static char pidfilename[MAXPATHLEN]; char devname[MAXPATHLEN] = "/dev/tty"; /* Device name */ int default_device = TRUE; /* use default device (stdin/out) */ int fd; /* Device file descriptor */ int s; /* Socket file descriptor */ #ifdef SGTTY static struct sgttyb initsgttyb; /* Initial TTY sgttyb */ #else static struct termios inittermios; /* Initial TTY termios */ #endif static int initfdflags = -1; /* Initial file descriptor flags */ static int restore_term; /* 1 => we've munged the terminal */ u_char outpacket_buf[MTU+DLLHEADERLEN]; /* buffer for outgoing packet */ static u_char inpacket_buf[MTU+DLLHEADERLEN]; /* buffer for incoming packet */ int hungup; /* terminal has been hung up */ /* configured variables */ int debug = 0; /* Debug flag */ char user[MAXNAMELEN]; /* username for PAP */ char passwd[MAXSECRETLEN]; /* password for PAP */ char *connector = NULL; /* "connect" command */ int inspeed = 0; /* Input/Output speed */ u_long netmask = 0; /* netmask to use on ppp interface */ int crtscts = 0; /* use h/w flow control */ int nodetach = 0; /* don't fork */ int modem = 0; /* use modem control lines */ int auth_required = 0; /* require peer to authenticate */ int defaultroute = 0; /* assign default route through interface */ int proxyarp = 0; /* set entry in arp table */ int persist = 0; /* re-initiate on termination */ int answer = 0; /* wait for incoming call */ int uselogin = 0; /* check PAP info against /etc/passwd */ /* prototypes */ static void hup __ARGS((int, int, struct sigcontext *, char *)); static void intr __ARGS((int, int, struct sigcontext *, char *)); static void term __ARGS((int, int, struct sigcontext *, char *)); static void alrm __ARGS((int, int, struct sigcontext *, char *)); static void io __ARGS((int, int, struct sigcontext *, char *)); static void incdebug __ARGS((int)); static void nodebug __ARGS((int)); void establish_ppp __ARGS((void)); void cleanup __ARGS((int, caddr_t)); void die __ARGS((int)); void dumpbuffer __ARGS((unsigned char *, int, int)); #ifdef STREAMS extern char *ttyname __ARGS((int)); #endif extern char *getlogin __ARGS((void)); /* * PPP Data Link Layer "protocol" table. * One entry per supported protocol. */ static struct protent { u_short protocol; void (*init)(); void (*input)(); void (*protrej)(); } prottbl[] = { { LCP, lcp_init, lcp_input, lcp_protrej }, { IPCP, ipcp_init, ipcp_input, ipcp_protrej }, { UPAP, upap_init, upap_input, upap_protrej }, { CHAP, ChapInit, ChapInput, ChapProtocolReject }, }; main(argc, argv) int argc; char *argv[]; { int mask, i; struct sigvec sv; struct cmd *cmdp; FILE *pidfile; char *p; /* * Initialize syslog system and magic number package. */ #if BSD >= 43 || defined(sun) openlog("pppd", LOG_PID | LOG_NDELAY, LOG_PPP); setlogmask(LOG_UPTO(LOG_INFO)); #else openlog("pppd", LOG_PID); #define LOG_UPTO(x) (x) #define setlogmask(x) (x) #endif #ifdef STREAMS p = ttyname(fileno(stdin)); if (p) strcpy(devname, p); #endif magic_init(); if (gethostname(hostname, MAXNAMELEN) < 0 ) { syslog(LOG_ERR, "couldn't get hostname: %m"); die(1); } hostname[MAXNAMELEN-1] = 0; pid = getpid(); /* * Initialize to the standard option set, then parse, in order, * the system options file, the user's options file, and the command * line arguments. */ for (i = 0; i < sizeof (prottbl) / sizeof (struct protent); i++) (*prottbl[i].init)(0); progname = *argv; if (!options_from_file(_PATH_SYSOPTIONS) || !options_from_user() || !parse_args(argc-1, argv+1)) die(1); check_auth_options(); p = getlogin(); if (p == NULL) p = "(unknown)"; syslog(LOG_NOTICE, "pppd %s patch level %d started by %s, uid %d", VERSION, PATCHLEVEL, p, getuid()); #ifdef SETSID /* * Make sure we can set the serial device to be our controlling terminal. */ if (default_device) { /* * No device name was specified: * we are in the device's session already. */ if ((pgrpid = getpgrp(0)) < 0) { syslog(LOG_ERR, "getpgrp(0): %m"); die(1); } if (pgrpid != pid) syslog(LOG_WARNING, "warning... not a process group leader"); } else { /* * Not default device: make sure we're not a process group leader, * then become session leader of a new session (so we can make * our device its controlling terminal and thus get SIGHUPs). */ if (!nodetach) { /* fork so we're not a process group leader */ if (pid = fork()) { exit(0); /* parent is finished */ } if (pid < 0) { syslog(LOG_ERR, "fork: %m"); die(1); } pid = getpid(); /* otherwise pid is 0 in child */ } else { /* * try to put ourself into our parent's process group, * so we're not a process group leader */ if (setpgrp(pid, getppid()) < 0) syslog(LOG_WARNING, "setpgrp: %m"); } /* create new session */ if ((pgrpid = setsid()) < 0) { syslog(LOG_ERR, "setsid(): %m"); die(1); } } #endif /* Get an internet socket for doing socket ioctl's on. */ if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { syslog(LOG_ERR, "socket : %m"); die(1); } /* * Compute mask of all interesting signals and install signal handlers * for each. Only one signal handler may be active at a time. Therefore, * all other signals should be masked when any handler is executing. */ sigemptyset(&mask); sigaddset(&mask, SIGHUP); sigaddset(&mask, SIGINT); sigaddset(&mask, SIGALRM); sigaddset(&mask, SIGIO); #ifdef STREAMS sigaddset(&mask, SIGPOLL); #endif #define SIGNAL(s, handler) { \ sv.sv_handler = handler; \ if (sigvec(s, &sv, NULL) < 0) { \ syslog(LOG_ERR, "sigvec(%d): %m", s); \ die(1); \ } \ } sv.sv_mask = mask; sv.sv_flags = 0; SIGNAL(SIGHUP, hup); /* Hangup */ SIGNAL(SIGINT, intr); /* Interrupt */ SIGNAL(SIGTERM, term); /* Terminate */ SIGNAL(SIGALRM, alrm); /* Timeout */ SIGNAL(SIGIO, io); /* Input available */ #ifdef STREAMS SIGNAL(SIGPOLL, io); /* Input available */ #endif signal(SIGUSR1, incdebug); /* Increment debug flag */ signal(SIGUSR2, nodebug); /* Reset debug flag */ /* * Open the serial device and set it up to be the ppp interface. */ if ((fd = open(devname, O_RDWR /*| O_NDELAY*/)) < 0) { syslog(LOG_ERR, "open(%s): %m", devname); die(1); } hungup = 0; /* set device to be controlling tty */ if (!default_device && ioctl(fd, TIOCSCTTY) < 0) { syslog(LOG_ERR, "ioctl(TIOCSCTTY): %m"); die(1); } /* set line speed, flow control, etc. */ set_up_tty(fd); /* run connection script */ if (connector) { syslog(LOG_INFO, "Connecting with <%s>", connector); /* drop dtr to hang up in case modem is off hook */ if (!default_device && modem) { setdtr(fd, FALSE); sleep(1); setdtr(fd, TRUE); } if (set_up_connection(connector, fd, fd) < 0) { syslog(LOG_ERR, "could not set up connection"); setdtr(fd, FALSE); die(1); } syslog(LOG_INFO, "Connected..."); sleep(1); /* give it time to set up its terminal */ } /* 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", pidpath, ifname); if ((pidfile = fopen(pidfilename, "w")) != NULL) { fprintf(pidfile, "%d\n", pid); (void) fclose(pidfile); } else { syslog(LOG_ERR, "unable to create pid file: %m"); pidfilename[0] = 0; } /* * Set process group of device to our process group so we can get SIGIOs. */ #ifdef SETSID if (default_device) { int id = tcgetpgrp(fd); if (id != pgrpid) { syslog(LOG_WARNING, "warning: not foreground process group leader"); } } else { if (tcsetpgrp(fd, pgrpid) < 0) { syslog(LOG_ERR, "tcsetpgrp(): %m"); die(1); } } #else /* set process group on tty so we get SIGIO's */ if (ioctl(fd, TIOCSPGRP, &pgrpid) < 0) { syslog(LOG_ERR, "ioctl(TIOCSPGRP): %m"); die(1); } #endif /* * Record initial device flags, then set device to cause SIGIO * signals to be generated. */ if ((initfdflags = fcntl(fd, F_GETFL)) == -1) { syslog(LOG_ERR, "fcntl(F_GETFL): %m"); die(1); } if (fcntl(fd, F_SETFL, FNDELAY | FASYNC) == -1) { syslog(LOG_ERR, "fcntl(F_SETFL, FNDELAY | FASYNC): %m"); die(1); } /* * Block all signals, start opening the connection, and wait for * incoming signals (reply, timeout, etc.). */ syslog(LOG_NOTICE, "Connect: %s <--> %s", ifname, devname); sigprocmask(SIG_BLOCK, &mask, NULL); /* Block signals now */ lcp_lowerup(0); /* XXX Well, sort of... */ lcp_open(0); /* Start protocol */ for (;;) { sigpause(0); /* Wait for next signal */ } } #if B9600 == 9600 /* * XXX assume speed_t values numerically equal bits per second * (so we can ask for any speed). */ #define translate_speed(bps) (bps) #else /* * List of valid speeds. */ struct speed { int speed_int, speed_val; } speeds[] = { #ifdef B50 { 50, B50 }, #endif #ifdef B75 { 75, B75 }, #endif #ifdef B110 { 110, B110 }, #endif #ifdef B134 { 134, B134 }, #endif #ifdef B150 { 150, B150 }, #endif #ifdef B200 { 200, B200 }, #endif #ifdef B300 { 300, B300 }, #endif #ifdef B600 { 600, B600 }, #endif #ifdef B1200 { 1200, B1200 }, #endif #ifdef B1800 { 1800, B1800 }, #endif #ifdef B2000 { 2000, B2000 }, #endif #ifdef B2400 { 2400, B2400 }, #endif #ifdef B3600 { 3600, B3600 }, #endif #ifdef B4800 { 4800, B4800 }, #endif #ifdef B7200 { 7200, B7200 }, #endif #ifdef B9600 { 9600, B9600 }, #endif #ifdef B19200 { 19200, B19200 }, #endif #ifdef B38400 { 38400, B38400 }, #endif #ifdef EXTA { 19200, EXTA }, #endif #ifdef EXTB { 38400, EXTB }, #endif #ifdef B57600 { 57600, B57600 }, #endif #ifdef B115200 { 115200, B115200 }, #endif { 0, 0 } }; /* * Translate from bits/second to a speed_t. */ int translate_speed(bps) int bps; { struct speed *speedp; if (bps == 0) return 0; for (speedp = speeds; speedp->speed_int; speedp++) if (bps == speedp->speed_int) return speedp->speed_val; syslog(LOG_WARNING, "speed %d not supported", bps); return 0; } #endif /* * set_up_tty: Set up the serial port on `fd' for 8 bits, no parity, * at the requested speed, etc. */ set_up_tty(fd) int fd; { #ifndef SGTTY int speed; struct termios tios; if (tcgetattr(fd, &tios) < 0) { syslog(LOG_ERR, "tcgetattr: %m"); die(1); } if (!restore_term) inittermios = tios; tios.c_cflag &= ~(CSIZE | CSTOPB | PARENB | CLOCAL | CRTSCTS); tios.c_cflag |= CS8 | CREAD | HUPCL; if (crtscts) tios.c_cflag |= CRTSCTS; if (!modem) tios.c_cflag |= CLOCAL; tios.c_iflag = IGNBRK | IGNPAR; tios.c_oflag = 0; tios.c_lflag = 0; tios.c_cc[VMIN] = 1; tios.c_cc[VTIME] = 0; speed = translate_speed(inspeed); if (speed) { cfsetospeed(&tios, speed); cfsetispeed(&tios, speed); } if (tcsetattr(fd, TCSAFLUSH, &tios) < 0) { syslog(LOG_ERR, "tcsetattr: %m"); die(1); } #else /* SGTTY */ int speed; struct sgttyb sgttyb; /* * Put the tty in raw mode. */ if (ioctl(fd, TIOCGETP, &sgttyb) < 0) { syslog(LOG_ERR, "ioctl(TIOCGETP): %m"); die(1); } if (!restore_term) initsgttyb = sgttyb; sgttyb.sg_flags = RAW | ANYP; speed = translate_speed(inspeed); if (speed) sgttyb.sg_ispeed = speed; if (ioctl(fd, TIOCSETP, &sgttyb) < 0) { syslog(LOG_ERR, "ioctl(TIOCSETP): %m"); die(1); } #endif restore_term = TRUE; } /* * quit - Clean up state and exit. */ void quit() { die(0); } /* * die - like quit, except we can specify an exit status. */ void die(status) int status; { cleanup(0, NULL); syslog(LOG_INFO, "Exit."); exit(status); } /* * cleanup - restore anything which needs to be restored before we exit */ /* ARGSUSED */ void cleanup(status, arg) int status; caddr_t arg; { if (fd != 0) { /* drop dtr to hang up */ if (modem) setdtr(fd, FALSE); if (fcntl(fd, F_SETFL, initfdflags) < 0) syslog(LOG_ERR, "fcntl(F_SETFL, fdflags): %m"); disestablish_ppp(); if (restore_term) { #ifndef SGTTY if (tcsetattr(fd, TCSAFLUSH, &inittermios) < 0) syslog(LOG_ERR, "tcsetattr: %m"); #else if (ioctl(fd, TIOCSETP, &initsgttyb) < 0) syslog(LOG_ERR, "ioctl(TIOCSETP): %m"); #endif } close(fd); fd = 0; } if (pidfilename[0] != 0 && unlink(pidfilename) < 0) syslog(LOG_WARNING, "unable to unlink pid file: %m"); pidfilename[0] = 0; } static struct callout *callout = NULL; /* Callout list */ static struct timeval schedtime; /* Time last timeout was set */ /* * timeout - Schedule a timeout. * * Note that this timeout takes the number of seconds, NOT hz (as in * the kernel). */ void timeout(func, arg, time) void (*func)(); caddr_t arg; int time; { struct itimerval itv; struct callout *newp, **oldpp; MAINDEBUG((LOG_DEBUG, "Timeout %x:%x in %d seconds.", (int) func, (int) arg, time)); /* * Allocate timeout. */ if ((newp = (struct callout *) malloc(sizeof(struct callout))) == NULL) { syslog(LOG_ERR, "Out of memory in timeout()!"); die(1); } newp->c_arg = arg; newp->c_func = func; /* * Find correct place to link it in and decrement its time by the * amount of time used by preceding timeouts. */ for (oldpp = &callout; *oldpp && (*oldpp)->c_time <= time; oldpp = &(*oldpp)->c_next) time -= (*oldpp)->c_time; newp->c_time = time; newp->c_next = *oldpp; if (*oldpp) (*oldpp)->c_time -= time; *oldpp = newp; /* * If this is now the first callout then we have to set a new * itimer. */ if (callout == newp) { itv.it_interval.tv_sec = itv.it_interval.tv_usec = itv.it_value.tv_usec = 0; itv.it_value.tv_sec = callout->c_time; MAINDEBUG((LOG_DEBUG, "Setting itimer for %d seconds.", itv.it_value.tv_sec)); if (setitimer(ITIMER_REAL, &itv, NULL)) { syslog(LOG_ERR, "setitimer(ITIMER_REAL): %m"); die(1); } if (gettimeofday(&schedtime, NULL)) { syslog(LOG_ERR, "gettimeofday: %m"); die(1); } } } /* * untimeout - Unschedule a timeout. */ void untimeout(func, arg) void (*func)(); caddr_t arg; { struct itimerval itv; struct callout **copp, *freep; int reschedule = 0; MAINDEBUG((LOG_DEBUG, "Untimeout %x:%x.", (int) func, (int) arg)); /* * If the first callout is unscheduled then we have to set a new * itimer. */ if (callout && callout->c_func == func && callout->c_arg == arg) reschedule = 1; /* * Find first matching timeout. Add its time to the next timeouts * time. */ for (copp = &callout; *copp; copp = &(*copp)->c_next) if ((*copp)->c_func == func && (*copp)->c_arg == arg) { freep = *copp; *copp = freep->c_next; if (*copp) (*copp)->c_time += freep->c_time; (void) free((char *) freep); break; } if (reschedule) { itv.it_interval.tv_sec = itv.it_interval.tv_usec = itv.it_value.tv_usec = 0; itv.it_value.tv_sec = callout ? callout->c_time : 0; MAINDEBUG((LOG_DEBUG, "Setting itimer for %d seconds.", itv.it_value.tv_sec)); if (setitimer(ITIMER_REAL, &itv, NULL)) { syslog(LOG_ERR, "setitimer(ITIMER_REAL): %m"); die(1); } if (gettimeofday(&schedtime, NULL)) { syslog(LOG_ERR, "gettimeofday: %m"); die(1); } } } /* * adjtimeout - Decrement the first timeout by the amount of time since * it was scheduled. */ void adjtimeout() { struct timeval tv; int timediff; if (callout == NULL) return; /* * Make sure that the clock hasn't been warped dramatically. * Account for recently expired, but blocked timer by adding * small fudge factor. */ if (gettimeofday(&tv, NULL)) { syslog(LOG_ERR, "gettimeofday: %m"); die(1); } timediff = tv.tv_sec - schedtime.tv_sec; if (timediff < 0 || timediff > callout->c_time + 1) return; callout->c_time -= timediff; /* OK, Adjust time */ } /* * hup - Catch SIGHUP signal. * * Indicates that the physical layer has been disconnected. */ /*ARGSUSED*/ static void hup(sig, code, scp, addr) int sig, code; struct sigcontext *scp; char *addr; { syslog(LOG_INFO, "Hangup (SIGHUP)"); hungup = 1; /* they hung up on us! */ persist = 0; /* don't try to restart */ adjtimeout(); /* Adjust timeouts */ lcp_lowerdown(0); /* Reset connection */ quit(); /* and die */ } /* * term - Catch SIGTERM signal. * * Indicates that we should initiate a graceful disconnect and exit. */ /*ARGSUSED*/ static void term(sig, code, scp, addr) int sig, code; struct sigcontext *scp; char *addr; { syslog(LOG_INFO, "Terminating link."); persist = 0; /* don't try to restart */ adjtimeout(); /* Adjust timeouts */ lcp_close(0); /* Close connection */ } /* * intr - Catch SIGINT signal (DEL/^C). * * Indicates that we should initiate a graceful disconnect and exit. */ /*ARGSUSED*/ static void intr(sig, code, scp, addr) int sig, code; struct sigcontext *scp; char *addr; { syslog(LOG_INFO, "Interrupt received: terminating link"); persist = 0; /* don't try to restart */ adjtimeout(); /* Adjust timeouts */ lcp_close(0); /* Close connection */ } /* * alrm - Catch SIGALRM signal. * * Indicates a timeout. */ /*ARGSUSED*/ static void alrm(sig, code, scp, addr) int sig, code; struct sigcontext *scp; char *addr; { struct itimerval itv; struct callout *freep; MAINDEBUG((LOG_DEBUG, "Alarm")); /* * Call and free first scheduled timeout and any that were scheduled * for the same time. */ while (callout) { freep = callout; /* Remove entry before calling */ callout = freep->c_next; (*freep->c_func)(freep->c_arg); (void) free((char *) freep); if (callout && callout->c_time) break; } /* * Set a new itimer if there are more timeouts scheduled. */ if (callout) { itv.it_interval.tv_sec = itv.it_interval.tv_usec = 0; itv.it_value.tv_usec = 0; itv.it_value.tv_sec = callout->c_time; MAINDEBUG((LOG_DEBUG, "Setting itimer for %d seconds.", itv.it_value.tv_sec)); if (setitimer(ITIMER_REAL, &itv, NULL)) { syslog(LOG_ERR, "setitimer(ITIMER_REAL): %m"); die(1); } if (gettimeofday(&schedtime, NULL)) { syslog(LOG_ERR, "gettimeofday: %m"); die(1); } } } /* * io - Catch SIGIO signal. * * Indicates that incoming data is available. */ /*ARGSUSED*/ static void io(sig, code, scp, addr) int sig, code; struct sigcontext *scp; char *addr; { int len, i; u_char *p; u_short protocol; fd_set fdset; struct timeval notime; int ready; MAINDEBUG((LOG_DEBUG, "IO signal received")); adjtimeout(); /* Adjust timeouts */ /* we do this to see if the SIGIO handler is being invoked for input */ /* ready, or for the socket buffer hitting the low-water mark. */ notime.tv_sec = 0; notime.tv_usec = 0; FD_ZERO(&fdset); FD_SET(fd, &fdset); if ((ready = select(32, &fdset, (fd_set *) NULL, (fd_set *) NULL, ¬ime)) == -1) { syslog(LOG_ERR, "Error in io() select: %m"); die(1); } if (ready == 0) { MAINDEBUG((LOG_DEBUG, "IO non-input ready SIGIO occured.")); return; } /* Yup, this is for real */ for (;;) { /* Read all available packets */ p = inpacket_buf; /* point to beginning of packet buffer */ len = read_packet(inpacket_buf); if (len < 0) return; if (len == 0) { syslog(LOG_ERR, "End of file on fd!"); die(1); } if (len < DLLHEADERLEN) { MAINDEBUG((LOG_INFO, "io(): Received short packet.")); return; } p += 2; /* Skip address and control */ GETSHORT(protocol, p); len -= DLLHEADERLEN; /* * Toss all non-LCP packets unless LCP is OPEN. */ if (protocol != LCP && lcp_fsm[0].state != OPENED) { MAINDEBUG((LOG_INFO, "io(): Received non-LCP packet when LCP not open.")); if (debug) dumpbuffer(inpacket_buf, len + DLLHEADERLEN, LOG_INFO); return; } /* * 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; } if (i == sizeof (prottbl) / sizeof (struct protent)) { syslog(LOG_WARNING, "input: Unknown protocol (%x) received!", protocol); lcp_sprotrej(0, p - DLLHEADERLEN, len + DLLHEADERLEN); } } } /* * demuxprotrej - Demultiplex a Protocol-Reject. */ void demuxprotrej(unit, protocol) int unit; u_short protocol; { int i; /* * Upcall the proper Protocol-Reject routine. */ for (i = 0; i < sizeof (prottbl) / sizeof (struct protent); i++) if (prottbl[i].protocol == protocol) { (*prottbl[i].protrej)(unit); return; } syslog(LOG_WARNING, "demuxprotrej: Unrecognized Protocol-Reject for protocol %d!", protocol); } /* * incdebug - Catch SIGUSR1 signal. * * Increment debug flag. */ /*ARGSUSED*/ static void incdebug(sig) int sig; { syslog(LOG_INFO, "Debug turned ON, Level %d", debug); setlogmask(LOG_UPTO(LOG_DEBUG)); debug++; } /* * nodebug - Catch SIGUSR2 signal. * * Turn off debugging. */ /*ARGSUSED*/ static void nodebug(sig) int sig; { setlogmask(LOG_UPTO(LOG_WARNING)); debug = 0; } /* * set_up_connection - run a program to initialize the serial connector */ int set_up_connection(program, in, out) char *program; int in, out; { int pid; int status; sigset_t mask; sigemptyset(&mask); sigaddset(&mask, SIGINT); sigaddset(&mask, SIGHUP); sigprocmask(SIG_BLOCK, &mask, &mask); pid = fork(); if (pid < 0) { syslog(LOG_ERR, "fork: %m"); die(1); } if (pid == 0) { setreuid(getuid(), getuid()); setregid(getgid(), getgid()); sigprocmask(SIG_SETMASK, &mask, NULL); dup2(in, 0); dup2(out, 1); execl("/bin/sh", "sh", "-c", program, (char *)0); syslog(LOG_ERR, "could not exec /bin/sh: %m"); _exit(99); /* NOTREACHED */ } while (waitpid(pid, &status, 0) != pid) { if (errno == EINTR) continue; syslog(LOG_ERR, "waiting for connection process: %m"); die(1); } sigprocmask(SIG_SETMASK, &mask, NULL); return (status == 0 ? 0 : -1); } /* * Return user specified netmask. A value of zero means no netmask has * been set. */ /* ARGSUSED */ u_long GetMask(addr) u_long addr; { return(netmask); } /* * dumpbuffer - print contents of a buffer in hex to standard output. */ void dumpbuffer(buffer, size, level) unsigned char *buffer; int size; int level; { register int i; char line[256], *p; printf("%d bytes:\n", size); while (size > 0) { p = line; sprintf(p, "%08lx: ", buffer); p += 10; for (i = 0; i < 8; i++, p += 3) if (size - i <= 0) sprintf(p, "xx "); else sprintf(p, "%02x ", buffer[i]); for (i = 0; i < 8; i++) if (size - i <= 0) *p++ = 'x'; else *p++ = (' ' <= buffer[i] && buffer[i] <= '~') ? buffer[i] : '.'; *p++ = 0; buffer += 8; size -= 8; /* syslog(level, "%s\n", line); */ printf("%s\n", line); fflush(stdout); } } /* * setdtr - control the DTR line on the serial port. * This is called from die(), so it shouldn't call die(). */ setdtr(fd, on) int fd, on; { int modembits = TIOCM_DTR; ioctl(fd, (on? TIOCMBIS: TIOCMBIC), &modembits); } #include char line[256]; char *p; logf(level, fmt, va_alist) int level; char *fmt; va_dcl { va_list pvar; char buf[256]; va_start(pvar); vsprintf(buf, fmt, pvar); va_end(pvar); p = line + strlen(line); strcat(p, buf); if (buf[strlen(buf)-1] == '\n') { syslog(level, "%s", line); line[0] = 0; } } void novm(msg) char *msg; { syslog(LOG_ERR, "Virtual memory exhausted allocating %s\n", msg); die(1); }