pppd/sys-osf.c

   1 /*
   2  * System-dependent procedures for pppd under Digital UNIX (OSF/1).
   3  *
   4  * Copyright (c) 1994 The Australian National University.
   5  * All rights reserved.
   6  *
   7  * Permission to use, copy, modify, and distribute this software and its
   8  * documentation is hereby granted, provided that the above copyright
   9  * notice appears in all copies.  This software is provided without any
  10  * warranty, express or implied. The Australian National University
  11  * makes no representations about the suitability of this software for
  12  * any purpose.
  13  *
  14  * IN NO EVENT SHALL THE AUSTRALIAN NATIONAL UNIVERSITY BE LIABLE TO ANY
  15  * PARTY FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES
  16  * ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF
  17  * THE AUSTRALIAN NATIONAL UNIVERSITY HAVE BEEN ADVISED OF THE POSSIBILITY
  18  * OF SUCH DAMAGE.
  19  *
  20  * THE AUSTRALIAN NATIONAL UNIVERSITY SPECIFICALLY DISCLAIMS ANY WARRANTIES,
  21  * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
  22  * AND FITNESS FOR A PARTICULAR PURPOSE.  THE SOFTWARE PROVIDED HEREUNDER IS
  23  * ON AN "AS IS" BASIS, AND THE AUSTRALIAN NATIONAL UNIVERSITY HAS NO
  24  * OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS,
  25  * OR MODIFICATIONS.
  26  */
  27
  28 #ifndef lint
  29 static char rcsid[] = "$Id: sys-osf.c,v 1.20 1999/03/16 22:53:48 paulus Exp $";
  30 #endif
  31
  32 #include <stdio.h>
  33 #include <stddef.h>
  34 #include <stdlib.h>
  35 #include <string.h>
  36 #include <ctype.h>
  37 #include <errno.h>
  38 #include <fcntl.h>
  39 #include <unistd.h>
  40 #include <termios.h>
  41 #include <signal.h>
  42 #include <malloc.h>
  43 #include <utmp.h>
  44 #include <sys/types.h>
  45 #include <sys/param.h>
  46 #include <sys/socket.h>
  47 #include <sys/stream.h>
  48 #include <sys/stropts.h>
  49 #include <sys/stat.h>
  50 #include <sys/time.h>
  51 #include <sys/poll.h>
  52 #include <sys/ioctl.h>
  53 #include <net/if.h>
  54 #include <net/if_dl.h>
  55 #include <net/if_arp.h>
  56 #include <net/route.h>
  57 #include <net/ppp_defs.h>
  58 #include <net/pppio.h>
  59 #include <netinet/in.h>
  60 #include <arpa/inet.h>
  61
  62 #include "pppd.h"
  63
  64 static int      pppfd;
  65 static int      fdmuxid = -1;
  66 static int      iffd;
  67 static int      sockfd;
  68
  69 static int      restore_term;
  70 static struct termios inittermios;
  71 static struct winsize wsinfo;   /* Initial window size info */
  72 static pid_t    tty_sid;        /* PID of our session leader */
  73
  74 extern u_char   inpacket_buf[]; /* borrowed from main.c */
  75
  76 static int      link_mtu, link_mru;
  77
  78 #define NMODULES        32
  79 static int      tty_nmodules;
  80 static char     tty_modules[NMODULES][FMNAMESZ+1];
  81
  82 static int closed_stdio;
  83 static int initfdflags = -1;
  84 static int orig_ttyfd = -1;
  85
  86 static int      if_is_up;       /* Interface has been marked up */
  87 static u_int32_t ifaddrs[2];    /* local and remote addresses */
  88 static u_int32_t default_route_gateway; /* Gateway for default route added */
  89 static u_int32_t proxy_arp_addr;        /* Addr for proxy arp entry added */
  90
  91 #define MAX_POLLFDS     32
  92 static struct pollfd pollfds[MAX_POLLFDS];
  93 static int n_pollfds;
  94
  95 /* Prototypes for procedures local to this file. */
  96 static int translate_speed __P((int));
  97 static int baud_rate_of __P((int));
  98 static int get_ether_addr __P((u_int32_t, struct sockaddr *));
  99 static int strioctl __P((int, int, void *, int, int));
 100
 101
 102 /*
 103  * sys_init - System-dependent initialization.
 104  */
 105 void
 106 sys_init()
 107 {
 108     int x;
 109
 110     openlog("pppd", LOG_PID | LOG_NDELAY, LOG_PPP);
 111     setlogmask(LOG_UPTO(LOG_INFO));
 112     if (debug)
 113         setlogmask(LOG_UPTO(LOG_DEBUG));
 114
 115     /* Get an internet socket for doing socket ioctl's on. */
 116     if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
 117         fatal("Couldn't create IP socket: %m");
 118
 119     if (default_device)
 120         tty_sid = getsid((pid_t)0);
 121
 122     /*
 123      * Open the ppp device.
 124      */
 125     pppfd = open("/dev/streams/ppp", O_RDWR | O_NONBLOCK, 0);
 126     if (pppfd < 0)
 127         fatal("Can't open /dev/streams/ppp: %m");
 128     if (kdebugflag) {
 129         x = PPPDBG_LOG + PPPDBG_DRIVER;
 130         strioctl(pppfd, PPPIO_DEBUG, &x, sizeof(int), 0);
 131     }
 132
 133     /* Assign a new PPA and get its unit number. */
 134     if (strioctl(pppfd, PPPIO_NEWPPA, &ifunit, 0, sizeof(int)) < 0)
 135         fatal("Can't create new PPP interface: %m");
 136
 137     /*
 138      * Open the ppp device again and push the if_ppp module on it.
 139      */
 140     iffd = open("/dev/streams/ppp", O_RDWR, 0);
 141     if (iffd < 0)
 142         fatal("Can't open /dev/streams/ppp (2): %m");
 143     if (kdebugflag) {
 144         x = PPPDBG_LOG + PPPDBG_DRIVER;
 145         strioctl(iffd, PPPIO_DEBUG, &x, sizeof(int), 0);
 146     }
 147     if (strioctl(iffd, PPPIO_ATTACH, &ifunit, sizeof(int), 0) < 0)
 148         fatal("Couldn't attach ppp interface to device: %m");
 149     if (ioctl(iffd, I_PUSH, "if_ppp") < 0)
 150         fatal("Can't push ppp interface module: %m");
 151     if (kdebugflag) {
 152         x = PPPDBG_LOG + PPPDBG_IF;
 153         strioctl(iffd, PPPIO_DEBUG, &x, sizeof(int), 0);
 154     }
 155     if (strioctl(iffd, PPPIO_NEWPPA, &ifunit, sizeof(int), 0) < 0)
 156         fatal("Couldn't create ppp interface unit: %m");
 157     x = PPP_IP;
 158     if (strioctl(iffd, PPPIO_BIND, &x, sizeof(int), 0) < 0)
 159         fatal("Couldn't bind ppp interface to IP SAP: %m");
 160
 161     n_pollfds = 0;
 162 }
 163
 164 /*
 165  * sys_cleanup - restore any system state we modified before exiting:
 166  * mark the interface down, delete default route and/or proxy arp entry.
 167  * This shouldn't call die() because it's called from die().
 168  */
 169 void
 170 sys_cleanup()
 171 {
 172     if (if_is_up)
 173         sifdown(0);
 174     if (ifaddrs[0])
 175         cifaddr(0, ifaddrs[0], ifaddrs[1]);
 176     if (default_route_gateway)
 177         cifdefaultroute(0, 0, default_route_gateway);
 178     if (proxy_arp_addr)
 179         cifproxyarp(0, proxy_arp_addr);
 180 }
 181
 182 /*
 183  * sys_close - Clean up in a child process before execing.
 184  */
 185 void
 186 sys_close()
 187 {
 188     close(iffd);
 189     close(pppfd);
 190     close(sockfd);
 191     closelog();
 192 }
 193
 194 /*
 195  * sys_check_options - check the options that the user specified
 196  */
 197 int
 198 sys_check_options()
 199 {
 200     return 1;
 201 }
 202
 203
 204 /*
 205  * daemon - Detach us from controlling terminal session.
 206  */
 207 int
 208 daemon(nochdir, noclose)
 209     int nochdir, noclose;
 210 {
 211     int pid;
 212
 213     if ((pid = fork()) < 0)
 214         return -1;
 215     if (pid != 0)
 216         exit(0);                /* parent dies */
 217     setsid();
 218     if (!nochdir)
 219         chdir("/");
 220     if (!noclose) {
 221         fclose(stdin);          /* don't need stdin, stdout, stderr */
 222         fclose(stdout);
 223         fclose(stderr);
 224     }
 225     return 0;
 226 }
 227
 228 /*
 229  * note_debug_level - note a change in the debug level.
 230  */
 231 void
 232 note_debug_level()
 233 {
 234     if (debug) {
 235         setlogmask(LOG_UPTO(LOG_DEBUG));
 236     } else {
 237         setlogmask(LOG_UPTO(LOG_WARNING));
 238     }
 239 }
 240
 241 /*
 242  * ppp_available - check whether the system has any ppp interfaces
 243  */
 244 int
 245 ppp_available()
 246 {
 247     struct stat buf;
 248
 249     return stat("/dev/streams/ppp", &buf) >= 0;
 250 }
 251
 252 char pipename[] = "/dev/streams/pipe";
 253
 254 /*
 255  *  streampipe -- Opens a STREAMS based pipe.  Used by streamify().
 256  */
 257
 258 int
 259 streampipe(int fd[2])
 260 {
 261     if ((fd[0]=open(pipename, O_RDWR)) == -1)
 262         return(-1);
 263     else if ((fd[1]=open(pipename, O_RDWR)) == -1) {
 264         close(fd[0]);
 265         return(-1);
 266     } else if (ioctl(fd[0], I_PIPE, fd[1]) != 0) {
 267         close(fd[0]);
 268         close(fd[1]);
 269         return(-1);
 270     } else {
 271         return(ioctl(fd[0], I_PUSH, "pipemod"));
 272     }
 273 }
 274
 275 /*
 276  *  streamify -- Needed for Digital UNIX, since some tty devices are not STREAMS
 277  *               modules (but ptys are, and pipes can be).
 278  */
 279
 280 #define BUFFSIZE 1000     /*  Size of buffer for streamify()  */
 281
 282 int
 283 streamify(int fd)
 284 {
 285     int fdes[2];
 286     fd_set readfds;
 287     int ret, fret, rret, maxfd;
 288     static char buffer[BUFFSIZE];
 289     struct sigaction sa;
 290
 291     if (streampipe(fdes) != 0)
 292         error("streampipe(): %m\n");
 293     else if (isastream(fdes[0]) == 1) {
 294         if ((fret=fork()) < 0) {
 295             error("fork(): %m\n");
 296         } else if (fret == 0) {
 297             /*  Process to forward things from pipe to tty  */
 298             sigemptyset(&(sa.sa_mask));
 299             sa.sa_handler = SIG_DFL;
 300             sa.sa_flags = 0;
 301             sigaction(SIGHUP, &sa, NULL);   /*  Go back to default actions */
 302             sigaction(SIGINT, &sa, NULL);   /*  for changed signals.  */
 303             sigaction(SIGTERM, &sa, NULL);
 304             sigaction(SIGCHLD, &sa, NULL);
 305             sigaction(SIGUSR1, &sa, NULL);
 306             sigaction(SIGUSR2, &sa, NULL);
 307             close(fdes[0]);
 308
 309             maxfd = (fdes[1]>fd)?fdes[1]:fd;
 310             while (1) {
 311                 FD_ZERO(&readfds);
 312                 FD_SET(fdes[1], &readfds);
 313                 FD_SET(fd, &readfds);
 314                 ret = select(maxfd+1, &readfds, NULL, NULL, NULL);
 315                 if (FD_ISSET(fd, &readfds)) {
 316                     rret = read(fd, buffer, BUFFSIZE);
 317                     if (rret == 0) {
 318                         SYSDEBUG(("slave died:  EOF on tty."));
 319                         exit(0);
 320                     } else {
 321                         write(fdes[1], buffer, rret);
 322                     }
 323                 }
 324                 if (FD_ISSET(fdes[1], &readfds)) {
 325                     rret = read(fdes[1], buffer, BUFFSIZE);
 326                     if (rret == 0) {
 327                         SYSDEBUG(("slave died:  EOF on pipe."));
 328                         exit(0);
 329                     } else {
 330                         write(fd, buffer, rret);
 331                     }
 332                 }
 333             }
 334         } else {
 335             close(fdes[1]);
 336             orig_ttyfd = fd;
 337             return(fdes[0]);
 338         }
 339     }
 340
 341     return(-1);
 342 }
 343
 344 /*
 345  * establish_ppp - Turn the serial port into a ppp interface.
 346  */
 347 int
 348 establish_ppp(fd)
 349     int fd;
 350 {
 351     int i;
 352
 353     if (isastream(fd) != 1) {
 354         if ((ttyfd = fd = streamify(fd)) < 0)
 355             fatal("Couldn't get a STREAMS module!\n");
 356     }
 357
 358     /* Pop any existing modules off the tty stream. */
 359     for (i = 0;; ++i) {
 360         if (ioctl(fd, I_LOOK, tty_modules[i]) < 0
 361             || ioctl(fd, I_POP, 0) < 0)
 362             break;
 363         error("popping module %s\n", tty_modules[i]);
 364     }
 365
 366     tty_nmodules = i;
 367
 368     /* Push the async hdlc module and the compressor module. */
 369     if (ioctl(fd, I_PUSH, "ppp_ahdl") < 0)
 370         fatal("Couldn't push PPP Async HDLC module: %m");
 371     if (ioctl(fd, I_PUSH, "ppp_comp") < 0)
 372         error("Couldn't push PPP compression module: %m");
 373
 374     /* read mode, message non-discard mode */
 375     if (ioctl(fd, I_SRDOPT, RMSGN|RPROTNORM) < 0)
 376         fatal("ioctl(I_SRDOPT, RMSGN): %m");
 377
 378     /* Link the serial port under the PPP multiplexor. */
 379     if ((fdmuxid = ioctl(pppfd, I_LINK, fd)) < 0)
 380         fatal("Can't link tty to PPP mux: %m");
 381
 382     /* close stdin, stdout, stderr if they might refer to the device */
 383     if (default_device && !closed_stdio) {
 384         int i;
 385
 386         for (i = 0; i <= 2; ++i)
 387             if (i != fd && i != sockfd)
 388                 close(i);
 389         closed_stdio = 1;
 390     }
 391
 392     /*
 393      * Set device for non-blocking reads.
 394      * XXX why do we need to do this?  don't we use pppfd not fd?
 395      */
 396     if ((initfdflags = fcntl(fd, F_GETFL)) == -1
 397         || fcntl(fd, F_SETFL, initfdflags | O_NONBLOCK) == -1) {
 398         warn("Couldn't set device to non-blocking mode: %m");
 399     }
 400
 401     return pppfd;
 402 }
 403
 404 /*
 405  * restore_loop - reattach the ppp unit to the loopback.
 406  * This doesn't need to do anything because disestablish_ppp does it.
 407  */
 408 void
 409 restore_loop()
 410 {
 411 }
 412
 413 /*
 414  * disestablish_ppp - Restore the serial port to normal operation.
 415  * It attempts to reconstruct the stream with the previously popped
 416  * modules.  This shouldn't call die() because it's called from die().
 417  */
 418 void
 419 disestablish_ppp(fd)
 420     int fd;
 421 {
 422     int i;
 423
 424     if (fdmuxid >= 0) {
 425         if (ioctl(pppfd, I_UNLINK, fdmuxid) < 0) {
 426             if (!hungup)
 427                 error("Can't unlink tty from PPP mux: %m");
 428         }
 429         fdmuxid = -1;
 430
 431         /* Reset non-blocking mode on the file descriptor. */
 432         if (initfdflags != -1 && fcntl(fd, F_SETFL, initfdflags) < 0)
 433             warn("Couldn't restore device fd flags: %m");
 434         initfdflags = -1;
 435
 436         if (!hungup) {
 437             while (ioctl(fd, I_POP, 0) >= 0)
 438                 ;
 439             for (i = tty_nmodules - 1; i >= 0; --i)
 440                 if (ioctl(fd, I_PUSH, tty_modules[i]) < 0)
 441                     error("Couldn't restore tty module %s: %m",
 442                            tty_modules[i]);
 443         }
 444
 445         if (hungup && default_device && tty_sid > 0) {
 446             /*
 447              * If we have received a hangup, we need to send a SIGHUP
 448              * to the terminal's controlling process.  The reason is
 449              * that the original stream head for the terminal hasn't
 450              * seen the M_HANGUP message (it went up through the ppp
 451              * driver to the stream head for our fd to /dev/ppp).
 452              */
 453             dbglog("sending hangup to %d", tty_sid);
 454             if (kill(tty_sid, SIGHUP) < 0)
 455                 error("couldn't kill pgrp: %m");
 456         }
 457         if (orig_ttyfd >= 0) {
 458             close(fd);
 459             (void)wait((void *)0);
 460             ttyfd = orig_ttyfd;
 461             orig_ttyfd = -1;
 462         }
 463     }
 464 }
 465
 466 /*
 467  * Check whether the link seems not to be 8-bit clean.
 468  */
 469 void
 470 clean_check()
 471 {
 472     int x;
 473     char *s;
 474
 475     if (strioctl(pppfd, PPPIO_GCLEAN, &x, 0, sizeof(x)) < 0)
 476         return;
 477     s = NULL;
 478     switch (~x) {
 479     case RCV_B7_0:
 480         s = "bit 7 set to 1";
 481         break;
 482     case RCV_B7_1:
 483         s = "bit 7 set to 0";
 484         break;
 485     case RCV_EVNP:
 486         s = "odd parity";
 487         break;
 488     case RCV_ODDP:
 489         s = "even parity";
 490         break;
 491     }
 492     if (s != NULL) {
 493         warn("Serial link is not 8-bit clean:");
 494         warn("All received characters had %s", s);
 495     }
 496 }
 497
 498 /*
 499  * List of valid speeds.
 500  */
 501 struct speed {
 502     int speed_int, speed_val;
 503 } speeds[] = {
 504 #ifdef B50
 505     { 50, B50 },
 506 #endif
 507 #ifdef B75
 508     { 75, B75 },
 509 #endif
 510 #ifdef B110
 511     { 110, B110 },
 512 #endif
 513 #ifdef B134
 514     { 134, B134 },
 515 #endif
 516 #ifdef B150
 517     { 150, B150 },
 518 #endif
 519 #ifdef B200
 520     { 200, B200 },
 521 #endif
 522 #ifdef B300
 523     { 300, B300 },
 524 #endif
 525 #ifdef B600
 526     { 600, B600 },
 527 #endif
 528 #ifdef B1200
 529     { 1200, B1200 },
 530 #endif
 531 #ifdef B1800
 532     { 1800, B1800 },
 533 #endif
 534 #ifdef B2000
 535     { 2000, B2000 },
 536 #endif
 537 #ifdef B2400
 538     { 2400, B2400 },
 539 #endif
 540 #ifdef B3600
 541     { 3600, B3600 },
 542 #endif
 543 #ifdef B4800
 544     { 4800, B4800 },
 545 #endif
 546 #ifdef B7200
 547     { 7200, B7200 },
 548 #endif
 549 #ifdef B9600
 550     { 9600, B9600 },
 551 #endif
 552 #ifdef B19200
 553     { 19200, B19200 },
 554 #endif
 555 #ifdef B38400
 556     { 38400, B38400 },
 557 #endif
 558 #ifdef EXTA
 559     { 19200, EXTA },
 560 #endif
 561 #ifdef EXTB
 562     { 38400, EXTB },
 563 #endif
 564 #ifdef B57600
 565     { 57600, B57600 },
 566 #endif
 567 #ifdef B115200
 568     { 115200, B115200 },
 569 #endif
 570     { 0, 0 }
 571 };
 572
 573 /*
 574  * Translate from bits/second to a speed_t.
 575  */
 576 static int
 577 translate_speed(bps)
 578     int bps;
 579 {
 580     struct speed *speedp;
 581
 582     if (bps == 0)
 583         return 0;
 584     for (speedp = speeds; speedp->speed_int; speedp++)
 585         if (bps == speedp->speed_int)
 586             return speedp->speed_val;
 587     warn("speed %d not supported", bps);
 588     return 0;
 589 }
 590
 591 /*
 592  * Translate from a speed_t to bits/second.
 593  */
 594 static int
 595 baud_rate_of(speed)
 596     int speed;
 597 {
 598     struct speed *speedp;
 599
 600     if (speed == 0)
 601         return 0;
 602     for (speedp = speeds; speedp->speed_int; speedp++)
 603         if (speed == speedp->speed_val)
 604             return speedp->speed_int;
 605     return 0;
 606 }
 607
 608 /*
 609  * set_up_tty: Set up the serial port on `fd' for 8 bits, no parity,
 610  * at the requested speed, etc.  If `local' is true, set CLOCAL
 611  * regardless of whether the modem option was specified.
 612  */
 613 void
 614 set_up_tty(fd, local)
 615     int fd, local;
 616 {
 617     int speed;
 618     struct termios tios;
 619
 620     if (tcgetattr(fd, &tios) < 0)
 621         fatal("tcgetattr: %m");
 622
 623     if (!restore_term) {
 624         inittermios = tios;
 625         ioctl(fd, TIOCGWINSZ, &wsinfo);
 626     }
 627
 628     tios.c_cflag &= ~(CSIZE | CSTOPB | PARENB | CLOCAL);
 629     if (crtscts > 0)
 630         tios.c_cflag |= CRTSCTS;
 631     else if (crtscts < 0)
 632         tios.c_cflag &= ~CRTSCTS;
 633
 634     tios.c_cflag |= CS8 | CREAD | HUPCL;
 635     if (local || !modem)
 636         tios.c_cflag |= CLOCAL;
 637     tios.c_iflag = IGNBRK | IGNPAR;
 638     tios.c_oflag = 0;
 639     tios.c_lflag = 0;
 640     tios.c_cc[VMIN] = 1;
 641     tios.c_cc[VTIME] = 0;
 642
 643     if (crtscts == -2) {
 644         tios.c_iflag |= IXON | IXOFF;
 645         tios.c_cc[VSTOP] = 0x13;        /* DC3 = XOFF = ^S */
 646         tios.c_cc[VSTART] = 0x11;       /* DC1 = XON  = ^Q */
 647     }
 648
 649     speed = translate_speed(inspeed);
 650     if (speed) {
 651         cfsetospeed(&tios, speed);
 652         cfsetispeed(&tios, speed);
 653     } else {
 654         speed = cfgetospeed(&tios);
 655         /*
 656          * We can't proceed if the serial port speed is 0,
 657          * since that implies that the serial port is disabled.
 658          */
 659         if (speed == B0)
 660             fatal("Baud rate for %s is 0; need explicit baud rate", devnam);
 661     }
 662
 663     if (tcsetattr(fd, TCSAFLUSH, &tios) < 0)
 664         fatal("tcsetattr: %m");
 665
 666     baud_rate = inspeed = baud_rate_of(speed);
 667     restore_term = 1;
 668 }
 669
 670 /*
 671  * restore_tty - restore the terminal to the saved settings.
 672  */
 673 void
 674 restore_tty(fd)
 675     int fd;
 676 {
 677     if (restore_term) {
 678         if (!default_device) {
 679             /*
 680              * Turn off echoing, because otherwise we can get into
 681              * a loop with the tty and the modem echoing to each other.
 682              * We presume we are the sole user of this tty device, so
 683              * when we close it, it will revert to its defaults anyway.
 684              */
 685             inittermios.c_lflag &= ~(ECHO | ECHONL);
 686         }
 687         if (tcsetattr(fd, TCSAFLUSH, &inittermios) < 0)
 688             if (!hungup && errno != ENXIO)
 689                 warn("tcsetattr: %m");
 690         ioctl(fd, TIOCSWINSZ, &wsinfo);
 691         restore_term = 0;
 692     }
 693 }
 694
 695 /*
 696  * setdtr - control the DTR line on the serial port.
 697  * This is called from die(), so it shouldn't call die().
 698  */
 699 void
 700 setdtr(fd, on)
 701 int fd, on;
 702 {
 703     int modembits = TIOCM_DTR;
 704
 705     ioctl(fd, (on? TIOCMBIS: TIOCMBIC), &modembits);
 706 }
 707
 708 /*
 709  * open_loopback - open the device we use for getting packets
 710  * in demand mode.  Under Digital Unix, we use our existing fd
 711  * to the ppp driver.
 712  */
 713 int
 714 open_ppp_loopback()
 715 {
 716     return pppfd;
 717 }
 718
 719 /*
 720  * output - Output PPP packet.
 721  */
 722 void
 723 output(unit, p, len)
 724     int unit;
 725     u_char *p;
 726     int len;
 727 {
 728     struct strbuf data;
 729     int retries;
 730     struct pollfd pfd;
 731
 732     if (debug)
 733         dbglog("sent %P", p, len);
 734
 735     data.len = len;
 736     data.buf = (caddr_t) p;
 737     retries = 4;
 738     while (putmsg(pppfd, NULL, &data, 0) < 0) {
 739         if (--retries < 0 || (errno != EWOULDBLOCK && errno != EAGAIN)) {
 740             if (errno != ENXIO)
 741                 error("Couldn't send packet: %m");
 742             break;
 743         }
 744         pfd.fd = pppfd;
 745         pfd.events = POLLOUT;
 746         poll(&pfd, 1, 250);     /* wait for up to 0.25 seconds */
 747     }
 748 }
 749
 750
 751 /*
 752  * wait_input - wait until there is data available on fd,
 753  * for the length of time specified by *timo (indefinite
 754  * if timo is NULL).
 755  */
 756 void
 757 wait_input(timo)
 758     struct timeval *timo;
 759 {
 760     int t;
 761
 762     t = timo == NULL? -1: timo->tv_sec * 1000 + timo->tv_usec / 1000;
 763     if (poll(pollfds, n_pollfds, t) < 0 && errno != EINTR)
 764         fatal("poll: %m");
 765 }
 766
 767 /*
 768  * add_fd - add an fd to the set that wait_input waits for.
 769  */
 770 void add_fd(int fd)
 771 {
 772     int n;
 773
 774     for (n = 0; n < n_pollfds; ++n)
 775         if (pollfds[n].fd == fd)
 776             return;
 777     if (n_pollfds < MAX_POLLFDS) {
 778         pollfds[n_pollfds].fd = fd;
 779         pollfds[n_pollfds].events = POLLIN | POLLPRI | POLLHUP;
 780         ++n_pollfds;
 781     } else
 782         error("Too many inputs!");
 783 }
 784
 785 /*
 786  * remove_fd - remove an fd from the set that wait_input waits for.
 787  */
 788 void remove_fd(int fd)
 789 {
 790     int n;
 791
 792     for (n = 0; n < n_pollfds; ++n) {
 793         if (pollfds[n].fd == fd) {
 794             while (++n < n_pollfds)
 795                 pollfds[n-1] = pollfds[n];
 796             --n_pollfds;
 797             break;
 798         }
 799     }
 800 }
 801
 802 #if 0
 803 /*
 804  * wait_loop_output - wait until there is data available on the
 805  * loopback, for the length of time specified by *timo (indefinite
 806  * if timo is NULL).
 807  */
 808 void
 809 wait_loop_output(timo)
 810     struct timeval *timo;
 811 {
 812     wait_input(timo);
 813 }
 814
 815 /*
 816  * wait_time - wait for a given length of time or until a
 817  * signal is received.
 818  */
 819 void
 820 wait_time(timo)
 821     struct timeval *timo;
 822 {
 823     int n;
 824
 825     n = select(0, NULL, NULL, NULL, timo);
 826     if (n < 0 && errno != EINTR)
 827         fatal("select: %m");
 828 }
 829 #endif
 830
 831 /*
 832  * read_packet - get a PPP packet from the serial device.
 833  */
 834 int
 835 read_packet(buf)
 836     u_char *buf;
 837 {
 838     struct strbuf ctrl, data;
 839     int flags, len;
 840     unsigned char ctrlbuf[64];
 841
 842     for (;;) {
 843         data.maxlen = PPP_MRU + PPP_HDRLEN;
 844         data.buf = (caddr_t) buf;
 845         ctrl.maxlen = sizeof(ctrlbuf);
 846         ctrl.buf = (caddr_t) ctrlbuf;
 847         flags = 0;
 848         len = getmsg(pppfd, &ctrl, &data, &flags);
 849         if (len < 0) {
 850             if (errno = EAGAIN || errno == EWOULDBLOCK || errno == EINTR)
 851                 return -1;
 852             fatal("Error reading packet: %m");
 853         }
 854
 855         if (ctrl.len <= 0)
 856             return data.len;
 857
 858         /*
 859          * Got a M_PROTO or M_PCPROTO message.  Huh?
 860          */
 861         if (debug)
 862             dbglog("got ctrl msg len=%d", ctrl.len);
 863
 864     }
 865 }
 866
 867 /*
 868  * get_loop_output - get outgoing packets from the ppp device,
 869  * and detect when we want to bring the real link up.
 870  * Return value is 1 if we need to bring up the link, 0 otherwise.
 871  */
 872 int
 873 get_loop_output()
 874 {
 875     int len;
 876     int rv = 0;
 877
 878     while ((len = read_packet(inpacket_buf)) > 0) {
 879         if (loop_frame(inpacket_buf, len))
 880             rv = 1;
 881     }
 882     return rv;
 883 }
 884
 885 /*
 886  * ppp_send_config - configure the transmit characteristics of
 887  * the ppp interface.
 888  */
 889 void
 890 ppp_send_config(unit, mtu, asyncmap, pcomp, accomp)
 891     int unit, mtu;
 892     u_int32_t asyncmap;
 893     int pcomp, accomp;
 894 {
 895     int cf[2];
 896
 897     link_mtu = mtu;
 898     if (strioctl(pppfd, PPPIO_MTU, &mtu, sizeof(mtu), 0) < 0) {
 899         if (hungup && errno == ENXIO)
 900             return;
 901         error("Couldn't set MTU: %m");
 902     }
 903     if (strioctl(pppfd, PPPIO_XACCM, &asyncmap, sizeof(asyncmap), 0) < 0) {
 904         error("Couldn't set transmit ACCM: %m");
 905     }
 906     cf[0] = (pcomp? COMP_PROT: 0) + (accomp? COMP_AC: 0);
 907     cf[1] = COMP_PROT | COMP_AC;
 908     if (strioctl(pppfd, PPPIO_CFLAGS, cf, sizeof(cf), sizeof(int)) < 0) {
 909         error("Couldn't set prot/AC compression: %m");
 910     }
 911 }
 912
 913 /*
 914  * ppp_set_xaccm - set the extended transmit ACCM for the interface.
 915  */
 916 void
 917 ppp_set_xaccm(unit, accm)
 918     int unit;
 919     ext_accm accm;
 920 {
 921     if (strioctl(pppfd, PPPIO_XACCM, accm, sizeof(ext_accm), 0) < 0) {
 922         if (!hungup || errno != ENXIO)
 923             warn("Couldn't set extended ACCM: %m");
 924     }
 925 }
 926
 927 /*
 928  * ppp_recv_config - configure the receive-side characteristics of
 929  * the ppp interface.
 930  */
 931 void
 932 ppp_recv_config(unit, mru, asyncmap, pcomp, accomp)
 933     int unit, mru;
 934     u_int32_t asyncmap;
 935     int pcomp, accomp;
 936 {
 937     int cf[2];
 938
 939     link_mru = mru;
 940     if (strioctl(pppfd, PPPIO_MRU, &mru, sizeof(mru), 0) < 0) {
 941         if (hungup && errno == ENXIO)
 942             return;
 943         error("Couldn't set MRU: %m");
 944     }
 945     if (strioctl(pppfd, PPPIO_RACCM, &asyncmap, sizeof(asyncmap), 0) < 0) {
 946         error("Couldn't set receive ACCM: %m");
 947     }
 948     cf[0] = (pcomp? DECOMP_PROT: 0) + (accomp? DECOMP_AC: 0);
 949     cf[1] = DECOMP_PROT | DECOMP_AC;
 950     if (strioctl(pppfd, PPPIO_CFLAGS, cf, sizeof(cf), sizeof(int)) < 0) {
 951         error("Couldn't set prot/AC decompression: %m");
 952     }
 953 }
 954
 955 /*
 956  * ccp_test - ask kernel whether a given compression method
 957  * is acceptable for use.
 958  *
 959  * In Digital UNIX the memory buckets for chunks >16K are not
 960  * primed when the system comes up.  That means we're not
 961  * likely to get the memory needed for the compressor on
 962  * the first try.  The way we work around this is to have
 963  * the driver spin off a thread to go get the memory for us
 964  * (we can't block at that point in a streams context.)
 965  *
 966  * This code synchronizes with the thread when it has returned
 967  * with the memory we need.  The driver will continue to return
 968  * with EAGAIN until the thread comes back.  We give up here
 969  * if after 10 attempts in one second we still don't have memory.
 970  * It's up to the driver to not lose track of that memory if
 971  * thread takes too long to return.
 972  */
 973 int
 974 ccp_test(unit, opt_ptr, opt_len, for_transmit)
 975     int unit, opt_len, for_transmit;
 976     u_char *opt_ptr;
 977 {
 978     struct timeval tval;
 979     int i;
 980
 981     tval.tv_sec = 0;
 982     tval.tv_usec = 100000;
 983     for (i = 0; i < 10; ++i) {
 984         if (strioctl(pppfd, (for_transmit? PPPIO_XCOMP: PPPIO_RCOMP),
 985             opt_ptr, opt_len, 0) >= 0) {
 986             return 1;
 987         }
 988         if (errno != EAGAIN)
 989             break;
 990         wait_time(&tval);
 991     }
 992     if (errno != 0)
 993         error("hard failure trying to get memory for a compressor: %m");
 994     return (errno == ENOSR)? 0: -1;
 995 }
 996
 997 /*
 998  * ccp_flags_set - inform kernel about the current state of CCP.
 999  */
1000 void
1001 ccp_flags_set(unit, isopen, isup)
1002     int unit, isopen, isup;
1003 {
1004     int cf[2];
1005
1006     cf[0] = (isopen? CCP_ISOPEN: 0) + (isup? CCP_ISUP: 0);
1007     cf[1] = CCP_ISOPEN | CCP_ISUP | CCP_ERROR | CCP_FATALERROR;
1008     if (strioctl(pppfd, PPPIO_CFLAGS, cf, sizeof(cf), sizeof(int)) < 0) {
1009         if (!hungup || errno != ENXIO)
1010             error("Couldn't set kernel CCP state: %m");
1011     }
1012 }
1013
1014 /*
1015  * get_idle_time - return how long the link has been idle.
1016  */
1017 int
1018 get_idle_time(u, ip)
1019     int u;
1020     struct ppp_idle *ip;
1021 {
1022     return strioctl(pppfd, PPPIO_GIDLE, ip, 0, sizeof(struct ppp_idle)) >= 0;
1023 }
1024
1025
1026 /*
1027  * ccp_fatal_error - returns 1 if decompression was disabled as a
1028  * result of an error detected after decompression of a packet,
1029  * 0 otherwise.  This is necessary because of patent nonsense.
1030  */
1031 int
1032 ccp_fatal_error(unit)
1033     int unit;
1034 {
1035     int cf[2];
1036
1037     cf[0] = cf[1] = 0;
1038     if (strioctl(pppfd, PPPIO_CFLAGS, cf, sizeof(cf), sizeof(int)) < 0) {
1039         if (errno != ENXIO && errno != EINVAL)
1040             error("Couldn't get compression flags: %m");
1041         return 0;
1042     }
1043     return cf[0] & CCP_FATALERROR;
1044 }
1045
1046 /*
1047  * sifvjcomp - config tcp header compression
1048  */
1049 int
1050 sifvjcomp(u, vjcomp, xcidcomp, xmaxcid)
1051     int u, vjcomp, xcidcomp, xmaxcid;
1052 {
1053     int cf[2];
1054     char maxcid[2];
1055
1056     if (vjcomp) {
1057         maxcid[0] = xcidcomp;
1058         maxcid[1] = 15;         /* XXX should be rmaxcid */
1059         if (strioctl(pppfd, PPPIO_VJINIT, maxcid, sizeof(maxcid), 0) < 0) {
1060             error("Couldn't initialize VJ compression: %m");
1061         }
1062     }
1063
1064     cf[0] = (vjcomp? COMP_VJC + DECOMP_VJC: 0)  /* XXX this is wrong */
1065         + (xcidcomp? COMP_VJCCID + DECOMP_VJCCID: 0);
1066     cf[1] = COMP_VJC + DECOMP_VJC + COMP_VJCCID + DECOMP_VJCCID;
1067     if (strioctl(pppfd, PPPIO_CFLAGS, cf, sizeof(cf), sizeof(int)) < 0) {
1068         if (vjcomp)
1069             error("Couldn't enable VJ compression: %m");
1070     }
1071
1072     return 1;
1073 }
1074
1075 /*
1076  * sifup - Config the interface up and enable IP packets to pass.
1077  */
1078 int
1079 sifup(u)
1080     int u;
1081 {
1082     struct ifreq ifr;
1083
1084     strlcpy(ifr.ifr_name, sizeof(ifr.ifr_name), ifname);
1085     if (ioctl(sockfd, SIOCGIFFLAGS, &ifr) < 0) {
1086         error("Couldn't mark interface up (get): %m");
1087         return 0;
1088     }
1089     ifr.ifr_flags |= IFF_UP;
1090     if (ioctl(sockfd, SIOCSIFFLAGS, &ifr) < 0) {
1091         error("Couldn't mark interface up (set): %m");
1092         return 0;
1093     }
1094     if_is_up = 1;
1095     return 1;
1096 }
1097
1098 /*
1099  * sifdown - Config the interface down and disable IP.
1100  */
1101 int
1102 sifdown(u)
1103     int u;
1104 {
1105     struct ifreq ifr;
1106
1107     strlcpy(ifr.ifr_name, sizeof(ifr.ifr_name), ifname);
1108     if (ioctl(sockfd, SIOCGIFFLAGS, &ifr) < 0) {
1109         error("Couldn't mark interface down (get): %m");
1110         return 0;
1111     }
1112     if ((ifr.ifr_flags & IFF_UP) != 0) {
1113         ifr.ifr_flags &= ~IFF_UP;
1114         if (ioctl(sockfd, SIOCSIFFLAGS, &ifr) < 0) {
1115             error("Couldn't mark interface down (set): %m");
1116             return 0;
1117         }
1118     }
1119     if_is_up = 0;
1120     return 1;
1121 }
1122
1123 /*
1124  * sifnpmode - Set the mode for handling packets for a given NP.
1125  */
1126 int
1127 sifnpmode(u, proto, mode)
1128     int u;
1129     int proto;
1130     enum NPmode mode;
1131 {
1132     int npi[2];
1133
1134     npi[0] = proto;
1135     npi[1] = (int) mode;
1136     if (strioctl(pppfd, PPPIO_NPMODE, npi, 2 * sizeof(int), 0) < 0) {
1137         error("ioctl(set NP %d mode to %d): %m", proto, mode);
1138         return 0;
1139     }
1140     return 1;
1141 }
1142
1143 #define INET_ADDR(x)    (((struct sockaddr_in *) &(x))->sin_addr.s_addr)
1144
1145 /*
1146  * SET_SA_FAMILY - initialize a struct sockaddr, setting the sa_family field.
1147  */
1148 #define SET_SA_FAMILY(addr, family)             \
1149     BZERO((char *) &(addr), sizeof(addr));      \
1150     addr.sa_family = (family);                  \
1151     addr.sa_len = sizeof ((addr))
1152
1153 /*
1154  * sifaddr - Config the interface IP addresses and netmask.
1155  */
1156 int
1157 sifaddr(u, o, h, m)
1158     int u;
1159     u_int32_t o, h, m;
1160 {
1161     struct ifreq ifr;
1162     struct ifaliasreq addreq;
1163     int ret;
1164
1165     ret = 1;
1166
1167     /* flush old address, if any
1168      */
1169     bzero(&ifr, sizeof (ifr));
1170     strlcpy(ifr.ifr_name, sizeof (ifr.ifr_name), ifname);
1171     SET_SA_FAMILY(ifr.ifr_addr, AF_INET);
1172     ((struct sockaddr_in *) &ifr.ifr_addr)->sin_addr.s_addr = o;
1173     if ((ioctl(sockfd, (int)SIOCDIFADDR, (caddr_t) &ifr) < 0)
1174         && errno != EADDRNOTAVAIL) {
1175         error("ioctl(SIOCDIFADDR): %m");
1176         ret = 0;
1177     }
1178
1179     bzero(&addreq, sizeof (addreq));
1180     strlcpy(addreq.ifra_name, sizeof (addreq.ifra_name), ifname);
1181     SET_SA_FAMILY(addreq.ifra_addr, AF_INET);
1182     SET_SA_FAMILY(addreq.ifra_broadaddr, AF_INET);
1183     ((struct sockaddr_in *)&addreq.ifra_addr)->sin_addr.s_addr = o;
1184     ((struct sockaddr_in *)&addreq.ifra_broadaddr)->sin_addr.s_addr = h;
1185
1186     if (m != 0) {
1187         ((struct sockaddr_in *)&addreq.ifra_mask)->sin_addr.s_addr = m;
1188         addreq.ifra_mask.sa_len = sizeof (struct sockaddr);
1189         info("Setting interface mask to %s\n", ip_ntoa(m));
1190     }
1191
1192     /* install new src/dst and (possibly) netmask
1193      */
1194     if (ioctl(sockfd, SIOCPIFADDR, &addreq) < 0) {
1195         error("ioctl(SIOCPIFADDR): %m");
1196         ret = 0;
1197     }
1198
1199     ifr.ifr_metric = link_mtu;
1200     if (ioctl(sockfd, SIOCSIPMTU, &ifr) < 0) {
1201         error("Couldn't set IP MTU: %m");
1202         ret = 0;
1203     }
1204
1205     ifaddrs[0] = o;
1206     ifaddrs[1] = h;
1207     return (ret);
1208 }
1209
1210
1211 /*
1212  * cifaddr - Clear the interface IP addresses, and delete routes
1213  * through the interface if possible.
1214  */
1215 int
1216 cifaddr(u, o, h)
1217     int u;
1218     u_int32_t o, h;
1219 {
1220     struct ifreq ifr;
1221
1222     ifaddrs[0] = 0;
1223     ifaddrs[1] = 0;
1224     bzero(&ifr, sizeof (ifr));
1225     strlcpy(ifr.ifr_name, sizeof (ifr.ifr_name), ifname);
1226     SET_SA_FAMILY(ifr.ifr_addr, AF_INET);
1227     ((struct sockaddr_in *) &ifr.ifr_addr)->sin_addr.s_addr = o;
1228     if (ioctl(sockfd, (int)SIOCDIFADDR, (caddr_t) &ifr) < 0) {
1229         error("ioctl(SIOCDIFADDR): %m");
1230         return 0;
1231     }
1232     return 1;
1233 }
1234
1235
1236 /*
1237  * sifdefaultroute - assign a default route through the address given.
1238  */
1239 int
1240 sifdefaultroute(u, l, g)
1241     int u;
1242     u_int32_t l, g;
1243 {
1244     struct ortentry rt;
1245
1246     BZERO(&rt, sizeof(rt));
1247     SET_SA_FAMILY(rt.rt_dst, AF_INET);
1248     SET_SA_FAMILY(rt.rt_gateway, AF_INET);
1249     ((struct sockaddr_in *) &rt.rt_gateway)->sin_addr.s_addr = g;
1250     rt.rt_flags = RTF_GATEWAY;
1251     if (ioctl(sockfd, (int)SIOCADDRT, &rt) < 0) {
1252         error("default route ioctl(SIOCADDRT): %m");
1253         return 0;
1254     }
1255     default_route_gateway = g;
1256     return 1;
1257 }
1258
1259
1260 /*
1261  * cifdefaultroute - delete a default route through the address given.
1262  */
1263 int
1264 cifdefaultroute(u, l, g)
1265     int u;
1266     u_int32_t l, g;
1267 {
1268     struct ortentry rt;
1269
1270     BZERO(&rt, sizeof(rt));
1271     SET_SA_FAMILY(rt.rt_dst, AF_INET);
1272     SET_SA_FAMILY(rt.rt_gateway, AF_INET);
1273     ((struct sockaddr_in *) &rt.rt_gateway)->sin_addr.s_addr = g;
1274     rt.rt_flags = RTF_GATEWAY;
1275     if (ioctl(sockfd, (int)SIOCDELRT, &rt) < 0) {
1276         error("default route ioctl(SIOCDELRT): %m");
1277         return 0;
1278     }
1279     default_route_gateway = 0;
1280     return 1;
1281 }
1282
1283 /*
1284  * sifproxyarp - Make a proxy ARP entry for the peer.
1285  */
1286 int
1287 sifproxyarp(unit, hisaddr)
1288     int unit;
1289     u_int32_t hisaddr;
1290 {
1291     struct arpreq arpreq;
1292
1293     BZERO(&arpreq, sizeof(arpreq));
1294
1295     /*
1296      * Get the hardware address of an interface on the same subnet
1297      * as our local address.
1298      */
1299     if (!get_ether_addr(hisaddr, &arpreq.arp_ha)) {
1300         warn("Cannot determine ethernet address for proxy ARP");
1301         return 0;
1302     }
1303
1304     SET_SA_FAMILY(arpreq.arp_pa, AF_INET);
1305     ((struct sockaddr_in *) &arpreq.arp_pa)->sin_addr.s_addr = hisaddr;
1306     arpreq.arp_flags = ATF_PERM | ATF_PUBL;
1307     if (ioctl(sockfd, (int)SIOCSARP, (caddr_t)&arpreq) < 0) {
1308         error("ioctl(SIOCSARP): %m");
1309         return 0;
1310     }
1311
1312     proxy_arp_addr = hisaddr;
1313     return 1;
1314 }
1315
1316
1317 /*
1318  * cifproxyarp - Delete the proxy ARP entry for the peer.
1319  */
1320 int
1321 cifproxyarp(unit, hisaddr)
1322     int unit;
1323     u_int32_t hisaddr;
1324 {
1325     struct arpreq arpreq;
1326
1327     BZERO(&arpreq, sizeof(arpreq));
1328     SET_SA_FAMILY(arpreq.arp_pa, AF_INET);
1329     ((struct sockaddr_in *) &arpreq.arp_pa)->sin_addr.s_addr = hisaddr;
1330     if (ioctl(sockfd, (int)SIOCDARP, (caddr_t)&arpreq) < 0) {
1331         error("ioctl(SIOCDARP): %m");
1332         return 0;
1333     }
1334     proxy_arp_addr = 0;
1335     return 1;
1336 }
1337
1338 /*
1339  * get_ether_addr - get the hardware address of an interface on the
1340  * the same subnet as ipaddr.
1341  */
1342 #define MAX_IFS         32
1343
1344 static int
1345 get_ether_addr(ipaddr, hwaddr)
1346     u_int32_t ipaddr;
1347     struct sockaddr *hwaddr;
1348 {
1349     struct ifreq *ifr, *ifend;
1350     u_int32_t ina, mask;
1351     struct ifreq ifreq;
1352     struct ifconf ifc;
1353     struct ifreq ifs[MAX_IFS];
1354     struct ifdevea ifdevreq;
1355
1356     ifc.ifc_len = sizeof(ifs);
1357     ifc.ifc_req = ifs;
1358     if (ioctl(sockfd, SIOCGIFCONF, &ifc) < 0) {
1359         error("ioctl(SIOCGIFCONF): %m");
1360         return 0;
1361     }
1362
1363     /*
1364      * Scan through looking for an interface with an Internet
1365      * address on the same subnet as `ipaddr'.
1366      */
1367     ifend = (struct ifreq *) (ifc.ifc_buf + ifc.ifc_len);
1368     for (ifr = ifc.ifc_req; ifr < ifend; ifr++) {
1369         if (ifr->ifr_addr.sa_family == AF_INET) {
1370
1371             /*
1372              * Check that the interface is up, and not point-to-point
1373              * or loopback.
1374              */
1375             strlcpy(ifreq.ifr_name, sizeof(ifreq.ifr_name), ifr->ifr_name);
1376             if (ioctl(sockfd, SIOCGIFFLAGS, &ifreq) < 0)
1377                 continue;
1378             if ((ifreq.ifr_flags &
1379                  (IFF_UP|IFF_BROADCAST|IFF_POINTOPOINT|IFF_LOOPBACK|IFF_NOARP))
1380                  != (IFF_UP|IFF_BROADCAST))
1381                 continue;
1382
1383             /*
1384              * Get its netmask and check that it's on the right subnet.
1385              */
1386             if (ioctl(sockfd, SIOCGIFNETMASK, &ifreq) < 0)
1387                 continue;
1388             ina = ((struct sockaddr_in *) &ifr->ifr_addr)->sin_addr.s_addr;
1389             mask = ((struct sockaddr_in *) &ifreq.ifr_addr)->sin_addr.s_addr;
1390             if ((ipaddr & mask) != (ina & mask))
1391                 continue;
1392
1393             break;
1394         } else {
1395             if (ifr->ifr_addr.sa_len > sizeof (ifr->ifr_addr))
1396                 ifr = (struct ifreq *)((caddr_t)ifr + (ifr->ifr_addr.sa_len - sizeof (ifr->ifr_addr)));
1397         }
1398     }
1399
1400     if (ifr >= ifend)
1401         return 0;
1402     info("found interface %s for proxy arp", ifr->ifr_name);
1403
1404     strlcpy(ifdevreq.ifr_name, sizeof(ifdevreq.ifr_name), ifr->ifr_name);
1405
1406     if (ioctl(sockfd, (int)SIOCRPHYSADDR, &ifdevreq) < 0) {
1407         perror("ioctl(SIOCRPHYSADDR)");
1408         return(0);
1409     }
1410
1411     hwaddr->sa_family = AF_UNSPEC;
1412     memcpy(hwaddr->sa_data, ifdevreq.current_pa, sizeof(ifdevreq.current_pa));
1413     return 1;
1414 }
1415
1416 #define WTMPFILE        "/usr/adm/wtmp"
1417
1418 void
1419 logwtmp(line, name, host)
1420     const char *line, *name, *host;
1421 {
1422     int fd;
1423     struct stat buf;
1424     struct utmp ut;
1425
1426     if ((fd = open(WTMPFILE, O_WRONLY|O_APPEND, 0)) < 0)
1427         return;
1428     if (!fstat(fd, &buf)) {
1429         strlcpy(ut.ut_line, sizeof(ut.ut_line), line);
1430         strlcpy(ut.ut_name, sizeof(ut.ut_name), name);
1431         strlcpy(ut.ut_host, sizeof(ut.ut_host), host);
1432         (void)time(&ut.ut_time);
1433         if (write(fd, (char *)&ut, sizeof(struct utmp)) != sizeof(struct utmp))
1434             (void)ftruncate(fd, buf.st_size);
1435     }
1436     close(fd);
1437 }
1438
1439 /*
1440  * Return user specified netmask, modified by any mask we might determine
1441  * for address `addr' (in network byte order).
1442  * Here we scan through the system's list of interfaces, looking for
1443  * any non-point-to-point interfaces which might appear to be on the same
1444  * network as `addr'.  If we find any, we OR in their netmask to the
1445  * user-specified netmask.
1446  */
1447 u_int32_t
1448 GetMask(addr)
1449     u_int32_t addr;
1450 {
1451     u_int32_t mask, nmask, ina;
1452     struct ifreq *ifr, *ifend, ifreq;
1453     struct ifconf ifc;
1454
1455     addr = ntohl(addr);
1456     if (IN_CLASSA(addr))        /* determine network mask for address class */
1457         nmask = IN_CLASSA_NET;
1458     else if (IN_CLASSB(addr))
1459         nmask = IN_CLASSB_NET;
1460     else
1461         nmask = IN_CLASSC_NET;
1462     /* class D nets are disallowed by bad_ip_adrs */
1463     mask = netmask | htonl(nmask);
1464
1465     /*
1466      * Scan through the system's network interfaces.
1467      */
1468     ifc.ifc_len = MAX_IFS * sizeof(struct ifreq);
1469     ifc.ifc_req = (struct ifreq *)alloca(ifc.ifc_len);
1470     if (ifc.ifc_req == 0)
1471         return mask;
1472     if (ioctl(sockfd, SIOCGIFCONF, &ifc) < 0) {
1473         warn("Couldn't get system interface list: %m");
1474         return mask;
1475     }
1476     ifend = (struct ifreq *) (ifc.ifc_buf + ifc.ifc_len);
1477     for (ifr = ifc.ifc_req; ifr < ifend; ifr++) {
1478         /*
1479          * Check the interface's internet address.
1480          */
1481         if (ifr->ifr_addr.sa_family == AF_INET) {
1482             ina = INET_ADDR(ifr->ifr_addr);
1483             if ((ntohl(ina) & nmask) != (addr & nmask))
1484                 continue;
1485             /*
1486              * Check that the interface is up, and not point-to-point or loopback.
1487              */
1488             strlcpy(ifreq.ifr_name, sizeof(ifreq.ifr_name), ifr->ifr_name);
1489             if (ioctl(sockfd, SIOCGIFFLAGS, &ifreq) < 0)
1490                 continue;
1491             if ((ifreq.ifr_flags & (IFF_UP|IFF_POINTOPOINT|IFF_LOOPBACK))
1492                 != IFF_UP)
1493                 continue;
1494             /*
1495              * Get its netmask and OR it into our mask.
1496              */
1497             if (ioctl(sockfd, SIOCGIFNETMASK, &ifreq) < 0)
1498                 continue;
1499             mask |= INET_ADDR(ifreq.ifr_addr);
1500             break;
1501         } else {
1502             if (ifr->ifr_addr.sa_len > sizeof (ifr->ifr_addr))
1503                 ifr = (struct ifreq *)((caddr_t)ifr + (ifr->ifr_addr.sa_len - sizeof (ifr->ifr_addr)));
1504         }
1505     }
1506
1507     return mask;
1508 }
1509
1510 /*
1511  * have_route_to - determine if the system has any route to
1512  * a given IP address.  `addr' is in network byte order.
1513  * For demand mode to work properly, we have to ignore routes
1514  * through our own interface.
1515  */
1516 int have_route_to(u_int32_t addr)
1517 {
1518         char buf[sizeof(struct rt_msghdr) + (sizeof(struct sockaddr_in))];
1519         int status;
1520         int s, n;
1521         struct rt_msghdr *rtm;
1522         struct sockaddr_in *sin;
1523         int msglen = sizeof(*rtm) + (sizeof(*sin));
1524         char *cp;
1525         char msg[2048];
1526
1527         rtm = (struct rt_msghdr *)buf;
1528         memset(rtm, 0, msglen);
1529         rtm->rtm_msglen = msglen;
1530         rtm->rtm_version = RTM_VERSION;
1531         rtm->rtm_type = RTM_GET;
1532         rtm->rtm_addrs = RTA_DST;
1533         /* rtm->rtm_addrs, rtm_flags  should be set on output */
1534
1535         sin = (struct sockaddr_in *)((u_char *)rtm + sizeof(*rtm));
1536         sin->sin_len = sizeof(*sin);
1537         sin->sin_family = AF_INET;
1538         sin->sin_addr.s_addr = addr;
1539
1540         status = 0;
1541
1542         if ((s = socket(PF_ROUTE, SOCK_RAW, 0)) < 0)
1543                 return -1;
1544         if (write(s, (char *)rtm, msglen) != msglen) {
1545                 close(s);
1546                 return status == ESRCH? 0: -1;
1547         }
1548
1549         n = read(s, msg, 2048);
1550         close(s);
1551         if (n <= 0)
1552                 return -1;
1553
1554         rtm = (struct rt_msghdr *) msg;
1555         if (rtm->rtm_version != RTM_VERSION)
1556                 return -1;
1557
1558         /* here we try to work out if the route is through our own interface */
1559         cp = (char *)(rtm + 1);
1560         if (rtm->rtm_addrs & RTA_DST) {
1561                 struct sockaddr *sa = (struct sockaddr *) cp;
1562                 cp = (char *)(((unsigned long)cp + sa->sa_len
1563                                + sizeof(long) - 1) & ~(sizeof(long) - 1));
1564         }
1565         if (rtm->rtm_addrs & RTA_GATEWAY) {
1566                 sin = (struct sockaddr_in *) cp;
1567                 if (sin->sin_addr.s_addr == ifaddrs[0]
1568                     || sin->sin_addr.s_addr == ifaddrs[1])
1569                         return 0;       /* route is through our interface */
1570         }
1571
1572         return 1;
1573 }
1574
1575 static int
1576 strioctl(fd, cmd, ptr, ilen, olen)
1577     int fd, cmd, ilen, olen;
1578     void *ptr;
1579 {
1580     struct strioctl str;
1581
1582     str.ic_cmd = cmd;
1583     str.ic_timout = 0;
1584     str.ic_len = ilen;
1585     str.ic_dp = ptr;
1586     if (ioctl(fd, I_STR, &str) == -1)
1587         return -1;
1588     if (str.ic_len != olen)
1589         dbglog("strioctl: expected %d bytes, got %d for cmd %x\n",
1590                olen, str.ic_len, cmd);
1591     return 0;
1592 }
1593
1594 /*
1595  * Use the hostid as part of the random number seed.
1596  */
1597 int
1598 get_host_seed()
1599 {
1600     return gethostid();
1601 }
1602
1603 /*
1604  * Code for locking/unlocking the serial device.
1605  * This code is derived from chat.c.
1606  */
1607
1608 #if !defined(HDB) && !defined(SUNOS3)
1609 #define HDB     1               /* ascii lock files are the default */
1610 #endif
1611
1612 #ifndef LOCK_DIR
1613 # if HDB
1614 #  define       PIDSTRING
1615 #  define       LOCK_PREFIX     "/usr/spool/locks/LCK.."
1616 # else /* HDB */
1617 #  define       LOCK_PREFIX     "/usr/spool/uucp/LCK.."
1618 # endif /* HDB */
1619 #endif /* LOCK_DIR */
1620
1621 static char *lock_file;         /* name of lock file created */
1622
1623 /*
1624  * lock - create a lock file for the named device.
1625  */
1626 int
1627 lock(dev)
1628     char *dev;
1629 {
1630     char hdb_lock_buffer[12];
1631     int fd, pid, n;
1632     char *p;
1633     size_t l;
1634
1635     if ((p = strrchr(dev, '/')) != NULL)
1636         dev = p + 1;
1637     l = strlen(LOCK_PREFIX) + strlen(dev) + 1;
1638     lock_file = malloc(l);
1639     if (lock_file == NULL)
1640         novm("lock file name");
1641     slprintf(lock_file, l, "%s%s", LOCK_PREFIX, dev);
1642
1643     while ((fd = open(lock_file, O_EXCL | O_CREAT | O_RDWR, 0644)) < 0) {
1644         if (errno == EEXIST
1645             && (fd = open(lock_file, O_RDONLY, 0)) >= 0) {
1646             /* Read the lock file to find out who has the device locked */
1647 #ifdef PIDSTRING
1648             n = read(fd, hdb_lock_buffer, 11);
1649             if (n > 0) {
1650                 hdb_lock_buffer[n] = 0;
1651                 pid = atoi(hdb_lock_buffer);
1652             }
1653 #else
1654             n = read(fd, &pid, sizeof(pid));
1655 #endif
1656             if (n <= 0) {
1657                 error("Can't read pid from lock file %s", lock_file);
1658                 close(fd);
1659             } else {
1660                 if (kill(pid, 0) == -1 && errno == ESRCH) {
1661                     /* pid no longer exists - remove the lock file */
1662                     if (unlink(lock_file) == 0) {
1663                         close(fd);
1664                         notice("Removed stale lock on %s (pid %d)",
1665                                dev, pid);
1666                         continue;
1667                     } else
1668                         warn("Couldn't remove stale lock on %s",
1669                                dev);
1670                 } else
1671                     notice("Device %s is locked by pid %d",
1672                            dev, pid);
1673             }
1674             close(fd);
1675         } else
1676             error("Can't create lock file %s: %m", lock_file);
1677         free(lock_file);
1678         lock_file = NULL;
1679         return -1;
1680     }
1681
1682 #ifdef PIDSTRING
1683     slprintf(hdb_lock_buffer, sizeof(hdb_lock_buffer), "%10d\n", getpid());
1684     write(fd, hdb_lock_buffer, 11);
1685 #else
1686     pid = getpid();
1687     write(fd, &pid, sizeof pid);
1688 #endif
1689
1690     close(fd);
1691     return 0;
1692 }
1693
1694 /*
1695  * unlock - remove our lockfile
1696  */
1697 void
1698 unlock()
1699 {
1700     if (lock_file) {
1701         unlink(lock_file);
1702         free(lock_file);
1703         lock_file = NULL;
1704     }
1705 }
1706
1707 int
1708 set_filters(pass, active)
1709     struct bpf_program *pass, *active;
1710 {
1711     return 1;
1712 }
1713
1714 int
1715 bpf_compile(program, buf, optimize)
1716     struct bpf_program *program;
1717     char *buf;
1718     int optimize;
1719 {
1720     return 0;
1721 }
1722
1723 char *
1724 bpf_geterr()
1725 {
1726     return 0;
1727 }
1728
1729 u_int
1730 bpf_filter(pc, p, wirelen, buflen)
1731     struct bpf_insn *pc;
1732     u_char *p;
1733     u_int wirelen;
1734     u_int buflen;
1735 {
1736     return 0;
1737 }