Logo Search packages:      
Sourcecode: isdnutils version File versions  Download package

main.c

/*
 * main.c - Point-to-Point Protocol main module
 *
 * Fairly patched version for isdn4linux
 * copyright (c) 1995,1996,1997 of all patches by Michael Hipp
 * still no warranties (see disclaimer)
 *
 * 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.
 */

/*
 * PATCHLEVEL 9
 */

char main_rcsid[] = "$Id: main.c,v 1.26 2005/08/01 12:15:15 keil Exp $";

#include <stdio.h>
#include <stdarg.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>
#include <errno.h>
#include <fcntl.h>
#include <syslog.h>
#include <netdb.h>
#include <utmp.h>
#include <pwd.h>
#include <unistd.h>
#include <ctype.h>
#include <time.h>
#include <sys/param.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <time.h>
#include <sys/resource.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include </usr/include/net/if.h>

#include "fsm.h"
#include "ipppd.h"
#include "magic.h"
#include "lcp.h"
#include "ipcp.h"
#include "ipxcp.h"
#include "environ.h"

#include "upap.h"
#include "chap.h"
#include "cbcp.h"
#include "ccp.h"
#include "pathnames.h"
#include "patchlevel.h"
#include "protos.h"

extern int readpassw(char *, int);

/*
 * If REQ_SYSOPTIONS is defined to 1, pppd will not run unless
 * /etc/ppp/ioptions exists.
 */
#ifndef     REQ_SYSOPTIONS
#define REQ_SYSOPTIONS  1
#endif

/* interface vars */

extern void make_options_global(int slot);
char pidfilename[MAXPATHLEN]; /* name of pid file */
char *progname;               /* Name of this program */
char hostname[MAXNAMELEN];    /* Our hostname */
static pid_t      pid;        /* Our pid */

static uid_t uid;       /* Our real user-id */

struct link_struct lns[NUM_PPP];
int numdev = 0;

int kill_link = 0;

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 */

static int n_children;        /* # child processes still running */
int baud_rate;
char *no_ppp_msg = "Sorry - this system lacks PPP kernel support.\n"
      "Check whether you configured at least the ippp0 device!\n";

/* prototypes */
static void hup(int);
static void term(int);
static void chld(int);
static void toggle_debug(int);
static void reload_param(int);
static void bad_signal(int);
static void get_input(int);
static void connect_time_expired(caddr_t);
static int init_unit(int);
static int exit_unit(int);

void remote_sys_options __P((void));
void reload_config(void);

extern      char  *ttyname __P((int));
extern      char  *getlogin __P((void));
extern int daemon(int,int);

#ifdef ultrix
#undef      O_NONBLOCK
#define     O_NONBLOCK  O_NDELAY
#endif

/*
 * PPP Data Link Layer "protocol" table.
 * One entry per supported protocol.
 * The last entry must be NULL.
 */
struct protent *protocols[] = {
    &lcp_protent,
    &pap_protent,
    &chap_protent,
    &cbcp_protent,
    &ipcp_protent,
    &ccp_protent,
    &ccp_link_protent,
    &ipxcp_protent,
    NULL
};

int main(int argc,char **argv)
{
      int             i,j,l;
      struct sigaction sa;
      FILE            *pidfile;
      struct timeval  timo;
      sigset_t        mask;
      struct protent  *protp;
      char            *devnam;
      int             ppp_ok;

      if(argc > 1 && !strcmp(argv[1],"-version")) {
#ifndef RADIUS      
            fprintf(stderr,"ipppd %s.%d (isdn4linux version of pppd by MH) started\n", VERSION, PATCHLEVEL);
#else
            fprintf(stderr,"ipppd %s.%d (isdn4linux version of pppd with RADIUS extension by mla) started\n", VERSION, PATCHLEVEL);
#endif            
            
            fprintf(stderr,"%s\n%s\n%s\n%s\n%s\n",lcp_rcsid,ipcp_rcsid,ipxcp_rcsid,ccp_rcsid,magic_rcsid);
            fprintf(stderr,"%s\n%s\n%s\n%s\n",chap_rcsid,upap_rcsid,main_rcsid,options_rcsid);
            fprintf(stderr,"%s\n%s\n%s\n",fsm_rcsid,cbcp_rcsid,sys_rcsid);
#ifdef USE_MSCHAP
            fprintf(stderr,"%s\n",chap_ms_rcsid);
#endif
            exit(1);
      }

      /*
       * Initialize magic number package.
       */
      magic_init();

      for(i=0;i<NUM_PPP;i++) {
            lns[i].openfails = 0;
            lns[i].initfdflags = -1;
            lns[i].hungup = 1;
            lns[i].bundle_next = &lns[i];
            lns[i].ifname[0] = 0;
            lns[i].ifunit = -1;
            lns[i].phase = PHASE_WAIT;
            lns[i].fd = -1;
            lns[i].logged_in = 0;
            lns[i].lcp_unit = lns[i].ipcp_unit = lns[i].ccp_unit = -1;
            lns[i].cbcp_unit = lns[i].ccp_l_unit = -1;
            lns[i].ipxcp_unit = -1;
            lns[i].unit = i;
            lns[i].chap_unit = lns[i].upap_unit = -1;
            lns[i].auth_up_script = 0;
            lns[i].attempts = 0;
      }

      if (gethostname(hostname, MAXNAMELEN) < 0 ) {
            perror("couldn't get hostname");
            die(1);
      }
      hostname[MAXNAMELEN-1] = 0;

      pidfilename[0] = 0;
      uid = getuid();

    /*
     * Initialize to the standard option set, then parse, in order,
     * the system options file, the user's options file, and the command
     * line arguments.
     */
      progname = *argv;

      for (i = 0; (protp = protocols[i]) != NULL; i++)
            for(j=0;j<NUM_PPP;j++)
                  (*protp->init)(j); /* modifies our options .. !!!! */

#ifdef OPTIONS_TTY_FIRST
      if (!options_from_file(_PATH_SYSOPTIONS, REQ_SYSOPTIONS, 0, 0 ) ||
          !options_for_tty() ||
          !parse_args(argc-1, argv+1))
#else
      if (!options_from_file(_PATH_SYSOPTIONS, REQ_SYSOPTIONS, 0 , 0) ||
                  !parse_args(argc-1, argv+1) || !options_for_tty() )
#endif        
            die(1);

    /*
     * copy protocol options for unit 0 to all option fields
     */
    make_options_global(0);

    /* Check each device to find one that supports PPP */
    /* The first one might not, if it's a slave device... */
    ppp_ok = 0;
    for (i = 0; i < NUM_PPP && lns[i].devnam; i++) {
        if ((devnam = strrchr(lns[i].devnam, '/')))
            devnam++;
        else
            devnam = lns[i].devnam;
        if (ppp_available(devnam)) {
            ppp_ok = 1;
            break;
        }
    }
    if (!ppp_ok) {
        fprintf(stderr, no_ppp_msg);
        exit(1);
    }

    if (ask_passwd) {
      l = readpassw(passwd, MAXSECRETLEN);
      if (l <= 0) {
            fprintf(stderr, "get no password with askpassword\n");
            exit(1);
      }
    } else if (fdpasswd) {
      i=1;   
      l=0;
      while(i>0) {
            j = read(fdpasswd, &i, 1);
            if (j == -1 && (errno == EAGAIN || errno == EINTR))
                  continue;
            if (j!=1)
                  break;
            if (i=='\n')
                  break;
            passwd[l++] = i;
            if (l>=MAXSECRETLEN) {
                  l--;
                  break;
            }
      }
      if (l <= 0) {
            fprintf(stderr, "get no password from fd(%d)\n", fdpasswd);
            exit(1);
      }
      passwd[l] = 0;
    }
    remove_sys_options();
    check_auth_options();
    setipdefault();

    sys_init(); /* init log stuff and open socket for ioctl commands */

    if(!numdev) {
      fprintf(stderr,"ipppd: No devices found.\n");
      die(1);
    }
    else {
      char devstr[1024], *p, *end;
      end = devstr+sizeof(devstr)-1;      /* points to last byte in array */
      /* p points to next empty byte always */
      p = devstr + sprintf(devstr,"Found %d device%s: ",numdev, numdev==1?"":"s");
      for(i=0;i<numdev;i++)
      {
        int len = strlen(lns[i].ifname);
        if (p+len+3 > end) {
          /* not enough space left for interface name plus ... */
          if (p+3 < end) /* enough space for ... */
            strcpy(p, "..."); /* indicate truncation */
          break;
        }
        strcpy(p, lns[i].ifname);
        p += len;
        if (i < numdev - 1) {
          strcpy(p,", ");
          p += 2;
        }
      }
      syslog(LOG_NOTICE,"%s", devstr);
    }

    /*
     * Detach ourselves from the terminal, if required,
     * and identify who is running us.
     */
      if (!nodetach) {
            int a,f;

        f = fork();
        if(f < 0) {
                  perror("Couldn't detach from controlling terminal");
                  exit(1);
            }
            if(f)
                  exit(0);
            setsid();
            chdir("/");
            a = open("/dev/null",O_RDWR);
            if(a < 0) {
                  perror("Couldn't open /dev/null");
                  exit(1);
            }
            dup2(a,0);
            dup2(a,1);
            dup2(a,2);
            close(a);
      }

      pid = getpid();

      /* write pid to file */
      if(!strlen(pidfilename))
#if 0 /* old style, default is to use same pidfile for all devices */
            sprintf(pidfilename, "%s%s.pid", _PATH_VARRUN, "ipppd" );
#else /* new style, incorporate device name into pidfile (like mgetty does) */
      {
            char *p;
            if ((p = strrchr(lns[0].devnam, '/')))
                  p++;
            else
                  p = lns[0].devnam;
            snprintf(pidfilename, sizeof(pidfilename), "%s%s.%s.pid", _PATH_VARRUN, "ipppd", p);
      }
#endif
      
      if ((pidfile = fopen(pidfilename, "w")) != NULL) {
            fprintf(pidfile, "%d\n", pid);
            fclose(pidfile);
      } else {
            syslog(LOG_ERR, "Failed to create pid file %s: %m", pidfilename);
            pidfilename[0] = 0;
      }

      syslog(LOG_NOTICE, "ipppd %s.%d (isdn4linux version of pppd by MH) started", VERSION, PATCHLEVEL);
  
      /*
       * 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, SIGTERM);
      sigaddset(&mask, SIGCHLD);

#define SIGNAL(s, handler)    { \
      sa.sa_handler = handler; \
      if (sigaction(s, &sa, NULL) < 0) { \
          syslog(LOG_ERR, "Couldn't establish signal handler (%d): %m", s); \
          die(1); \
      } \
    }

    sa.sa_mask = mask;
    sa.sa_flags = 0;
    SIGNAL(SIGHUP, hup);            /* Hangup */
    SIGNAL(SIGINT, term);           /* Interrupt */
    SIGNAL(SIGTERM, term);          /* Terminate */
    SIGNAL(SIGCHLD, chld);

    SIGNAL(SIGUSR1, toggle_debug);  /* Toggle debug flag */
    SIGNAL(SIGUSR2, reload_param);        /* reload parameters */

    /*
     * Install a handler for other signals which would otherwise
     * cause pppd to exit without cleaning up.
     */
    SIGNAL(SIGABRT, bad_signal);
    SIGNAL(SIGALRM, bad_signal);
    SIGNAL(SIGFPE, bad_signal);
    SIGNAL(SIGILL, bad_signal);
    SIGNAL(SIGPIPE, bad_signal);
    SIGNAL(SIGQUIT, bad_signal);
    SIGNAL(SIGSEGV, bad_signal);
#ifdef SIGBUS
    SIGNAL(SIGBUS, bad_signal);
#endif
#ifdef SIGEMT
    SIGNAL(SIGEMT, bad_signal);
#endif
#ifdef SIGPOLL
    SIGNAL(SIGPOLL, bad_signal);
#endif
#ifdef SIGPROF
    SIGNAL(SIGPROF, bad_signal);
#endif
#ifdef SIGSYS
    SIGNAL(SIGSYS, bad_signal);
#endif
#ifdef SIGTRAP
    SIGNAL(SIGTRAP, bad_signal);
#endif
#ifdef SIGVTALRM
    SIGNAL(SIGVTALRM, bad_signal);
#endif
#ifdef SIGXCPU
    SIGNAL(SIGXCPU, bad_signal);
#endif
#ifdef SIGXFSZ
    SIGNAL(SIGXFSZ, bad_signal);
#endif

        for(i=0;i<numdev;i++) {
          if(lns[i].fd == -1) {
            syslog(LOG_NOTICE,"init_unit: %d\n",i);
            if(init_unit(i) < 0) {
                        /* Error */
            }
          }
        }

        for(;!kill_link;) {
          fd_set ready;
          int n,i,max=-1;
    
          FD_ZERO(&ready);
          for(i=0;i<numdev;i++)
            if(lns[i].fd >= 0) {
              if(lns[i].fd > max)
                max = lns[i].fd;
              FD_SET(lns[i].fd, &ready);
            }

          n = select(max+1, &ready, NULL, NULL, timeleft(&timo) );
          if (n < 0 && errno != EINTR) {
          syslog(LOG_ERR, "select: %m");
          die(1);
          }

          calltimeout();
          
          for(i=0;i<numdev && n>0;i++) {
            if(lns[i].fd >= 0 && FD_ISSET(lns[i].fd,&ready)) {
            /*  n--; */
              if(lns[i].phase == PHASE_WAIT) {
                /* ok, now we (usually) have a unit */
                lns[i].hungup = 0;
                establish_ppp(i);
                if(maxconnect > 0)
                  timeout(connect_time_expired, (void *)(long)i, maxconnect);
               
                syslog(LOG_NOTICE,"PHASE_WAIT -> PHASE_ESTABLISHED, ifunit: %d, linkunit: %d, fd: %d",lns[i].ifunit,i,lns[i].fd);
                lcp_open(lns[i].lcp_unit);
                lns[i].phase = PHASE_ESTABLISH;
              }
              get_input(i);
            }
          }
        reap_kids();    /* Don't leave dead kids lying around */
          for(i=0;i<numdev;i++)
            if(kill_link || lns[i].phase == PHASE_DEAD) {
                    if(!kill_link)
                syslog(LOG_NOTICE,"taking down PHASE_DEAD link %d, linkunit: %d",i,lns[i].unit);
              untimeout(connect_time_expired,(void *) (long)i);
              lcp_close(lns[i].lcp_unit,"link closed");
              lcp_lowerdown(lns[i].lcp_unit);
              lcp_freeunit(lns[i].lcp_unit);
              if(debug)
                      syslog(LOG_NOTICE,"LCP is down");
              exit_unit(i);
              syslog(LOG_NOTICE,"link %d closed , linkunit: %d",i,lns[i].unit);
              lns[i].phase = PHASE_WAIT;
            }
          if(!kill_link) {
            for(i=0;i<numdev;i++)
              if(lns[i].fd == -1) {
                syslog(LOG_NOTICE,"reinit_unit: %d\n",i);
                if(init_unit(i) < 0) { /* protokolle hier neu initialisieren?? */
                              /* error */
                }
              }
          }
        }


  if (unlink(pidfilename) < 0 && errno != ENOENT) 
    syslog(LOG_WARNING, "unable to delete pid file: %m");
  pidfilename[0] = 0;
  die(0);
  return 0; /*NOTREACHED*/
}

/*
 * initialize unit
 */

static int init_unit(int linkunit)
{
      if ((lns[linkunit].fd = open(lns[linkunit].devnam, O_NONBLOCK | O_RDWR, 0)) < 0) {
            if(errno == ENOENT) {
                  syslog(LOG_ERR, "[%d] Failed to open %s: %m -> Disabling this unit",linkunit,lns[linkunit].devnam);
                  syslog(LOG_NOTICE, "[%d] Failed to open %s: %m -> Disabling this unit",linkunit,lns[linkunit].devnam);
                  lns[linkunit].fd = -2;
            } else {
                  syslog(LOG_ERR, "[%d] Failed to open %s: %m",linkunit,lns[linkunit].devnam);
                  syslog(LOG_NOTICE, "[%d] Failed to open %s: %m",linkunit,lns[linkunit].devnam);
                  lns[linkunit].fd = -1;
            }
/* maybe we should start a timer here to retry the open after a few seconds */

            lns[linkunit].openfails++;
            if(lns[linkunit].openfails >= 16) {
                  syslog(LOG_ERR, "Too much open fails on %s: %m", lns[linkunit].devnam);
                  lns[linkunit].fd = -2;
            }
            return -1;
      }

      if ((lns[linkunit].initfdflags = fcntl(lns[linkunit].fd, F_GETFL)) == -1) {
            syslog(LOG_ERR, "Couldn't get device fd flags: %m");
            lns[linkunit].fd = -2;
            return -1;
      }

      /*
       * Set device for non-blocking reads.
       */
      if (fcntl(lns[linkunit].fd, F_SETFL, lns[linkunit].initfdflags | O_NONBLOCK) == -1) {
            syslog(LOG_ERR, "Couldn't set device to non-blocking mode: %m");
            lns[linkunit].fd = -2;
            return -1;
      }
      syslog(LOG_NOTICE, "Connect[%d]: %s, fd: %d",linkunit, lns[linkunit].devnam,lns[linkunit].fd);

      set_kdebugflag (kdebugflag,linkunit);

      lns[linkunit].openfails = 0;
      lns[linkunit].auth_up_script = 0;
      lns[linkunit].attempts = 0;
      lns[linkunit].hungup = 1;
      lns[linkunit].lcp_unit = lcp_getunit(linkunit);
      /*
       * give the same unit number to chap,upap 
       */
      lns[linkunit].upap_unit = lns[linkunit].chap_unit = lns[linkunit].lcp_unit;
      upap[lns[linkunit].upap_unit].us_unit = chap[lns[linkunit].chap_unit].unit = linkunit;
      lcp_lowerup(lns[linkunit].lcp_unit);
#ifdef IPPP_FILTER
      set_filters(linkunit, &pass_filter, &active_filter);
#endif /* IPPP_FILTER */

      return 0;
}


static int exit_unit(int the_unit)
{
      if (lns[the_unit].initfdflags != -1) { 
            lns[the_unit].initfdflags &= ~O_NONBLOCK;
            if(fcntl(lns[the_unit].fd, F_SETFL, lns[the_unit].initfdflags) < 0)
                  syslog(LOG_ERR,"Failed to set %s back to blocking mode %m",lns[the_unit].devnam);
            lns[the_unit].initfdflags = -1;
      }
      close_fd(the_unit);
      return 0;
}

/*
 * connect_time_expired - log a message and close the connection.
 */
static void connect_time_expired(caddr_t arg)
{
    int linkunit = (int)(long)arg;
    syslog(LOG_INFO, "Connect time expired");
    lcp_close(linkunit, "Connect time expired");       /* Close connection */
}

char *protocol2name(int p)
{
      int top = (sizeof(protonames) / sizeof(struct protos));
      int bottom = 0;
      int pos = top >> 1;
      int step = (pos+1) >> 1;

      while(pos < top && pos >= bottom) {
            if(protonames[pos].val == p)
                  return protonames[pos].name;
            if(protonames[pos].val > p) {
                  top = pos;
                  pos -= step;
                  step = (step+1)>>1;
            }
            else {
                  bottom = pos + 1;
                  pos += step;
                  step = (step+1)>>1;
            }
      }
      return NULL;
}

/*
 * get_input - called when incoming data is available.
 */
static void get_input(int linkunit)
{
    int len, i;
    u_char *p;
    u_short protocol;
      struct protent *protp;

    p = inpacket_buf;   /* point to beginning of packet buffer */

    len = read_packet(inpacket_buf,linkunit);
    if (len < 0)
      return;

    if (len == 0) {
      syslog(LOG_NOTICE, "Modem hangup");
      lns[linkunit].hungup = 1;
#if 0
      lcp_lowerdown(lns[linkunit].lcp_unit);    /* serial link is no longer available */
#endif
      link_terminated(linkunit);
      return;
    }

    if (debug)
        log_packet(p, len, "rcvd ",linkunit);

    if (len < PPP_HDRLEN) {
      MAINDEBUG((LOG_INFO, "io(): Received short packet."));
      return;
    }

    p += 2;                   /* Skip address and control */
    GETSHORT(protocol, p);
    len -= PPP_HDRLEN;

    /*
     * Toss all non-LCP packets unless LCP is OPEN.
     */
    if (protocol != PPP_LCP && lcp_fsm[lns[linkunit].lcp_unit].state != OPENED) {
      MAINDEBUG((LOG_INFO,
               "io(): Received non-LCP packet when LCP not open."));
      return;
    }

    /*
     * Upcall the proper protocol input routine.
     */

      for (i = 0; (protp = protocols[i]) != NULL; ++i) {
            if (protp->protocol == protocol && protp->enabled_flag) {
                  (*protp->input)(linkunit, p, len);
                  return;
            }
        if (protocol == (protp->protocol & ~0x8000) && protp->enabled_flag
                  && protp->datainput != NULL) {
                  (*protp->datainput)(linkunit, p, len);
                  return;
            }
    }

    if (debug) {
            char *s;
            s = protocol2name(protocol);
            if(!s)
                  syslog(LOG_WARNING, "Unknown protocol (0x%x) received", protocol);
            else
                  syslog(LOG_WARNING, "Unsupported protocol '%s' (0x%x) received", s,protocol);
      }
    lcp_sprotrej(linkunit, p - PPP_HDRLEN, len + PPP_HDRLEN);
}


/*
 * demuxprotrej - Demultiplex a Protocol-Reject.
 */
void demuxprotrej(int linkunit,u_short protocol)
{
    int i;
      struct protent *protp;

    /*
     * Upcall the proper Protocol-Reject routine.
     */
      for (i = 0; (protp = protocols[i]) != NULL; ++i) {
            if (protp->protocol == protocol) {
                  (*protp->protrej)(linkunit);
                  return;
            }
      }

    syslog(LOG_WARNING,
         "demuxprotrej: Unrecognized Protocol-Reject for protocol 0x%x",
         protocol);
}


/*
 * bad_signal - We've caught a fatal signal.  Clean up state and exit.
 */
static void bad_signal(int sig) 
{
    syslog(LOG_ERR, "Fatal signal %d", sig);
    die(1);
}

/*
 * die - like quit, except we can specify an exit status.
 */
void die(int status)
{
    int i;
    for(i=0;i<numdev;i++)
      cleanup(0, NULL,i);
    syslog(LOG_INFO, "Exit.");
    exit(status);
}

/*
 * cleanup - restore anything which needs to be restored before we exit
 */
/* ARGSUSED */
void cleanup(int status,caddr_t arg,int tu)
{
    if (lns[tu].fd >= 0)
      close_fd(tu);

    if (pidfilename[0] != 0 && unlink(pidfilename) < 0 && errno != ENOENT) 
      syslog(LOG_WARNING, "unable to delete pid file: %m");
    pidfilename[0] = 0;

#if 0
    if (lockflag)
      unlock();
#endif

}

/*
 * close_fd - restore the terminal device and close it.
 */
void close_fd(int tu)
{
      if (lns[tu].initfdflags != -1 && fcntl(lns[tu].fd, F_SETFL, lns[tu].initfdflags) < 0)
            syslog(LOG_WARNING, "Couldn't restore device fd flags: %m");
      lns[tu].initfdflags = -1;
    syslog(LOG_INFO, "closing fd %d from unit %d",lns[tu].fd,tu);
    close(lns[tu].fd);
    lns[tu].fd = -1;
}


00775 struct      callout {
    struct timeval      c_time;           /* time at which to call routine */
    caddr_t       c_arg;            /* argument to routine */
    void          (*c_func)();      /* routine */
    struct        callout *c_next;
};

static struct callout *callout = NULL;    /* Callout list */
static struct timeval timenow;            /* Current time */

/*
 * timeout - Schedule a timeout.
 *
 * Note that this timeout takes the number of seconds, NOT hz (as in
 * the kernel).
 */
void timeout(void (*func)(),caddr_t arg,int time)
{
    struct callout *newp, *p, **pp;
  
    MAINDEBUG((LOG_DEBUG, "Timeout %lx:%lx in %d seconds.",
             (long) func, (long) 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;
      gettimeofday(&timenow, NULL);
      newp->c_time.tv_sec = timenow.tv_sec + time;
      newp->c_time.tv_usec = timenow.tv_usec;
  
    /*
     * Find correct place and link it in.
     */
      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))
                  break;
      }
      newp->c_next = p;
      *pp = newp;
}


/*
 * untimeout - Unschedule a timeout.
 */
void untimeout(void (*func)(),caddr_t arg)
{
      struct callout **copp, *freep;
  
      MAINDEBUG((LOG_DEBUG, "Untimeout %lx:%lx.", (long) func, (long) arg));
  
      /*
       * Find first matching timeout and remove it from the list.
       */
      for (copp = &callout; (freep = *copp); copp = &freep->c_next)
            if (freep->c_func == func && freep->c_arg == arg) {
                  *copp = freep->c_next;
                  free((char *) freep);
                  break;
            }
}


/*
 * calltimeout - Call any timeout routines which are now due.
 */
void calltimeout()
{
    struct callout *p;

    while (callout != NULL) {
      p = callout;

      if (gettimeofday(&timenow, NULL) < 0) {
          syslog(LOG_ERR, "Failed to get time of day: %m");
          die(1);
      }
      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)))
          break;        /* no, it's not time yet */

      callout = p->c_next;
      (*p->c_func)(p->c_arg);

      free((char *) p);
    }
}


/*
 * timeleft - return the length of time until the next timeout is due.
 */
struct timeval *
timeleft(tvp)
    struct timeval *tvp;
{
    if (callout == NULL)
      return NULL;

    gettimeofday(&timenow, NULL);
    tvp->tv_sec = callout->c_time.tv_sec - timenow.tv_sec;
    tvp->tv_usec = callout->c_time.tv_usec - timenow.tv_usec;
    if (tvp->tv_usec < 0) {
      tvp->tv_usec += 1000000;
      tvp->tv_sec -= 1;
    }
    if (tvp->tv_sec < 0)
      tvp->tv_sec = tvp->tv_usec = 0;

    return tvp;
}
    

/*
 * hup - Catch SIGHUP signal.
 *
 * Indicates that the physical layer has been disconnected.
 * We don't rely on this indication; if the user has sent this
 * signal, we just take the link down.
 */
static void hup(int sig)
{
      syslog(LOG_INFO, "Hangup (SIGHUP)");
/*    kill_link = 1; */
}


/*
 * term - Catch SIGTERM signal and SIGINT signal (^C/del).
 *
 * Indicates that we should initiate a graceful disconnect and exit.
 */
static void term(int sig)
{
      syslog(LOG_INFO, "Terminating on signal %d.", sig);
      kill_link = 1;
}


/*
 * chld - Catch SIGCHLD signal.
 * Calls reap_kids to get status for any dead kids.
 */
static void chld(int sig)
{
      reap_kids();
}

/*
 * toggle_debug - Catch SIGUSR1 signal.
 *
 * Toggle debug flag.
 */
static void toggle_debug(int sig)
{
      debug = !debug;
      note_debug_level();
}


/*
 * reload param - Catch SIGUSR2 signal.
 */
static void reload_param(int sig)
{
      reload_config();
}


/*
 * 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.
 */
int run_program(char *prog,char **args,int must_exist,int unit)
{
      int pid;
      char *nullenv[1];
      char **envtouse;

      pid = fork();
      if (pid < 0) {
            syslog(LOG_ERR, "Failed to create child process for %s: %m", prog);
            return -1;
    }

      if (pid == 0) {
            int i,new_fd;

            setsid();
            umask (S_IRWXG|S_IRWXO);
            chdir ("/");
            /* AUD: full root privs? */
            setuid(geteuid());
            setgid(getegid());

            close (0);
            close (1);
            close (2);
            for(i=0;i<NUM_PPP;i++)
                  if(lns[i].fd >= 0)
                        close(lns[i].fd); 

            new_fd = open (_PATH_DEVNULL, O_RDWR);
            if (new_fd >= 0) {
                  if (new_fd != 0) {
                        dup2  (new_fd, 0); /* stdin <- /dev/null */
                        close (new_fd);
                  }
                  dup2 (0, 1); /* stdout -> /dev/null */
                  dup2 (0, 2); /* stderr -> /dev/null */
            }

            nullenv[0] = NULL;
            if (script_env)
                  envtouse = script_env;
            else
                  envtouse = nullenv;
            execve(prog, args, envtouse);
            if (must_exist || errno != ENOENT)
                  syslog(LOG_WARNING, "Can't execute %s: %m", prog);
            exit(99); /* CHILD exit */
      }
      MAINDEBUG((LOG_DEBUG, "Script %s started; pid = %d", prog, pid));
      ++n_children;

      return 0;
}


/*
 * reap_kids - get status from any dead child processes,
 * and log a message for abnormal terminations.
 */
void reap_kids()
{
      int pid, status;

      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) {
            --n_children;
            if (WIFSIGNALED(status)) {
                  syslog(LOG_WARNING, "Child process %d terminated with signal %d",
                        pid, WTERMSIG(status));
            }
      }
}


/*
 * log_packet - format a packet and log it.
 */

static char line[256];              /* line to be logged accumulated here */
static char *linep;

static void pr_log __P((void *, char *, ...));

void log_packet(u_char *p,int len,char *prefix,int linkunit)
{

    int i, n;
    u_short proto;
    u_char x;
    struct protent *protp;

      strcpy(line, prefix);
      linep = line + strlen(line);

      if (len >= PPP_HDRLEN && p[0] == PPP_ALLSTATIONS && p[1] == PPP_UI) {
            p += 2;
            GETSHORT(proto, p);
            len -= PPP_HDRLEN;
            for (i = 0; (protp = protocols[i]) != NULL; ++i) {
                  if (proto == protp->protocol)
                        break;
            }

        pr_log(NULL,"[%d]",linkunit);
            if (protp) {
                pr_log(NULL, "[%s", protp->name);
                  n = (*protp->printpkt)(p, len, pr_log, NULL);
                  pr_log(NULL, "]");
                  p += n;
                  len -= n;
            } else {
                  pr_log(NULL, "[proto=0x%x]", proto);
            }
      }

      for (; len > 0; --len) {
            GETCHAR(x, p);
            pr_log(NULL, " %.2x", x);
      }

    if (linep != line)
        syslog(LOG_DEBUG, "%s", line);
}


#ifdef __STDC__
#include <stdarg.h>

static void pr_log(void *arg, char *fmt, ...)
{
      int n;
      va_list pvar;
      char buf[256];

      va_start(pvar, fmt);
      vsprintf(buf, fmt, pvar);
      va_end(pvar);

      n = strlen(buf);
      if (linep + n + 1 > line + sizeof(line)) {
            syslog(LOG_DEBUG, "%s", line);
            linep = line;
      }
      strcpy(linep, buf);
      linep += n;
}

#else /* __STDC__ */
#include <varargs.h>

static void pr_log(arg, fmt, va_alist)
void *arg;
char *fmt;
va_dcl
{
    int n;
    va_list pvar;
    char buf[256];

    va_start(pvar);
    vsprintf(buf, fmt, pvar);
    va_end(pvar);

    n = strlen(buf);
    if (linep + n + 1 > line + sizeof(line)) {
      syslog(LOG_DEBUG, "%s", line);
      linep = line;
    }
    strcpy(linep, buf);
    linep += n;
}
#endif

/*
 * print_string - print a readable representation of a string using
 * printer.
 */
void print_string(char *p,int len,void (*printer) __P((void *, char *, ...)),void *arg)
{
    int c;

    printer(arg, "\"");
    for (; len > 0; --len) {
      c = *p++;
      if (' ' <= c && c <= '~')
          printer(arg, "%c", c);
      else
          printer(arg, "\\%.3o", c);
    }
    printer(arg, "\"");
}

/*
 * novm - log an error message saying we ran out of memory, and die.
 */
void novm(char *msg)
{
    syslog(LOG_ERR, "Virtual memory exhausted allocating %s\n", msg);
    die(1);
}

/*
 * fmtmsg - 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.
 * Doesn't do floating-point formats.
 * Returns the number of chars put into buf.
 */
int fmtmsg(char *buf, int buflen, char *fmt, ...)
{
    va_list args;
    int n;

#if __STDC__
    va_start(args, fmt);
#else
    char *buf;
    int buflen;
    char *fmt;
    va_start(args);
    buf = va_arg(args, char *);
    buflen = va_arg(args, int);
    fmt = va_arg(args, char *);
#endif
    n = vfmtmsg(buf, buflen, fmt, args);
    va_end(args);
    return n;
}

/*
 * vfmtmsg - like fmtmsg, takes a va_list instead of a list of args.
 */
#define OUTCHAR(c)  (buflen > 0? (--buflen, *buf++ = (c)): 0)

int vfmtmsg(char *buf,int buflen,char *fmt,va_list args)
{
    int c, i, n;
    int width, prec, fillch;
    int base, len, neg, quoted;
    unsigned long val=0;
    char *str, *f, *buf0;
    unsigned char *p;
    void *a;
    char num[32];
    time_t t;
    static char hexchars[] = "0123456789abcdef";

    buf0 = buf;
    --buflen;
    while (buflen > 0) {
    for (f = fmt; *f != '%' && *f != 0; ++f)
        ;
    if (f > fmt) {
        len = f - fmt;
        if (len > buflen)
        len = buflen;
        memcpy(buf, fmt, len);
        buf += len;
        buflen -= len;
        fmt = f;
    }
    if (*fmt == 0)
        break;
    c = *++fmt;
    width = prec = 0;
    fillch = ' ';
    if (c == '0') {
        fillch = '0';
        c = *++fmt;
    }
    if (c == '*') {
        width = va_arg(args, int);
        c = *++fmt;
    } else {
        while (isdigit(c)) {
        width = width * 10 + c - '0';
        c = *++fmt;
        }
    }
    if (c == '.') {
        c = *++fmt;
        if (c == '*') {
        prec = va_arg(args, int);
        c = *++fmt;
        } else {
        while (isdigit(c)) {
            prec = prec * 10 + c - '0';
            c = *++fmt;
        }
        }
    }
    str = 0;
    base = 0;
    neg = 0;
    ++fmt;
    switch (c) {
    case 'd':
        i = va_arg(args, int);
        if (i < 0) {
        neg = 1;
        val = -i;
        } else
        val = i;
        base = 10;
        break;
    case 'o':
        val = va_arg(args, unsigned int);
        base = 8;
        break;
    case 'x':
        val = va_arg(args, unsigned int);
        base = 16;
        break;
    case 'p':
        val = (unsigned long) va_arg(args, void *);
        base = 16;
        neg = 2;
        break;
    case 's':
        str = va_arg(args, char *);
        break;
    case 'c':
        num[0] = va_arg(args, int);
        num[1] = 0;
        str = num;
        break;
    case 'm':
        str = strerror(errno);
        break;
    case 'I':
        str = ip_ntoa(va_arg(args, u_int32_t));
        break;
    case 'r':
        f = va_arg(args, char *);
        /*
         * XXX We assume a va_list is either a pointer or an array, so
         * what gets passed for a va_list is like a void * in some sense.
         */
        a = va_arg(args, void *);
#ifdef __alpha__       /* always do this? */
      n = fmtmsg(buf, buflen + 1, f, a);
#else
      n = vfmtmsg(buf, buflen + 1, f, a);
#endif
        buf += n;
        buflen -= n;
        continue;
    case 't':
        time(&t);
        str = ctime(&t);
        str += 4;       /* chop off the day name */
        str[15] = 0;    /* chop off year and newline */
        break;
    case 'v':       /* "visible" string */
    case 'q':       /* quoted string */
        quoted = c == 'q';
        p = va_arg(args, unsigned char *);
        if (fillch == '0' && prec > 0) {
        n = prec;
        } else {
        n = strlen((char *)p);
        if (prec > 0 && prec < n)
            n = prec;
        }
        while (n > 0 && buflen > 0) {
        c = *p++;
        --n;
        if (!quoted && c >= 0x80) {
            OUTCHAR('M');
            OUTCHAR('-');
            c -= 0x80;
        }
        if (quoted && (c == '"' || c == '\\'))
            OUTCHAR('\\');
        if ( (c < 0x20 || 0x7f <= c) && c < 0xa0) {
            if (quoted) {
            OUTCHAR('\\');
            switch (c) {
            case '\t':  OUTCHAR('t');   break;
            case '\n':  OUTCHAR('n');   break;
            case '\b':  OUTCHAR('b');   break;
            case '\f':  OUTCHAR('f');   break;
            default:
                OUTCHAR('x');
                OUTCHAR(hexchars[c >> 4]);
                OUTCHAR(hexchars[c & 0xf]);
            }
            } else {
            if (c == '\t')
                OUTCHAR(c);
            else {
                OUTCHAR('^');
                OUTCHAR(c ^ 0x40);
            }
            }
        } else
            OUTCHAR(c);
        }
        continue;
    default:
        *buf++ = '%';
        if (c != '%')
        --fmt;      /* so %z outputs %z etc. */
        --buflen;
        continue;
    }
    if (base != 0) {
        str = num + sizeof(num);
        *--str = 0;
        while (str > num + neg) {
        *--str = hexchars[val % base];
        val = val / base;
        if (--prec <= 0 && val == 0)
            break;
        }
        switch (neg) {
        case 1:
        *--str = '-';
        break;
        case 2:
        *--str = 'x';
        *--str = '0';
        break;
        }
        len = num + sizeof(num) - 1 - str;
    } else {
        len = strlen(str);
        if (prec > 0 && len > prec)
        len = prec;
    }
    if (width > 0) {
        if (width > buflen)
        width = buflen;
        if ((n = width - len) > 0) {
        buflen -= n;
        for (; n > 0; --n)
            *buf++ = fillch;
        }
    }
    if (len > buflen)
        len = buflen;
    memcpy(buf, str, len);
    buf += len;
    buflen -= len;
    }
    *buf = 0;
    return buf - buf0;
}
 
void reload_config(void)
{
  auth_reload_upap_pw();
}


Generated by  Doxygen 1.6.0   Back to index