]> git.ozlabs.org Git - ppp.git/blob - pppd/sys-bsd.c
added add_fd, remove_fd, removed wait_loop_output, wait_time.
[ppp.git] / pppd / sys-bsd.c
1 /*
2  * sys-bsd.c - System-dependent procedures for setting up
3  * PPP interfaces on bsd-4.4-ish systems (including 386BSD, NetBSD, etc.)
4  *
5  * Copyright (c) 1989 Carnegie Mellon University.
6  * Copyright (c) 1995 The Australian National University.
7  * All rights reserved.
8  *
9  * Redistribution and use in source and binary forms are permitted
10  * provided that the above copyright notice and this paragraph are
11  * duplicated in all such forms and that any documentation,
12  * advertising materials, and other materials related to such
13  * distribution and use acknowledge that the software was developed
14  * by Carnegie Mellon University and The Australian National University.
15  * The names of the Universities may not be used to endorse or promote
16  * products derived from this software without specific prior written
17  * permission.
18  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
19  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
20  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
21  */
22
23 #ifndef lint
24 static char rcsid[] = "$Id: sys-bsd.c,v 1.37 1999/03/16 02:57:06 paulus Exp $";
25 /*      $NetBSD: sys-bsd.c,v 1.1.1.3 1997/09/26 18:53:04 christos Exp $ */
26 #endif
27
28 /*
29  * TODO:
30  */
31
32 #include <stdio.h>
33 #include <string.h>
34 #include <stdlib.h>
35 #include <unistd.h>
36 #include <errno.h>
37 #include <fcntl.h>
38 #include <termios.h>
39 #include <signal.h>
40 #include <sys/ioctl.h>
41 #include <sys/types.h>
42 #include <sys/socket.h>
43 #include <sys/time.h>
44 #include <sys/stat.h>
45 #include <sys/param.h>
46 #ifdef NetBSD1_2
47 #include <util.h>
48 #endif
49 #ifdef PPP_FILTER
50 #include <net/bpf.h>
51 #endif
52
53 #include <net/if.h>
54 #include <net/ppp_defs.h>
55 #include <net/if_ppp.h>
56 #include <net/route.h>
57 #include <net/if_dl.h>
58 #include <netinet/in.h>
59
60 #if RTM_VERSION >= 3
61 #include <sys/param.h>
62 #if defined(NetBSD) && (NetBSD >= 199703)
63 #include <netinet/if_inarp.h>
64 #else   /* NetBSD 1.2D or later */
65 #ifdef __FreeBSD__
66 #include <netinet/if_ether.h>
67 #else
68 #include <net/if_ether.h>
69 #endif
70 #endif
71 #endif
72
73 #include "pppd.h"
74 #include "fsm.h"
75 #include "ipcp.h"
76
77 static int initdisc = -1;       /* Initial TTY discipline for ppp_fd */
78 static int initfdflags = -1;    /* Initial file descriptor flags for ppp_fd */
79 static int ppp_fd = -1;         /* fd which is set to PPP discipline */
80 static int rtm_seq;
81
82 static int restore_term;        /* 1 => we've munged the terminal */
83 static struct termios inittermios; /* Initial TTY termios */
84 static struct winsize wsinfo;   /* Initial window size info */
85
86 static char *lock_file;         /* name of lock file created */
87
88 static int loop_slave = -1;
89 static int loop_master;
90 static char loop_name[20];
91
92 static unsigned char inbuf[512]; /* buffer for chars read from loopback */
93
94 static int sockfd;              /* socket for doing interface ioctls */
95
96 static fd_set in_fds;           /* set of fds that wait_input waits for */
97 static int max_in_fd;           /* highest fd set in in_fds */
98
99 static int if_is_up;            /* the interface is currently up */
100 static u_int32_t ifaddrs[2];    /* local and remote addresses we set */
101 static u_int32_t default_route_gateway; /* gateway addr for default route */
102 static u_int32_t proxy_arp_addr;        /* remote addr for proxy arp */
103
104 /* Prototypes for procedures local to this file. */
105 static int dodefaultroute __P((u_int32_t, int));
106 static int get_ether_addr __P((u_int32_t, struct sockaddr_dl *));
107
108
109 /*
110  * sys_init - System-dependent initialization.
111  */
112 void
113 sys_init()
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     FD_ZERO(&in_fds);
120     max_in_fd = 0;
121 }
122
123 /*
124  * sys_cleanup - restore any system state we modified before exiting:
125  * mark the interface down, delete default route and/or proxy arp entry.
126  * This should call die() because it's called from die().
127  */
128 void
129 sys_cleanup()
130 {
131     struct ifreq ifr;
132
133     if (if_is_up) {
134         strlcpy(ifr.ifr_name, sizeof(ifr.ifr_name), ifname);
135         if (ioctl(sockfd, SIOCGIFFLAGS, &ifr) >= 0
136             && ((ifr.ifr_flags & IFF_UP) != 0)) {
137             ifr.ifr_flags &= ~IFF_UP;
138             ioctl(sockfd, SIOCSIFFLAGS, &ifr);
139         }
140     }
141     if (ifaddrs[0] != 0)
142         cifaddr(0, ifaddrs[0], ifaddrs[1]);
143     if (default_route_gateway)
144         cifdefaultroute(0, 0, default_route_gateway);
145     if (proxy_arp_addr)
146         cifproxyarp(0, proxy_arp_addr);
147 }
148
149 /*
150  * sys_close - Clean up in a child process before execing.
151  */
152 void
153 sys_close()
154 {
155     close(sockfd);
156     if (loop_slave >= 0) {
157         close(loop_slave);
158         close(loop_master);
159     }
160 }
161
162 /*
163  * sys_check_options - check the options that the user specified
164  */
165 int
166 sys_check_options()
167 {
168 #ifndef CDTRCTS
169     if (crtscts == 2) {
170         warn("DTR/CTS flow control is not supported on this system");
171         return 0;
172     }
173 #endif
174     return 1;
175 }
176
177 /*
178  * ppp_available - check whether the system has any ppp interfaces
179  * (in fact we check whether we can do an ioctl on ppp0).
180  */
181 int
182 ppp_available()
183 {
184     int s, ok;
185     struct ifreq ifr;
186     extern char *no_ppp_msg;
187
188     if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
189         return 1;               /* can't tell */
190
191     strlcpy(ifr.ifr_name, sizeof (ifr.ifr_name), "ppp0");
192     ok = ioctl(s, SIOCGIFFLAGS, (caddr_t) &ifr) >= 0;
193     close(s);
194
195     no_ppp_msg = "\
196 This system lacks kernel support for PPP.  To include PPP support\n\
197 in the kernel, please follow the steps detailed in the README.bsd\n\
198 file in the ppp-2.2 distribution.\n";
199     return ok;
200 }
201
202 /*
203  * establish_ppp - Turn the serial port into a ppp interface.
204  */
205 void
206 establish_ppp(fd)
207     int fd;
208 {
209     int pppdisc = PPPDISC;
210     int x;
211
212     if (demand) {
213         /*
214          * Demand mode - prime the old ppp device to relinquish the unit.
215          */
216         if (ioctl(ppp_fd, PPPIOCXFERUNIT, 0) < 0)
217             fatal("ioctl(transfer ppp unit): %m");
218     }
219
220     /*
221      * Save the old line discipline of fd, and set it to PPP.
222      */
223     if (ioctl(fd, TIOCGETD, &initdisc) < 0)
224         fatal("ioctl(TIOCGETD): %m");
225     if (ioctl(fd, TIOCSETD, &pppdisc) < 0)
226         fatal("ioctl(TIOCSETD): %m");
227
228     if (!demand) {
229         /*
230          * Find out which interface we were given.
231          */
232         if (ioctl(fd, PPPIOCGUNIT, &ifunit) < 0) {    
233             fatal("ioctl(PPPIOCGUNIT): %m");
234     } else {
235         /*
236          * Check that we got the same unit again.
237          */
238         if (ioctl(fd, PPPIOCGUNIT, &x) < 0) { 
239             fatal("ioctl(PPPIOCGUNIT): %m");
240         if (x != ifunit)
241             fatal("transfer_ppp failed: wanted unit %d, got %d", ifunit, x);
242         x = TTYDISC;
243         ioctl(loop_slave, TIOCSETD, &x);
244     }
245
246     ppp_fd = fd;
247
248     /*
249      * Enable debug in the driver if requested.
250      */
251     if (kdebugflag) {
252         if (ioctl(fd, PPPIOCGFLAGS, (caddr_t) &x) < 0) {
253             warn("ioctl (PPPIOCGFLAGS): %m");
254         } else {
255             x |= (kdebugflag & 0xFF) * SC_DEBUG;
256             if (ioctl(fd, PPPIOCSFLAGS, (caddr_t) &x) < 0)
257                 warn("ioctl(PPPIOCSFLAGS): %m");
258         }
259     }
260
261     /*
262      * Set device for non-blocking reads.
263      */
264     if ((initfdflags = fcntl(fd, F_GETFL)) == -1
265         || fcntl(fd, F_SETFL, initfdflags | O_NONBLOCK) == -1) {
266         warn("Couldn't set device to non-blocking mode: %m");
267     }
268 }
269
270 /*
271  * restore_loop - reattach the ppp unit to the loopback.
272  */
273 void
274 restore_loop()
275 {
276     int x;
277
278     /*
279      * Transfer the ppp interface back to the loopback.
280      */
281     if (ioctl(ppp_fd, PPPIOCXFERUNIT, 0) < 0)
282         fatal("ioctl(transfer ppp unit): %m");
283     x = PPPDISC;
284     if (ioctl(loop_slave, TIOCSETD, &x) < 0)
285         fatal("ioctl(TIOCSETD): %m");
286
287     /*
288      * Check that we got the same unit again.
289      */
290     if (ioctl(loop_slave, PPPIOCGUNIT, &x) < 0)
291         fatal("ioctl(PPPIOCGUNIT): %m");
292     if (x != ifunit)
293         fatal("transfer_ppp failed: wanted unit %d, got %d", ifunit, x);
294     ppp_fd = loop_slave;
295 }
296
297
298 /*
299  * disestablish_ppp - Restore the serial port to normal operation.
300  * This shouldn't call die() because it's called from die().
301  */
302 void
303 disestablish_ppp(fd)
304     int fd;
305 {
306     /* Reset non-blocking mode on fd. */
307     if (initfdflags != -1 && fcntl(fd, F_SETFL, initfdflags) < 0)
308         warn("Couldn't restore device fd flags: %m");
309     initfdflags = -1;
310
311     /* Restore old line discipline. */
312     if (initdisc >= 0 && ioctl(fd, TIOCSETD, &initdisc) < 0)
313         error("ioctl(TIOCSETD): %m");
314     initdisc = -1;
315
316     if (fd == ppp_fd)
317         ppp_fd = -1;
318 }
319
320 /*
321  * Check whether the link seems not to be 8-bit clean.
322  */
323 void
324 clean_check()
325 {
326     int x;
327     char *s;
328
329     if (ioctl(ppp_fd, PPPIOCGFLAGS, (caddr_t) &x) == 0) {
330         s = NULL;
331         switch (~x & (SC_RCV_B7_0|SC_RCV_B7_1|SC_RCV_EVNP|SC_RCV_ODDP)) {
332         case SC_RCV_B7_0:
333             s = "bit 7 set to 1";
334             break;
335         case SC_RCV_B7_1:
336             s = "bit 7 set to 0";
337             break;
338         case SC_RCV_EVNP:
339             s = "odd parity";
340             break;
341         case SC_RCV_ODDP:
342             s = "even parity";
343             break;
344         }
345         if (s != NULL) {
346             warn("Serial link is not 8-bit clean:");
347             warn("All received characters had %s", s);
348         }
349     }
350 }
351
352 /*
353  * set_up_tty: Set up the serial port on `fd' for 8 bits, no parity,
354  * at the requested speed, etc.  If `local' is true, set CLOCAL
355  * regardless of whether the modem option was specified.
356  *
357  * For *BSD, we assume that speed_t values numerically equal bits/second.
358  */
359 void
360 set_up_tty(fd, local)
361     int fd, local;
362 {
363     struct termios tios;
364
365     if (tcgetattr(fd, &tios) < 0)
366         fatal("tcgetattr: %m");
367
368     if (!restore_term) {
369         inittermios = tios;
370         ioctl(fd, TIOCGWINSZ, &wsinfo);
371     }
372
373     tios.c_cflag &= ~(CSIZE | CSTOPB | PARENB | CLOCAL);
374     if (crtscts > 0 && !local) {
375         if (crtscts == 2) {
376 #ifdef CDTRCTS
377             tios.c_cflag |= CDTRCTS;
378 #endif
379         } else
380             tios.c_cflag |= CRTSCTS;
381     } else if (crtscts < 0) {
382         tios.c_cflag &= ~CRTSCTS;
383 #ifdef CDTRCTS
384         tios.c_cflag &= ~CDTRCTS;
385 #endif
386     }
387
388     tios.c_cflag |= CS8 | CREAD | HUPCL;
389     if (local || !modem)
390         tios.c_cflag |= CLOCAL;
391     tios.c_iflag = IGNBRK | IGNPAR;
392     tios.c_oflag = 0;
393     tios.c_lflag = 0;
394     tios.c_cc[VMIN] = 1;
395     tios.c_cc[VTIME] = 0;
396
397     if (crtscts == -2) {
398         tios.c_iflag |= IXON | IXOFF;
399         tios.c_cc[VSTOP] = 0x13;        /* DC3 = XOFF = ^S */
400         tios.c_cc[VSTART] = 0x11;       /* DC1 = XON  = ^Q */
401     }
402
403     if (inspeed) {
404         cfsetospeed(&tios, inspeed);
405         cfsetispeed(&tios, inspeed);
406     } else {
407         inspeed = cfgetospeed(&tios);
408         /*
409          * We can't proceed if the serial port speed is 0,
410          * since that implies that the serial port is disabled.
411          */
412         if (inspeed == 0)
413             fatal("Baud rate for %s is 0; need explicit baud rate", devnam);
414     }
415     baud_rate = inspeed;
416
417     if (tcsetattr(fd, TCSAFLUSH, &tios) < 0)
418         fatal("tcsetattr: %m");
419
420     restore_term = 1;
421 }
422
423 /*
424  * restore_tty - restore the terminal to the saved settings.
425  */
426 void
427 restore_tty(fd)
428     int fd;
429 {
430     if (restore_term) {
431         if (!default_device) {
432             /*
433              * Turn off echoing, because otherwise we can get into
434              * a loop with the tty and the modem echoing to each other.
435              * We presume we are the sole user of this tty device, so
436              * when we close it, it will revert to its defaults anyway.
437              */
438             inittermios.c_lflag &= ~(ECHO | ECHONL);
439         }
440         if (tcsetattr(fd, TCSAFLUSH, &inittermios) < 0)
441             if (errno != ENXIO)
442                 warn("tcsetattr: %m");
443         ioctl(fd, TIOCSWINSZ, &wsinfo);
444         restore_term = 0;
445     }
446 }
447
448 /*
449  * setdtr - control the DTR line on the serial port.
450  * This is called from die(), so it shouldn't call die().
451  */
452 void
453 setdtr(fd, on)
454 int fd, on;
455 {
456     int modembits = TIOCM_DTR;
457
458     ioctl(fd, (on? TIOCMBIS: TIOCMBIC), &modembits);
459 }
460
461
462 /*
463  * open_ppp_loopback - open the device we use for getting
464  * packets in demand mode, and connect it to a ppp interface.
465  * Here we use a pty.
466  */
467 void
468 open_ppp_loopback()
469 {
470     int flags;
471     struct termios tios;
472     int pppdisc = PPPDISC;
473
474     if (openpty(&loop_master, &loop_slave, loop_name, NULL, NULL) < 0)
475         fatal("No free pty for loopback");
476     SYSDEBUG(("using %s for loopback", loop_name));
477
478     if (tcgetattr(loop_slave, &tios) == 0) {
479         tios.c_cflag &= ~(CSIZE | CSTOPB | PARENB);
480         tios.c_cflag |= CS8 | CREAD;
481         tios.c_iflag = IGNPAR;
482         tios.c_oflag = 0;
483         tios.c_lflag = 0;
484         if (tcsetattr(loop_slave, TCSAFLUSH, &tios) < 0)
485             warn("couldn't set attributes on loopback: %m");
486     }
487
488     if ((flags = fcntl(loop_master, F_GETFL)) != -1) 
489         if (fcntl(loop_master, F_SETFL, flags | O_NONBLOCK) == -1)
490             warn("couldn't set loopback to nonblock: %m");
491
492     ppp_fd = loop_slave;
493     if (ioctl(ppp_fd, TIOCSETD, &pppdisc) < 0)
494         fatal("ioctl(TIOCSETD): %m");
495
496     /*
497      * Find out which interface we were given.
498      */
499     if (ioctl(ppp_fd, PPPIOCGUNIT, &ifunit) < 0)
500         fatal("ioctl(PPPIOCGUNIT): %m");
501
502     /*
503      * Enable debug in the driver if requested.
504      */
505     if (kdebugflag) {
506         if (ioctl(ppp_fd, PPPIOCGFLAGS, (caddr_t) &flags) < 0) {
507             warn("ioctl (PPPIOCGFLAGS): %m");
508         } else {
509             flags |= (kdebugflag & 0xFF) * SC_DEBUG;
510             if (ioctl(ppp_fd, PPPIOCSFLAGS, (caddr_t) &flags) < 0)
511                 warn("ioctl(PPPIOCSFLAGS): %m");
512         }
513     }
514
515 }
516
517
518 /*
519  * output - Output PPP packet.
520  */
521 void
522 output(unit, p, len)
523     int unit;
524     u_char *p;
525     int len;
526 {
527     if (debug)
528         dbglog("sent %P", p, len);
529
530     if (write(ttyfd, p, len) < 0) {
531         if (errno != EIO)
532             error("write: %m");
533     }
534 }
535
536
537 /*
538  * wait_input - wait until there is data available,
539  * for the length of time specified by *timo (indefinite
540  * if timo is NULL).
541  */
542 void
543 wait_input(timo)
544     struct timeval *timo;
545 {
546     fd_set ready;
547     int n;
548
549     ready = in_fds;
550     n = select(max_in_fd + 1, &ready, NULL, &ready, timo);
551     if (n < 0 && errno != EINTR)
552         fatal("select: %m");
553 }
554
555
556 /*
557  * add_fd - add an fd to the set that wait_input waits for.
558  */
559 void add_fd(int fd)
560 {
561     FD_SET(fd, &in_fds);
562     if (fd > max_in_fd)
563         max_in_fd = fd;
564 }
565
566 /*
567  * remove_fd - remove an fd from the set that wait_input waits for.
568  */
569 void remove_fd(int fd)
570 {
571     FD_CLR(fd, &in_fds);
572 }
573
574 #if 0
575 /*
576  * wait_loop_output - wait until there is data available on the
577  * loopback, for the length of time specified by *timo (indefinite
578  * if timo is NULL).
579  */
580 void
581 wait_loop_output(timo)
582     struct timeval *timo;
583 {
584     fd_set ready;
585     int n;
586
587     FD_ZERO(&ready);
588     FD_SET(loop_master, &ready);
589     n = select(loop_master + 1, &ready, NULL, &ready, timo);
590     if (n < 0 && errno != EINTR)
591         fatal("select: %m");
592 }
593
594
595 /*
596  * wait_time - wait for a given length of time or until a
597  * signal is received.
598  */
599 void
600 wait_time(timo)
601     struct timeval *timo;
602 {
603     int n;
604
605     n = select(0, NULL, NULL, NULL, timo);
606     if (n < 0 && errno != EINTR)
607         fatal("select: %m");
608 }
609 #endif
610
611
612 /*
613  * read_packet - get a PPP packet from the serial device.
614  */
615 int
616 read_packet(buf)
617     u_char *buf;
618 {
619     int len;
620
621     if ((len = read(ttyfd, buf, PPP_MTU + PPP_HDRLEN)) < 0) {
622         if (errno == EWOULDBLOCK || errno == EINTR)
623             return -1;
624         fatal("read: %m");
625     }
626     return len;
627 }
628
629
630 /*
631  * get_loop_output - read characters from the loopback, form them
632  * into frames, and detect when we want to bring the real link up.
633  * Return value is 1 if we need to bring up the link, 0 otherwise.
634  */
635 int
636 get_loop_output()
637 {
638     int rv = 0;
639     int n;
640
641     while ((n = read(loop_master, inbuf, sizeof(inbuf))) >= 0) {
642         if (loop_chars(inbuf, n))
643             rv = 1;
644     }
645
646     if (n == 0)
647         fatal("eof on loopback");
648     if (errno != EWOULDBLOCK)
649         fatal("read from loopback: %m");
650
651     return rv;
652 }
653
654
655 /*
656  * ppp_send_config - configure the transmit characteristics of
657  * the ppp interface.
658  */
659 void
660 ppp_send_config(unit, mtu, asyncmap, pcomp, accomp)
661     int unit, mtu;
662     u_int32_t asyncmap;
663     int pcomp, accomp;
664 {
665     u_int x;
666     struct ifreq ifr;
667
668     strlcpy(ifr.ifr_name, sizeof (ifr.ifr_name), ifname);
669     ifr.ifr_mtu = mtu;
670     if (ioctl(sockfd, SIOCSIFMTU, (caddr_t) &ifr) < 0)
671         fatal("ioctl(SIOCSIFMTU): %m");
672
673     if (ioctl(ppp_fd, PPPIOCSASYNCMAP, (caddr_t) &asyncmap) < 0)
674         fatal("ioctl(PPPIOCSASYNCMAP): %m");
675
676     if (ioctl(ppp_fd, PPPIOCGFLAGS, (caddr_t) &x) < 0)
677         fatal("ioctl (PPPIOCGFLAGS): %m");
678     x = pcomp? x | SC_COMP_PROT: x &~ SC_COMP_PROT;
679     x = accomp? x | SC_COMP_AC: x &~ SC_COMP_AC;
680     if (ioctl(ppp_fd, PPPIOCSFLAGS, (caddr_t) &x) < 0)
681         fatal("ioctl(PPPIOCSFLAGS): %m");
682 }
683
684
685 /*
686  * ppp_set_xaccm - set the extended transmit ACCM for the interface.
687  */
688 void
689 ppp_set_xaccm(unit, accm)
690     int unit;
691     ext_accm accm;
692 {
693     if (ioctl(ppp_fd, PPPIOCSXASYNCMAP, accm) < 0 && errno != ENOTTY)
694         warn("ioctl(set extended ACCM): %m");
695 }
696
697
698 /*
699  * ppp_recv_config - configure the receive-side characteristics of
700  * the ppp interface.
701  */
702 void
703 ppp_recv_config(unit, mru, asyncmap, pcomp, accomp)
704     int unit, mru;
705     u_int32_t asyncmap;
706     int pcomp, accomp;
707 {
708     int x;
709
710     if (ioctl(ppp_fd, PPPIOCSMRU, (caddr_t) &mru) < 0)
711         fatal("ioctl(PPPIOCSMRU): %m");
712     if (ioctl(ppp_fd, PPPIOCSRASYNCMAP, (caddr_t) &asyncmap) < 0)
713         fatal("ioctl(PPPIOCSRASYNCMAP): %m");
714     if (ioctl(ppp_fd, PPPIOCGFLAGS, (caddr_t) &x) < 0)
715         fatal("ioctl (PPPIOCGFLAGS): %m");
716     x = !accomp? x | SC_REJ_COMP_AC: x &~ SC_REJ_COMP_AC;
717     if (ioctl(ppp_fd, PPPIOCSFLAGS, (caddr_t) &x) < 0)
718         fatal("ioctl(PPPIOCSFLAGS): %m");
719 }
720
721 /*
722  * ccp_test - ask kernel whether a given compression method
723  * is acceptable for use.  Returns 1 if the method and parameters
724  * are OK, 0 if the method is known but the parameters are not OK
725  * (e.g. code size should be reduced), or -1 if the method is unknown.
726  */
727 int
728 ccp_test(unit, opt_ptr, opt_len, for_transmit)
729     int unit, opt_len, for_transmit;
730     u_char *opt_ptr;
731 {
732     struct ppp_option_data data;
733
734     data.ptr = opt_ptr;
735     data.length = opt_len;
736     data.transmit = for_transmit;
737     if (ioctl(ttyfd, PPPIOCSCOMPRESS, (caddr_t) &data) >= 0)
738         return 1;
739     return (errno == ENOBUFS)? 0: -1;
740 }
741
742 /*
743  * ccp_flags_set - inform kernel about the current state of CCP.
744  */
745 void
746 ccp_flags_set(unit, isopen, isup)
747     int unit, isopen, isup;
748 {
749     int x;
750
751     if (ioctl(ppp_fd, PPPIOCGFLAGS, (caddr_t) &x) < 0) {
752         error("ioctl (PPPIOCGFLAGS): %m");
753         return;
754     }
755     x = isopen? x | SC_CCP_OPEN: x &~ SC_CCP_OPEN;
756     x = isup? x | SC_CCP_UP: x &~ SC_CCP_UP;
757     if (ioctl(ppp_fd, PPPIOCSFLAGS, (caddr_t) &x) < 0)
758         error("ioctl(PPPIOCSFLAGS): %m");
759 }
760
761 /*
762  * ccp_fatal_error - returns 1 if decompression was disabled as a
763  * result of an error detected after decompression of a packet,
764  * 0 otherwise.  This is necessary because of patent nonsense.
765  */
766 int
767 ccp_fatal_error(unit)
768     int unit;
769 {
770     int x;
771
772     if (ioctl(ppp_fd, PPPIOCGFLAGS, (caddr_t) &x) < 0) {
773         error("ioctl(PPPIOCGFLAGS): %m");
774         return 0;
775     }
776     return x & SC_DC_FERROR;
777 }
778
779 /*
780  * get_idle_time - return how long the link has been idle.
781  */
782 int
783 get_idle_time(u, ip)
784     int u;
785     struct ppp_idle *ip;
786 {
787     return ioctl(ppp_fd, PPPIOCGIDLE, ip) >= 0;
788 }
789
790
791 #ifdef PPP_FILTER
792 /*
793  * set_filters - transfer the pass and active filters to the kernel.
794  */
795 int
796 set_filters(pass, active)
797     struct bpf_program *pass, *active;
798 {
799     int ret = 1;
800
801     if (pass->bf_len > 0) {
802         if (ioctl(ppp_fd, PPPIOCSPASS, pass) < 0) {
803             error("Couldn't set pass-filter in kernel: %m");
804             ret = 0;
805         }
806     }
807     if (active->bf_len > 0) {
808         if (ioctl(ppp_fd, PPPIOCSACTIVE, active) < 0) {
809             error("Couldn't set active-filter in kernel: %m");
810             ret = 0;
811         }
812     }
813     return ret;
814 }
815 #endif
816
817 /*
818  * sifvjcomp - config tcp header compression
819  */
820 int
821 sifvjcomp(u, vjcomp, cidcomp, maxcid)
822     int u, vjcomp, cidcomp, maxcid;
823 {
824     u_int x;
825
826     if (ioctl(ppp_fd, PPPIOCGFLAGS, (caddr_t) &x) < 0) {
827         error("ioctl (PPPIOCGFLAGS): %m");
828         return 0;
829     }
830     x = vjcomp ? x | SC_COMP_TCP: x &~ SC_COMP_TCP;
831     x = cidcomp? x & ~SC_NO_TCP_CCID: x | SC_NO_TCP_CCID;
832     if (ioctl(ppp_fd, PPPIOCSFLAGS, (caddr_t) &x) < 0) {
833         error("ioctl(PPPIOCSFLAGS): %m");
834         return 0;
835     }
836     if (vjcomp && ioctl(ppp_fd, PPPIOCSMAXCID, (caddr_t) &maxcid) < 0) {
837         error("ioctl(PPPIOCSFLAGS): %m");
838         return 0;
839     }
840     return 1;
841 }
842
843 /*
844  * sifup - Config the interface up and enable IP packets to pass.
845  */
846 int
847 sifup(u)
848     int u;
849 {
850     struct ifreq ifr;
851
852     strlcpy(ifr.ifr_name, sizeof (ifr.ifr_name), ifname);
853     if (ioctl(sockfd, SIOCGIFFLAGS, (caddr_t) &ifr) < 0) {
854         error("ioctl (SIOCGIFFLAGS): %m");
855         return 0;
856     }
857     ifr.ifr_flags |= IFF_UP;
858     if (ioctl(sockfd, SIOCSIFFLAGS, (caddr_t) &ifr) < 0) {
859         error("ioctl(SIOCSIFFLAGS): %m");
860         return 0;
861     }
862     if_is_up = 1;
863     return 1;
864 }
865
866 /*
867  * sifnpmode - Set the mode for handling packets for a given NP.
868  */
869 int
870 sifnpmode(u, proto, mode)
871     int u;
872     int proto;
873     enum NPmode mode;
874 {
875     struct npioctl npi;
876
877     npi.protocol = proto;
878     npi.mode = mode;
879     if (ioctl(ppp_fd, PPPIOCSNPMODE, &npi) < 0) {
880         error("ioctl(set NP %d mode to %d): %m", proto, mode);
881         return 0;
882     }
883     return 1;
884 }
885
886 /*
887  * sifdown - Config the interface down and disable IP.
888  */
889 int
890 sifdown(u)
891     int u;
892 {
893     struct ifreq ifr;
894     int rv;
895     struct npioctl npi;
896
897     rv = 1;
898     npi.protocol = PPP_IP;
899     npi.mode = NPMODE_ERROR;
900     ioctl(ppp_fd, PPPIOCSNPMODE, (caddr_t) &npi);
901     /* ignore errors, because ppp_fd might have been closed by now. */
902
903     strlcpy(ifr.ifr_name, sizeof (ifr.ifr_name), ifname);
904     if (ioctl(sockfd, SIOCGIFFLAGS, (caddr_t) &ifr) < 0) {
905         error("ioctl (SIOCGIFFLAGS): %m");
906         rv = 0;
907     } else {
908         ifr.ifr_flags &= ~IFF_UP;
909         if (ioctl(sockfd, SIOCSIFFLAGS, (caddr_t) &ifr) < 0) {
910             error("ioctl(SIOCSIFFLAGS): %m");
911             rv = 0;
912         } else
913             if_is_up = 0;
914     }
915     return rv;
916 }
917
918 /*
919  * SET_SA_FAMILY - set the sa_family field of a struct sockaddr,
920  * if it exists.
921  */
922 #define SET_SA_FAMILY(addr, family)             \
923     BZERO((char *) &(addr), sizeof(addr));      \
924     addr.sa_family = (family);                  \
925     addr.sa_len = sizeof(addr);
926
927 /*
928  * sifaddr - Config the interface IP addresses and netmask.
929  */
930 int
931 sifaddr(u, o, h, m)
932     int u;
933     u_int32_t o, h, m;
934 {
935     struct ifaliasreq ifra;
936     struct ifreq ifr;
937
938     strlcpy(ifra.ifra_name, sizeof(ifra.ifra_name), ifname);
939     SET_SA_FAMILY(ifra.ifra_addr, AF_INET);
940     ((struct sockaddr_in *) &ifra.ifra_addr)->sin_addr.s_addr = o;
941     SET_SA_FAMILY(ifra.ifra_broadaddr, AF_INET);
942     ((struct sockaddr_in *) &ifra.ifra_broadaddr)->sin_addr.s_addr = h;
943     if (m != 0) {
944         SET_SA_FAMILY(ifra.ifra_mask, AF_INET);
945         ((struct sockaddr_in *) &ifra.ifra_mask)->sin_addr.s_addr = m;
946     } else
947         BZERO(&ifra.ifra_mask, sizeof(ifra.ifra_mask));
948     BZERO(&ifr, sizeof(ifr));
949     strlcpy(ifr.ifr_name, sizeof(ifr.ifr_name), ifname);
950     if (ioctl(sockfd, SIOCDIFADDR, (caddr_t) &ifr) < 0) {
951         if (errno != EADDRNOTAVAIL)
952             warn("Couldn't remove interface address: %m");
953     }
954     if (ioctl(sockfd, SIOCAIFADDR, (caddr_t) &ifra) < 0) {
955         if (errno != EEXIST) {
956             error("Couldn't set interface address: %m");
957             return 0;
958         }
959         warn("Couldn't set interface address: Address %I already exists", o);
960     }
961     ifaddrs[0] = o;
962     ifaddrs[1] = h;
963     return 1;
964 }
965
966 /*
967  * cifaddr - Clear the interface IP addresses, and delete routes
968  * through the interface if possible.
969  */
970 int
971 cifaddr(u, o, h)
972     int u;
973     u_int32_t o, h;
974 {
975     struct ifaliasreq ifra;
976
977     ifaddrs[0] = 0;
978     strlcpy(ifra.ifra_name, sizeof(ifra.ifra_name), ifname);
979     SET_SA_FAMILY(ifra.ifra_addr, AF_INET);
980     ((struct sockaddr_in *) &ifra.ifra_addr)->sin_addr.s_addr = o;
981     SET_SA_FAMILY(ifra.ifra_broadaddr, AF_INET);
982     ((struct sockaddr_in *) &ifra.ifra_broadaddr)->sin_addr.s_addr = h;
983     BZERO(&ifra.ifra_mask, sizeof(ifra.ifra_mask));
984     if (ioctl(sockfd, SIOCDIFADDR, (caddr_t) &ifra) < 0) {
985         if (errno != EADDRNOTAVAIL)
986             warn("Couldn't delete interface address: %m");
987         return 0;
988     }
989     return 1;
990 }
991
992 /*
993  * sifdefaultroute - assign a default route through the address given.
994  */
995 int
996 sifdefaultroute(u, l, g)
997     int u;
998     u_int32_t l, g;
999 {
1000     return dodefaultroute(g, 's');
1001 }
1002
1003 /*
1004  * cifdefaultroute - delete a default route through the address given.
1005  */
1006 int
1007 cifdefaultroute(u, l, g)
1008     int u;
1009     u_int32_t l, g;
1010 {
1011     return dodefaultroute(g, 'c');
1012 }
1013
1014 /*
1015  * dodefaultroute - talk to a routing socket to add/delete a default route.
1016  */
1017 static int
1018 dodefaultroute(g, cmd)
1019     u_int32_t g;
1020     int cmd;
1021 {
1022     int routes;
1023     struct {
1024         struct rt_msghdr        hdr;
1025         struct sockaddr_in      dst;
1026         struct sockaddr_in      gway;
1027         struct sockaddr_in      mask;
1028     } rtmsg;
1029
1030     if ((routes = socket(PF_ROUTE, SOCK_RAW, AF_INET)) < 0) {
1031         error("Couldn't %s default route: socket: %m",
1032                cmd=='s'? "add": "delete");
1033         return 0;
1034     }
1035
1036     memset(&rtmsg, 0, sizeof(rtmsg));
1037     rtmsg.hdr.rtm_type = cmd == 's'? RTM_ADD: RTM_DELETE;
1038     rtmsg.hdr.rtm_flags = RTF_UP | RTF_GATEWAY | RTF_STATIC;
1039     rtmsg.hdr.rtm_version = RTM_VERSION;
1040     rtmsg.hdr.rtm_seq = ++rtm_seq;
1041     rtmsg.hdr.rtm_addrs = RTA_DST | RTA_GATEWAY | RTA_NETMASK;
1042     rtmsg.dst.sin_len = sizeof(rtmsg.dst);
1043     rtmsg.dst.sin_family = AF_INET;
1044     rtmsg.gway.sin_len = sizeof(rtmsg.gway);
1045     rtmsg.gway.sin_family = AF_INET;
1046     rtmsg.gway.sin_addr.s_addr = g;
1047     rtmsg.mask.sin_len = sizeof(rtmsg.dst);
1048     rtmsg.mask.sin_family = AF_INET;
1049
1050     rtmsg.hdr.rtm_msglen = sizeof(rtmsg);
1051     if (write(routes, &rtmsg, sizeof(rtmsg)) < 0) {
1052         error("Couldn't %s default route: %m",
1053                cmd=='s'? "add": "delete");
1054         close(routes);
1055         return 0;
1056     }
1057
1058     close(routes);
1059     default_route_gateway = (cmd == 's')? g: 0;
1060     return 1;
1061 }
1062
1063 #if RTM_VERSION >= 3
1064
1065 /*
1066  * sifproxyarp - Make a proxy ARP entry for the peer.
1067  */
1068 static struct {
1069     struct rt_msghdr            hdr;
1070     struct sockaddr_inarp       dst;
1071     struct sockaddr_dl          hwa;
1072     char                        extra[128];
1073 } arpmsg;
1074
1075 static int arpmsg_valid;
1076
1077 int
1078 sifproxyarp(unit, hisaddr)
1079     int unit;
1080     u_int32_t hisaddr;
1081 {
1082     int routes;
1083
1084     /*
1085      * Get the hardware address of an interface on the same subnet
1086      * as our local address.
1087      */
1088     memset(&arpmsg, 0, sizeof(arpmsg));
1089     if (!get_ether_addr(hisaddr, &arpmsg.hwa)) {
1090         error("Cannot determine ethernet address for proxy ARP");
1091         return 0;
1092     }
1093
1094     if ((routes = socket(PF_ROUTE, SOCK_RAW, AF_INET)) < 0) {
1095         error("Couldn't add proxy arp entry: socket: %m");
1096         return 0;
1097     }
1098
1099     arpmsg.hdr.rtm_type = RTM_ADD;
1100     arpmsg.hdr.rtm_flags = RTF_ANNOUNCE | RTF_HOST | RTF_STATIC;
1101     arpmsg.hdr.rtm_version = RTM_VERSION;
1102     arpmsg.hdr.rtm_seq = ++rtm_seq;
1103     arpmsg.hdr.rtm_addrs = RTA_DST | RTA_GATEWAY;
1104     arpmsg.hdr.rtm_inits = RTV_EXPIRE;
1105     arpmsg.dst.sin_len = sizeof(struct sockaddr_inarp);
1106     arpmsg.dst.sin_family = AF_INET;
1107     arpmsg.dst.sin_addr.s_addr = hisaddr;
1108     arpmsg.dst.sin_other = SIN_PROXY;
1109
1110     arpmsg.hdr.rtm_msglen = (char *) &arpmsg.hwa - (char *) &arpmsg
1111         + arpmsg.hwa.sdl_len;
1112     if (write(routes, &arpmsg, arpmsg.hdr.rtm_msglen) < 0) {
1113         error("Couldn't add proxy arp entry: %m");
1114         close(routes);
1115         return 0;
1116     }
1117
1118     close(routes);
1119     arpmsg_valid = 1;
1120     proxy_arp_addr = hisaddr;
1121     return 1;
1122 }
1123
1124 /*
1125  * cifproxyarp - Delete the proxy ARP entry for the peer.
1126  */
1127 int
1128 cifproxyarp(unit, hisaddr)
1129     int unit;
1130     u_int32_t hisaddr;
1131 {
1132     int routes;
1133
1134     if (!arpmsg_valid)
1135         return 0;
1136     arpmsg_valid = 0;
1137
1138     arpmsg.hdr.rtm_type = RTM_DELETE;
1139     arpmsg.hdr.rtm_seq = ++rtm_seq;
1140
1141     if ((routes = socket(PF_ROUTE, SOCK_RAW, AF_INET)) < 0) {
1142         error("Couldn't delete proxy arp entry: socket: %m");
1143         return 0;
1144     }
1145
1146     if (write(routes, &arpmsg, arpmsg.hdr.rtm_msglen) < 0) {
1147         error("Couldn't delete proxy arp entry: %m");
1148         close(routes);
1149         return 0;
1150     }
1151
1152     close(routes);
1153     proxy_arp_addr = 0;
1154     return 1;
1155 }
1156
1157 #else   /* RTM_VERSION */
1158
1159 /*
1160  * sifproxyarp - Make a proxy ARP entry for the peer.
1161  */
1162 int
1163 sifproxyarp(unit, hisaddr)
1164     int unit;
1165     u_int32_t hisaddr;
1166 {
1167     struct arpreq arpreq;
1168     struct {
1169         struct sockaddr_dl      sdl;
1170         char                    space[128];
1171     } dls;
1172
1173     BZERO(&arpreq, sizeof(arpreq));
1174
1175     /*
1176      * Get the hardware address of an interface on the same subnet
1177      * as our local address.
1178      */
1179     if (!get_ether_addr(hisaddr, &dls.sdl)) {
1180         error("Cannot determine ethernet address for proxy ARP");
1181         return 0;
1182     }
1183
1184     arpreq.arp_ha.sa_len = sizeof(struct sockaddr);
1185     arpreq.arp_ha.sa_family = AF_UNSPEC;
1186     BCOPY(LLADDR(&dls.sdl), arpreq.arp_ha.sa_data, dls.sdl.sdl_alen);
1187     SET_SA_FAMILY(arpreq.arp_pa, AF_INET);
1188     ((struct sockaddr_in *) &arpreq.arp_pa)->sin_addr.s_addr = hisaddr;
1189     arpreq.arp_flags = ATF_PERM | ATF_PUBL;
1190     if (ioctl(sockfd, SIOCSARP, (caddr_t)&arpreq) < 0) {
1191         error("Couldn't add proxy arp entry: %m");
1192         return 0;
1193     }
1194
1195     proxy_arp_addr = hisaddr;
1196     return 1;
1197 }
1198
1199 /*
1200  * cifproxyarp - Delete the proxy ARP entry for the peer.
1201  */
1202 int
1203 cifproxyarp(unit, hisaddr)
1204     int unit;
1205     u_int32_t hisaddr;
1206 {
1207     struct arpreq arpreq;
1208
1209     BZERO(&arpreq, sizeof(arpreq));
1210     SET_SA_FAMILY(arpreq.arp_pa, AF_INET);
1211     ((struct sockaddr_in *) &arpreq.arp_pa)->sin_addr.s_addr = hisaddr;
1212     if (ioctl(sockfd, SIOCDARP, (caddr_t)&arpreq) < 0) {
1213         warn("Couldn't delete proxy arp entry: %m");
1214         return 0;
1215     }
1216     proxy_arp_addr = 0;
1217     return 1;
1218 }
1219 #endif  /* RTM_VERSION */
1220
1221
1222 /*
1223  * get_ether_addr - get the hardware address of an interface on the
1224  * the same subnet as ipaddr.
1225  */
1226 #define MAX_IFS         32
1227
1228 static int
1229 get_ether_addr(ipaddr, hwaddr)
1230     u_int32_t ipaddr;
1231     struct sockaddr_dl *hwaddr;
1232 {
1233     struct ifreq *ifr, *ifend, *ifp;
1234     u_int32_t ina, mask;
1235     struct sockaddr_dl *dla;
1236     struct ifreq ifreq;
1237     struct ifconf ifc;
1238     struct ifreq ifs[MAX_IFS];
1239
1240     ifc.ifc_len = sizeof(ifs);
1241     ifc.ifc_req = ifs;
1242     if (ioctl(sockfd, SIOCGIFCONF, &ifc) < 0) {
1243         error("ioctl(SIOCGIFCONF): %m");
1244         return 0;
1245     }
1246
1247     /*
1248      * Scan through looking for an interface with an Internet
1249      * address on the same subnet as `ipaddr'.
1250      */
1251     ifend = (struct ifreq *) (ifc.ifc_buf + ifc.ifc_len);
1252     for (ifr = ifc.ifc_req; ifr < ifend; ifr = (struct ifreq *)
1253                 ((char *)&ifr->ifr_addr + ifr->ifr_addr.sa_len)) {
1254         if (ifr->ifr_addr.sa_family == AF_INET) {
1255             ina = ((struct sockaddr_in *) &ifr->ifr_addr)->sin_addr.s_addr;
1256             strlcpy(ifreq.ifr_name, sizeof(ifreq.ifr_name), ifr->ifr_name);
1257             /*
1258              * Check that the interface is up, and not point-to-point
1259              * or loopback.
1260              */
1261             if (ioctl(sockfd, SIOCGIFFLAGS, &ifreq) < 0)
1262                 continue;
1263             if ((ifreq.ifr_flags &
1264                  (IFF_UP|IFF_BROADCAST|IFF_POINTOPOINT|IFF_LOOPBACK|IFF_NOARP))
1265                  != (IFF_UP|IFF_BROADCAST))
1266                 continue;
1267             /*
1268              * Get its netmask and check that it's on the right subnet.
1269              */
1270             if (ioctl(sockfd, SIOCGIFNETMASK, &ifreq) < 0)
1271                 continue;
1272             mask = ((struct sockaddr_in *) &ifreq.ifr_addr)->sin_addr.s_addr;
1273             if ((ipaddr & mask) != (ina & mask))
1274                 continue;
1275
1276             break;
1277         }
1278     }
1279
1280     if (ifr >= ifend)
1281         return 0;
1282     info("found interface %s for proxy arp", ifr->ifr_name);
1283
1284     /*
1285      * Now scan through again looking for a link-level address
1286      * for this interface.
1287      */
1288     ifp = ifr;
1289     for (ifr = ifc.ifc_req; ifr < ifend; ) {
1290         if (strcmp(ifp->ifr_name, ifr->ifr_name) == 0
1291             && ifr->ifr_addr.sa_family == AF_LINK) {
1292             /*
1293              * Found the link-level address - copy it out
1294              */
1295             dla = (struct sockaddr_dl *) &ifr->ifr_addr;
1296             BCOPY(dla, hwaddr, dla->sdl_len);
1297             return 1;
1298         }
1299         ifr = (struct ifreq *) ((char *)&ifr->ifr_addr + ifr->ifr_addr.sa_len);
1300     }
1301
1302     return 0;
1303 }
1304
1305 /*
1306  * Return user specified netmask, modified by any mask we might determine
1307  * for address `addr' (in network byte order).
1308  * Here we scan through the system's list of interfaces, looking for
1309  * any non-point-to-point interfaces which might appear to be on the same
1310  * network as `addr'.  If we find any, we OR in their netmask to the
1311  * user-specified netmask.
1312  */
1313 u_int32_t
1314 GetMask(addr)
1315     u_int32_t addr;
1316 {
1317     u_int32_t mask, nmask, ina;
1318     struct ifreq *ifr, *ifend, ifreq;
1319     struct ifconf ifc;
1320     struct ifreq ifs[MAX_IFS];
1321
1322     addr = ntohl(addr);
1323     if (IN_CLASSA(addr))        /* determine network mask for address class */
1324         nmask = IN_CLASSA_NET;
1325     else if (IN_CLASSB(addr))
1326         nmask = IN_CLASSB_NET;
1327     else
1328         nmask = IN_CLASSC_NET;
1329     /* class D nets are disallowed by bad_ip_adrs */
1330     mask = netmask | htonl(nmask);
1331
1332     /*
1333      * Scan through the system's network interfaces.
1334      */
1335     ifc.ifc_len = sizeof(ifs);
1336     ifc.ifc_req = ifs;
1337     if (ioctl(sockfd, SIOCGIFCONF, &ifc) < 0) {
1338         warn("ioctl(SIOCGIFCONF): %m");
1339         return mask;
1340     }
1341     ifend = (struct ifreq *) (ifc.ifc_buf + ifc.ifc_len);
1342     for (ifr = ifc.ifc_req; ifr < ifend; ifr = (struct ifreq *)
1343                 ((char *)&ifr->ifr_addr + ifr->ifr_addr.sa_len)) {
1344         /*
1345          * Check the interface's internet address.
1346          */
1347         if (ifr->ifr_addr.sa_family != AF_INET)
1348             continue;
1349         ina = ((struct sockaddr_in *) &ifr->ifr_addr)->sin_addr.s_addr;
1350         if ((ntohl(ina) & nmask) != (addr & nmask))
1351             continue;
1352         /*
1353          * Check that the interface is up, and not point-to-point or loopback.
1354          */
1355         strlcpy(ifreq.ifr_name, sizeof(ifreq.ifr_name), ifr->ifr_name);
1356         if (ioctl(sockfd, SIOCGIFFLAGS, &ifreq) < 0)
1357             continue;
1358         if ((ifreq.ifr_flags & (IFF_UP|IFF_POINTOPOINT|IFF_LOOPBACK))
1359             != IFF_UP)
1360             continue;
1361         /*
1362          * Get its netmask and OR it into our mask.
1363          */
1364         if (ioctl(sockfd, SIOCGIFNETMASK, &ifreq) < 0)
1365             continue;
1366         mask |= ((struct sockaddr_in *)&ifreq.ifr_addr)->sin_addr.s_addr;
1367     }
1368
1369     return mask;
1370 }
1371
1372 /*
1373  * have_route_to - determine if the system has any route to
1374  * a given IP address.
1375  * For demand mode to work properly, we have to ignore routes
1376  * through our own interface.
1377  */
1378 int have_route_to(u_int32_t addr)
1379 {
1380     return -1;
1381 }
1382
1383 /*
1384  * Use the hostid as part of the random number seed.
1385  */
1386 int
1387 get_host_seed()
1388 {
1389     return gethostid();
1390 }
1391
1392 /*
1393  * lock - create a lock file for the named lock device
1394  */
1395 #define LOCK_PREFIX     "/var/spool/lock/LCK.."
1396
1397 int
1398 lock(dev)
1399     char *dev;
1400 {
1401     char hdb_lock_buffer[12];
1402     int fd, pid, n;
1403     char *p;
1404     size_t l;
1405
1406     if ((p = strrchr(dev, '/')) != NULL)
1407         dev = p + 1;
1408     l = strlen(LOCK_PREFIX) + strlen(dev) + 1;
1409     lock_file = malloc(l);
1410     if (lock_file == NULL)
1411         novm("lock file name");
1412     slprintf(lock_file, l, "%s%s", LOCK_PREFIX, dev);
1413
1414     while ((fd = open(lock_file, O_EXCL | O_CREAT | O_RDWR, 0644)) < 0) {
1415         if (errno == EEXIST
1416             && (fd = open(lock_file, O_RDONLY, 0)) >= 0) {
1417             /* Read the lock file to find out who has the device locked */
1418             n = read(fd, hdb_lock_buffer, 11);
1419             if (n <= 0) {
1420                 error("Can't read pid from lock file %s", lock_file);
1421                 close(fd);
1422             } else {
1423                 hdb_lock_buffer[n] = 0;
1424                 pid = atoi(hdb_lock_buffer);
1425                 if (kill(pid, 0) == -1 && errno == ESRCH) {
1426                     /* pid no longer exists - remove the lock file */
1427                     if (unlink(lock_file) == 0) {
1428                         close(fd);
1429                         notice("Removed stale lock on %s (pid %d)",
1430                                dev, pid);
1431                         continue;
1432                     } else
1433                         warn("Couldn't remove stale lock on %s",
1434                                dev);
1435                 } else
1436                     notice("Device %s is locked by pid %d",
1437                            dev, pid);
1438             }
1439             close(fd);
1440         } else
1441             error("Can't create lock file %s: %m", lock_file);
1442         free(lock_file);
1443         lock_file = NULL;
1444         return -1;
1445     }
1446
1447     slprintf(hdb_lock_buffer, sizeof(hdb_lock_buffer), "%10d\n", getpid());
1448     write(fd, hdb_lock_buffer, 11);
1449
1450     close(fd);
1451     return 0;
1452 }
1453
1454 /*
1455  * unlock - remove our lockfile
1456  */
1457 void
1458 unlock()
1459 {
1460     if (lock_file) {
1461         unlink(lock_file);
1462         free(lock_file);
1463         lock_file = NULL;
1464     }
1465 }